Home
last modified time | relevance | path

Searched refs:thread (Results 126 - 150 of 914) sorted by relevance

12345678910>>...37

/third_party/python/Lib/test/
H A Dtest_queue.py25 # A thread to run a function that unclogs a blocked Queue.
35 # function in the main thread a chance at actually blocking before
47 # Execute a function that blocks, and in a separate thread, a function that
61 thread = _TriggerThread(trigger_func, trigger_args)
62 thread.start()
65 # If block_func returned before our thread made the call, we failed!
66 if not thread.startedEvent.is_set():
71 threading_helper.join_thread(thread) # make sure the thread terminates
76 thread
[all...]
/third_party/node/src/
H A Djs_native_api_v8_inspector.cc130 // Used from any thread
143 static T* get(MainThreadInterface* thread, int id) { in get() argument
145 static_cast<DeletableWrapper<T>*>(thread->GetObject(id))->object_.get(); in get()
164 void Call(MainThreadInterface* thread) override {
165 thread->AddObject(object_id_, WrapInDeletable(factory_(thread)));
183 void Call(MainThreadInterface* thread) override {
184 thread->RemoveObject(object_id_);
196 void Call(MainThreadInterface* thread) override {
197 fn_(DeletableWrapper<Target>::get(thread, id
208 AnotherThreadObjectReference( std::shared_ptr<MainThreadHandle> thread, int object_id) AnotherThreadObjectReference() argument
213 AnotherThreadObjectReference( std::shared_ptr<MainThreadHandle> thread, Factory factory) AnotherThreadObjectReference() argument
252 MainThreadSessionState(MainThreadInterface* thread, bool prevent_shutdown) MainThreadSessionState() argument
256 Create( MainThreadInterface* thread, bool prevent_shutdown) Create() argument
279 CrossThreadInspectorSession( int id, std::shared_ptr<MainThreadHandle> thread, std::unique_ptr<InspectorSessionDelegate> delegate, bool prevent_shutdown) CrossThreadInspectorSession() argument
301 ThreadSafeDelegate(std::shared_ptr<MainThreadHandle> thread, int object_id) ThreadSafeDelegate() argument
[all...]
/third_party/libuv/test/
H A Dtest-async-null-cb.c29 static uv_thread_t thread; variable
58 ASSERT_OK(uv_thread_create(&thread, thread_cb, NULL)); in TEST_IMPL()
60 ASSERT_OK(uv_thread_join(&thread)); in TEST_IMPL()
/third_party/musl/src/thread/
H A Dpthread_setname_np.c9 int pthread_setname_np(pthread_t thread, const char *name) in pthread_setname_np() argument
17 if (thread == pthread_self()) in pthread_setname_np()
20 snprintf(f, sizeof f, "/proc/self/task/%d/comm", thread->tid); in pthread_setname_np()
H A Dpthread_getname_np.c8 int pthread_getname_np(pthread_t thread, char *name, size_t len) in pthread_getname_np() argument
15 if (thread == pthread_self()) in pthread_getname_np()
18 snprintf(f, sizeof f, "/proc/self/task/%d/comm", thread->tid); in pthread_getname_np()
H A Dpthread_create.c84 * call; the loser is responsible for freeing thread resources. */ in __pthread_exit()
95 /* Access to target the exiting thread with syscalls that use in __pthread_exit()
102 /* The thread list lock must be AS-safe, and thus depends on in __pthread_exit()
106 /* If this is the only thread in the list, don't proceed with in __pthread_exit()
107 * termination of the thread, but restore the previous lock and in __pthread_exit()
117 /* At this point we are committed to thread termination. */ in __pthread_exit()
119 /* After the kernel thread exits, its tid may be reused. Clear it in __pthread_exit()
123 * see the thread as having exited. Release it now so that no in __pthread_exit()
124 * remaining locks (except thread list) are held if we end up in __pthread_exit()
130 * and the detached thread cas in __pthread_exit()
410 struct pthread *thread = (struct pthread *)thread_id; __pthread_list_find() local
433 struct pthread* thread = __pthread_list_find(t, "pthread_gettid_np"); __pthread_gettid_np() local
[all...]
/third_party/musl/libc-test/src/functionalext/supplement/thread/
H A Dpthread_getcpuclockid.c35 * @tc.desc : Get the specified thread clock ID
40 pthread_t thread; in pthread_getcpuclockid_0100() local
42 int ret = pthread_create(&thread, NULL, thread_func, NULL); in pthread_getcpuclockid_0100()
48 ret = pthread_getcpuclockid(thread, &cid); in pthread_getcpuclockid_0100()
H A Dpthread_spin_unlock.c41 pthread_t thread; in pthread_spin_unlock_0100() local
47 ret = pthread_create(&thread, NULL, (void *)thread1, NULL); in pthread_spin_unlock_0100()
54 pthread_join(thread, &rev); in pthread_spin_unlock_0100()
/applications/standard/app_samples/code/BasicFeature/Connectivity/VPN/entry/src/main/cpp/
H A Dvpn_client.cpp20 #include <thread>
26 #include <thread>
58 static std::thread g_threadt1;
59 static std::thread g_threadt2;
184 std::thread tt1(HandleReadTunfd, g_fdInfo); in StartVpn()
185 std::thread tt2(HandleTcpReceived, g_fdInfo); in StartVpn()
/third_party/node/src/inspector/
H A Dtracing_agent.cc23 // This should only be called from the main thread, meaning frontend should
39 void Call(MainThreadInterface* thread) override {
40 thread->AddObject(object_id_, std::move(frontend_wrapper_));
53 void Call(MainThreadInterface* thread) override {
54 thread->RemoveObject(object_id_);
66 void Call(MainThreadInterface* thread) override {
69 thread->GetObjectIfExists(object_id_));
144 "Tracing properties can only be changed through main thread sessions"); in start()
/third_party/ltp/testcases/realtime/func/pi-tests/
H A Dtestpi-7.c161 struct thread *t = (struct thread *)arg; in low_prio_rt_thread()
182 debug(DBG_INFO, "low prio thread finished (flags=%#x)\n", t->flags); in low_prio_rt_thread()
189 struct thread *t = (struct thread *)arg; in med_prio_thread()
199 debug(DBG_INFO, MP "thread %d writing flag\n", t->id); in med_prio_thread()
212 debug(DBG_INFO, MP "thread %d resetting m_flag\n", in med_prio_thread()
217 debug(DBG_INFO, "med prio thread finished\n"); in med_prio_thread()
227 struct thread *t = (struct thread *)ar in high_prio_rt_thread()
[all...]
/third_party/skia/third_party/externals/angle2/src/libANGLE/
H A DvalidationEGL.h67 const Thread *GetThreadIfValid(const Thread *thread);
75 LabeledObject *GetLabeledObjectIfValid(Thread *thread,
88 ReturnType GetDefaultReturnValue(Thread *thread);
92 GetDefaultReturnValue<angle::EntryPoint::EGLLabelObjectKHR, EGLint>(Thread *thread) in GetDefaultReturnValue() argument
94 return thread->getError(); in GetDefaultReturnValue()
98 ANGLE_INLINE ReturnType GetDefaultReturnValue(Thread *thread) in GetDefaultReturnValue() argument
/test/xts/acts/multimedia/media/media_cpp_standard/audioDecEncNdk/include/
H A DADecEncNdkSample.h24 #include <thread>
122 std::unique_ptr<std::thread> inputLoopDec_;
123 std::unique_ptr<std::thread> outputLoopDec_;
131 std::unique_ptr<std::thread> inputLoopEnc_;
132 std::unique_ptr<std::thread> outputLoopEnc_;
/third_party/skia/third_party/externals/angle2/src/tests/egl_tests/
H A DEGLContextASANTest.cpp18 #include <thread>
79 // If necessary, abort execution as the other thread has encountered a GL error. in TEST_P()
125 std::thread deletingThread = std::thread([&]() { in TEST_P()
132 // Wait for other thread to draw in TEST_P()
136 // current in another thread. in TEST_P()
139 // Wait for the other thread to use context again in TEST_P()
144 std::thread continuingThread = std::thread([&]() { in TEST_P()
171 // Wait for the other thread t in TEST_P()
[all...]
/third_party/skia/third_party/externals/microhttpd/src/include/
H A Dplatform_interface.h220 * Wait until specified thread is ended
221 * @param thread ID to watch
224 #define MHD_join_thread_(thread) pthread_join((thread), NULL)
227 * Wait until specified thread is ended
228 * Close thread handle on success
229 * @param thread handle to watch
232 #define MHD_join_thread_(thread) (WAIT_OBJECT_0 == WaitForSingleObject((thread), INFINITE) ? (CloseHandle((thread)),
[all...]
/third_party/vk-gl-cts/framework/common/
H A DtcuThreadUtil.hpp95 MessageBuilder (Thread& thread) : m_thread(thread) {} in MessageBuilder() argument
141 virtual void exec (Thread& thread) = 0; //!< Overwritten by inherited class to perform actual operation
142 virtual void execute (Thread& thread); //!< May Be overwritten by inherited class to change how syncronization is done
227 void exec (Thread& thread);
/third_party/musl/src/thread/linux/
H A Dpthread_create.c219 * call; the loser is responsible for freeing thread resources. */ in __pthread_exit()
230 /* Access to target the exiting thread with syscalls that use in __pthread_exit()
237 /* The thread list lock must be AS-safe, and thus depends on in __pthread_exit()
244 /* If this is the only thread in the list, don't proceed with in __pthread_exit()
245 * termination of the thread, but restore the previous lock and in __pthread_exit()
258 /* At this point we are committed to thread termination. */ in __pthread_exit()
260 /* After the kernel thread exits, its tid may be reused. Clear it in __pthread_exit()
264 * see the thread as having exited. Release it now so that no in __pthread_exit()
265 * remaining locks (except thread list) are held if we end up in __pthread_exit()
271 * and the detached thread cas in __pthread_exit()
599 struct pthread *thread = (struct pthread *)thread_id; __pthread_list_find() local
622 struct pthread* thread = __pthread_list_find(t, "pthread_gettid_np"); __pthread_gettid_np() local
[all...]
/third_party/musl/porting/linux/user/src/thread/
H A Dpthread_create.c167 * call; the loser is responsible for freeing thread resources. */ in __pthread_exit()
178 /* Access to target the exiting thread with syscalls that use in __pthread_exit()
185 /* The thread list lock must be AS-safe, and thus depends on in __pthread_exit()
192 /* If this is the only thread in the list, don't proceed with in __pthread_exit()
193 * termination of the thread, but restore the previous lock and in __pthread_exit()
206 /* At this point we are committed to thread termination. */ in __pthread_exit()
209 * and the detached thread case where the robust list head will in __pthread_exit()
230 /* Last, unlink thread from the list. This change will not be visible in __pthread_exit()
251 /* The following call unmaps the thread's stack mapping in __pthread_exit()
260 /* After the kernel thread exit in __pthread_exit()
535 struct pthread *thread = (struct pthread *)thread_id; __pthread_list_find() local
558 struct pthread* thread = __pthread_list_find(t, "pthread_gettid_np"); __pthread_gettid_np() local
[all...]
/third_party/glslang/
H A Dosinclude.cpp98 const deThread thread = (deThread)(deUintptr)((void**)threads)[ndx]; in OS_WaitForAllThreads() local
99 deThread_join(thread); in OS_WaitForAllThreads()
100 deThread_destroy(thread); in OS_WaitForAllThreads()
/third_party/ltp/testcases/kernel/syscalls/tgkill/
H A Dtgkill02.c6 * real-time signal. Test this by starting a child thread with SIGRTMIN
8 * SIGRTMIN from the parent thread.
46 pthread_t thread; in run() local
49 SAFE_PTHREAD_CREATE(&thread, NULL, thread_func, &tid); in run()
62 SAFE_PTHREAD_JOIN(thread, NULL); in run()
/third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_rwlock_init/
H A D2-1.c16 * 2. Create a child thread, the thread lock 'rwlock' for reading, shall not block.
58 pthread_t thread; in main() local
69 printf("main: create thread\n"); in main()
70 if (pthread_create(&thread, NULL, fn_rd, NULL) != 0) { in main()
71 printf("main: failed to create thread\n"); in main()
77 /* We expect the thread not to block */ in main()
84 printf("Test FAILED: thread blocked on read lock\n"); in main()
87 printf("main: Unexpected thread state\n"); in main()
91 if (pthread_join(thread, NUL in main()
[all...]
/third_party/vk-gl-cts/external/glslang/
H A Dosinclude.cpp98 const deThread thread = (deThread)(deUintptr)((void**)threads)[ndx]; in OS_WaitForAllThreads() local
99 deThread_join(thread); in OS_WaitForAllThreads()
100 deThread_destroy(thread); in OS_WaitForAllThreads()
/third_party/skia/third_party/externals/abseil-cpp/absl/synchronization/
H A Dblocking_counter_test.cc17 #include <thread> // NOLINT(build/c++11)
42 std::vector<std::thread> workers; in TEST()
61 for (std::thread& w : workers) { in TEST()
/third_party/rust/crates/once_cell/examples/
H A Dtest_synchronization.rs6 //! Every thread adds the results of the cells it sees to an accumulator, which is compared at the
22 (0..N_THREADS).map(|i| std::thread::spawn(move || thread_main(i))).collect::<Vec<_>>(); in main()
23 for thread in threads { in main()
24 thread.join().unwrap(); in main()
H A Dbench.rs13 (0..N_THREADS).map(|i| std::thread::spawn(move || thread_main(i))).collect::<Vec<_>>(); in main()
14 for thread in threads { in main()
15 thread.join().unwrap(); in main()

Completed in 10 milliseconds

12345678910>>...37