/third_party/musl/libc-test/src/functionalext/supplement/ldso/ldso_gtest/ |
H A D | ldso_dlerror_test.cpp | 4 #include <thread> 38 thread t1(DlerrorChildThread, ref(childErr)); in HWTEST_F() 60 thread t1(DlerrorChildThread, ref(childErr)); in HWTEST_F()
|
/third_party/skia/third_party/externals/swiftshader/tests/SystemUnitTests/ |
H A D | SynchronizationTests.cpp | 20 #include <thread> 62 auto t = std::thread([=, &b] { in TEST() 78 auto t = std::thread([=, &b] { in TEST()
|
/third_party/skia/third_party/externals/spirv-cross/include/spirv_cross/ |
H A D | thread_group.hpp | 23 #include <thread> 62 worker = std::thread([impl, this] { in start() 106 std::thread worker;
|
/third_party/skia/third_party/externals/dawn/src/utils/ |
H A D | WindowsDebugLogger.cpp | 21 #include <thread> 37 mThread = std::thread( in WindowsDebugLogger() 103 std::thread mThread;
|
/third_party/skia/third_party/externals/abseil-cpp/absl/synchronization/internal/ |
H A D | thread_pool.h | 22 #include <thread> // NOLINT(build/c++11) 37 threads_.push_back(std::thread(&ThreadPool::WorkLoop, this)); in ThreadPool() 56 // Schedule a function to be run on a ThreadPool thread immediately. 86 std::vector<std::thread> threads_;
|
/third_party/rust/crates/nix/test/ |
H A D | test_timer.rs | 9 use std::thread; 80 thread::sleep(2 * TIMER_PERIOD); in alarm_fires() 98 thread::sleep(TIMER_PERIOD); in alarm_fires()
|
/third_party/libuv/src/win/ |
H A D | thread.c | 126 HANDLE thread; in uv_thread_create_ex() local 151 /* Create the thread in suspended state so we have a chance to pass in uv_thread_create_ex() 153 thread = (HANDLE) _beginthreadex(NULL, in uv_thread_create_ex() 159 if (thread == NULL) { in uv_thread_create_ex() 164 *tid = thread; in uv_thread_create_ex() 165 ctx->self = thread; in uv_thread_create_ex() 166 ResumeThread(thread); in uv_thread_create_ex() 264 /* If the thread wasn't started by uv_thread_create (such as the main in uv_thread_self() 265 * thread), we assign an id to it now. */ in uv_thread_self()
|
/third_party/node/deps/uv/src/win/ |
H A D | thread.c | 126 HANDLE thread; in uv_thread_create_ex() local 151 /* Create the thread in suspended state so we have a chance to pass in uv_thread_create_ex() 153 thread = (HANDLE) _beginthreadex(NULL, in uv_thread_create_ex() 159 if (thread == NULL) { in uv_thread_create_ex() 164 *tid = thread; in uv_thread_create_ex() 165 ctx->self = thread; in uv_thread_create_ex() 166 ResumeThread(thread); in uv_thread_create_ex() 189 /* If the thread wasn't started by uv_thread_create (such as the main in uv_thread_self() 190 * thread), we assign an id to it now. */ in uv_thread_self()
|
/third_party/pulseaudio/src/modules/ |
H A D | module-sine-source.c | 38 #include <pulsecore/thread.h> 39 #include <pulsecore/thread-mq.h> 60 pa_thread *thread; member 105 /* Called from the IO thread. */ 276 if (!(u->thread = pa_thread_new("sine-source", thread_func, u))) { in pa__init() 277 pa_log("Failed to create thread."); in pa__init() 316 if (u->thread) { in pa__done() 318 pa_thread_free(u->thread); in pa__done()
|
H A D | module-null-source.c | 42 #include <pulsecore/thread-mq.h> 43 #include <pulsecore/thread.h> 67 pa_thread *thread; member 105 /* Called from the IO thread. */ 269 if (!(u->thread = pa_thread_new("null-source", thread_func, u))) { in pa__init() 270 pa_log("Failed to create thread."); in pa__init() 300 if (u->thread) { in pa__done() 302 pa_thread_free(u->thread); in pa__done()
|
H A D | module-pipe-source.c | 44 #include <pulsecore/thread.h> 45 #include <pulsecore/thread-mq.h> 70 pa_thread *thread; member 303 if (!(u->thread = pa_thread_new("pipe-source", thread_func, u))) { in pa__init() 304 pa_log("Failed to create thread."); in pa__init() 343 if (u->thread) { in pa__done() 345 pa_thread_free(u->thread); in pa__done()
|
/third_party/python/Lib/test/ |
H A D | test_largefile.py | 195 self.thread = None 199 if self.thread is not None: 200 self.thread.join(self.timeout) 201 self.thread = None 218 self.thread = threading.Thread(target=run, args=(sock, )) 219 self.thread.start()
|
/third_party/node/src/inspector/ |
H A D | worker_inspector.cc | 22 void Call(MainThreadInterface* thread) override { 23 auto manager = thread->inspector_agent()->GetWorkerManager(); 49 void Call(MainThreadInterface* thread) override { 50 thread->inspector_agent()->GetWorkerManager()->WorkerFinished(worker_id_);
|
/third_party/musl/porting/liteos_m/user/src/thread/ |
H A D | pthread_create.c | 25 * call; the loser is responsible for freeing thread resources. */ in __pthread_exit() 28 /* After the kernel thread exits, its tid may be reused. Clear it in __pthread_exit() 94 _LIBC_TEXT_SECTION static int __thread_clone(int (*func)(void *), int flags, struct pthread *thread, unsigned char *sp) in __thread_clone() argument 100 if (thread->detach_state == DT_JOINABLE) { in __thread_clone() 104 user_area = (unsigned long)TP_ADJ(thread); in __thread_clone() 111 thread->tid = (unsigned long)ret; in __thread_clone() 159 /* Setup argument structure for the new thread on its stack. in __pthread_create() 160 * It's safe to access from the caller only until the thread in __pthread_create() 171 * was requested, attempt it before unlocking the thread list so in __pthread_create() 172 * that the failed thread i in __pthread_create() [all...] |
/third_party/ltp/testcases/open_posix_testsuite/stress/threads/pthread_getschedparam/ |
H A D | stress.c | 20 * the queried thread. 94 pthread_t thread; member 110 ret = pthread_getschedparam(td[i].thread, &pol, &sp); in threaded() 138 /* This thread does almost nothing but wait... */ in rt_thread() 226 "Failed to initialize thread attribute"); in main() 244 "failed to set thread attribute sched param"); in main() 251 "failed to set thread attribute sched prio"); in main() 254 ret = pthread_create(&td[i].thread, &ta[i], rt_thread, &bar); in main() 258 "Failed to create a RT thread -- need more privilege?"); in main() 268 UNRESOLVED(ret, "failed to create a worker thread"); in main() [all...] |
/third_party/ltp/testcases/realtime/func/periodic_cpu_load/ |
H A D | periodic_cpu_load.c | 121 void *periodic_thread(void *thread) in periodic_thread() argument 123 struct thread *t = (struct thread *)thread; in periodic_thread() 182 printf("Running %d iterations per thread\n", iterations); in main()
|
/third_party/skia/third_party/externals/abseil-cpp/absl/base/internal/ |
H A D | periodic_sampler_test.cc | 17 #include <thread> // NOLINT(build/c++11) 160 std::thread thread([] { in TEST() 168 thread.join(); in TEST()
|
/third_party/backends/backend/ |
H A D | kvs40xx.c | 561 if (s->thread) in sane_start() 563 pthread_join (s->thread, NULL); in sane_start() 564 s->thread = 0; in sane_start() 639 if (pthread_create (&s->thread, NULL, read_data, s)) in sane_start() 647 pthread_join (s->thread, NULL); in sane_start() 648 s->thread = 0; in sane_start() 722 if (s->thread) in sane_cancel() 724 pthread_cancel (s->thread); in sane_cancel() 725 pthread_join (s->thread, NULL); in sane_cancel() 726 s->thread in sane_cancel() [all...] |
/third_party/json/tests/thirdparty/Fuzzer/test/ |
H A D | ThreadedLeakTest.cpp | 4 // The fuzzer should find a leak in a non-main thread. 7 #include <thread> 14 std::thread T([&] { Sink = new int; }); in LLVMFuzzerTestOneInput()
|
/third_party/musl/libc-test/src/functionalext/supplement/thread/thread_gtest/ |
H A D | thread_tls_get_addr_test.cpp | 2 #include <thread> 29 std::thread t(ThreadFunc); in HWTEST_F()
|
/third_party/pulseaudio/src/pulsecore/ |
H A D | rtkit.h | 45 /* This is mostly equivalent to sched_setparam(thread, SCHED_RR, { 46 * .sched_priority = priority }). 'thread' needs to be a kernel thread 47 * id as returned by gettid(), not a pthread_t! If 'thread' is 0 the 48 * current thread is used. The returned value is a negative errno 50 int rtkit_make_realtime(DBusConnection *system_bus, pid_t thread, int priority); 52 /* This is mostly equivalent to setpriority(PRIO_PROCESS, thread, 53 * nice_level). 'thread' needs to be a kernel thread id as returned by 54 * gettid(), not a pthread_t! If 'thread' i [all...] |
/third_party/skia/third_party/externals/oboe/apps/OboeTester/app/src/main/cpp/ |
H A D | FullDuplexLatency.cpp | 17 #include <thread> 37 // Crunch the numbers on a separate thread. in onBothStreamsReady() 38 std::thread t(analyze_data, this); in onBothStreamsReady()
|
/third_party/skia/third_party/externals/angle2/src/tests/egl_tests/ |
H A D | EGLContextSharingTest.cpp | 547 std::thread deletingThread = std::thread([&]() { in TEST_P() 563 // Wait for the other thread to also draw using the shared texture. in TEST_P() 574 // Delete this thread's framebuffer (reader of the shared texture). in TEST_P() 577 // Wait for the other thread to use the shared texture again before unbinding the in TEST_P() 587 std::thread continuingThread = std::thread([&]() { in TEST_P() 593 // Wait for first thread to draw using the shared texture. in TEST_P() 611 // Wait for the other thread to delete its framebuffer. in TEST_P() 646 // Test that eglTerminate() with a thread does [all...] |
/third_party/skia/third_party/externals/abseil-cpp/absl/synchronization/ |
H A D | mutex.cc | 39 #include <thread> // NOLINT(build/c++11) 149 // for any thread to make progress gets it without undue delay. in GetMutexGlobals() 464 // The SynchWaitParams struct encapsulates the way in which a thread is waiting: 467 // type of lock). It also points to the PerThreadSynch struct of its thread. 471 // PerThreadSynch because a thread can be waiting on multiple Mutexes if, 477 // the thread is on a Mutex's waiter queue. 487 thread(thread_arg), in SynchWaitParams() 491 const Mutex::MuHow how; // How this thread needs to wait. 492 const Condition *cond; // The condition that this thread is waiting for. 499 PerThreadSynch *const thread; // threa member [all...] |
/third_party/gn/src/util/ |
H A D | worker_pool.h | 12 #include <thread> 27 std::vector<std::thread> threads_;
|