/third_party/benchmark/test/ |
H A D | internal_threading_test.cc | 5 #include <thread> 81 std::thread Worker(&MyBusySpinwait); in BM_WorkerThread() 124 std::thread Worker(&MyBusySpinwait); in BM_MainThreadAndWorkerThread()
|
/third_party/node/deps/v8/third_party/wasm-api/example/ |
H A D | threads.cc | 3 #include <thread> 106 std::thread threads[N_THREADS]; in main() 110 std::cout << "Initializing thread " << i << "..." << std::endl; in main() 112 threads[i] = std::thread(run, engine.get(), shared.get(), &mutex, i); in main() 118 std::cout << "Waiting for thread " << i << "..." << std::endl; in main()
|
/third_party/ltp/testcases/kernel/mce-test/stress/tools/fs-metadata/ |
H A D | fs-metadata.sh | 47 k_log "killing k-thread $pid" 122 local thread=$3 124 local total_size=$(echo "scale=2; $tree_size * 2 * $thread " | bc) 164 k_log "thread $dir: begin to traverse dir $new_dir" 166 k_log "thread $dir: end to traverse dir $new_dir" 170 k_result "thread $dir: $result to compare result between dir $dir and $new_dir" 254 $K_CWD/k-thread.sh $counter $1 $2 &
|
/third_party/ltp/utils/sctp/func_tests/ |
H A D | test_1_to_1_threads.c | 141 pthread_t thread[THREADS]; in main() local 179 status = pthread_create(&thread[cnt], &attr, relay, &pth[cnt]); in main() 188 exit_status = pthread_join (thread[cnt], &result); in main()
|
/third_party/node/deps/uvwasi/src/ |
H A D | clocks.c | 60 mach_port_t thread; \ 64 thread = pthread_mach_thread_np(pthread_self()); \ 65 if (KERN_SUCCESS != thread_info(thread, \
|
/third_party/skia/third_party/externals/oboe/samples/RhythmGame/test/ |
H A D | testLockFreeQueue.cpp | 17 #include <thread> 184 std::thread writer([&myQ, &sourceData](){ in TEST_F() 190 std::thread reader([&myQ, &targetData](){ in TEST_F()
|
/third_party/skia/third_party/externals/dng_sdk/source/ |
H A D | dng_pthread.h | 96 int dng_pthread_create(dng_pthread_t *thread, const dng_pthread_attr_t * /* attrs */, void * (*func)(void *), void *arg); 97 int dng_pthread_detach(dng_pthread_t thread); 98 int dng_pthread_join(dng_pthread_t thread, void **result); 149 // dng_pthread may maintain per-thread global state. This routine frees that global state. 151 // dng_pthread routines of a thread after dng_pthread_disassociate as the global state will
|
H A D | dng_pthread.cpp | 215 // between pthreads thread funcs and Windows C lib thread funcs 310 int dng_pthread_create(dng_pthread_t *thread, const pthread_attr_t *attrs, void * (*func)(void *), void *arg) in dng_pthread_create() argument 342 // If there is a handle open on the thread, its ID should not be reused so assert that an insertion was made. in dng_pthread_create() 349 *thread = (dng_pthread_t)threadID; in dng_pthread_create() 360 int dng_pthread_detach(dng_pthread_t thread) in dng_pthread_detach() argument 368 ThreadMapType::iterator iter = primaryHandleMap.find(thread); in dng_pthread_detach() 374 // A join is waiting on the thread. in dng_pthread_detach() 393 int dng_pthread_join(dng_pthread_t thread, void **result) in dng_pthread_join() argument 404 iter = primaryHandleMap.find(thread); in dng_pthread_join() [all...] |
/third_party/rust/crates/rustix/tests/io/ |
H A D | epoll.rs | 12 use std::thread; 90 let _server = thread::Builder::new() in test_epoll() 96 let client = thread::Builder::new() in test_epoll()
|
/third_party/rust/crates/rustix/tests/net/ |
H A D | unix.rs | 26 use std::thread; 123 let server = thread::Builder::new() in test_unix() 130 let client = thread::Builder::new() in test_unix()
|
H A D | poll.rs | 11 use std::thread; 105 let server = thread::Builder::new() in test_poll() 111 let client = thread::Builder::new() in test_poll()
|
/third_party/python/Lib/test/ |
H A D | test_smtplib.py | 191 # Test server thread using the specified SMTP server class 256 self.thread = threading.Thread(target=debugging_server, args=serv_args) 257 self.thread.start() 259 # wait until server thread has assigned a port number 267 # wait for the server thread to terminate 269 threading_helper.join_thread(self.thread) 275 del self.thread 789 self.thread = threading.Thread(target=server, args=servargs) 790 self.thread.start() 797 threading_helper.join_thread(self.thread) [all...] |
/third_party/elfutils/tests/ |
H A D | backtrace.c | 88 // For the main thread we are only interested if we can unwind till in callback_verify() 227 Dwfl_Thread *thread = dwfl_frame_thread (state); in frame_callback() local 228 Dwfl *dwfl = dwfl_thread_dwfl (thread); in frame_callback() 236 pid_t tid = dwfl_thread_tid (thread); in frame_callback() 244 thread_callback (Dwfl_Thread *thread, void *thread_arg __attribute__((unused))) in thread_callback() argument 246 printf ("TID %ld:\n", (long) dwfl_thread_tid (thread)); in thread_callback() 248 switch (dwfl_thread_getframes (thread, frame_callback, &frameno)) in thread_callback() 399 /* Catch the main thread. Catch it first otherwise the /proc evaluation of in exec_dump() 406 // Main thread will signal SIGUSR2. Other thread wil in exec_dump() [all...] |
H A D | dwfl-proc-attach.c | 64 thread_callback (Dwfl_Thread *thread, void *thread_arg) in thread_callback() argument 67 pid_t tid = dwfl_thread_tid (thread); in thread_callback() 68 printf ("thread tid: %d\n", tid); in thread_callback()
|
/third_party/musl/libc-test/src/functionalext/supplement/thread/thread_gtest/ |
H A D | thread_rwlock_test.cpp | 9 #include <thread> 98 pthread_t thread; in TestPthreadRwlockWakeupWriter() local 102 pthread_create(&thread, nullptr, reinterpret_cast<void* (*)(void*)>(PthreadRwlockWakeupHelper), arg)); in TestPthreadRwlockWakeupWriter() 105 EXPECT_EQ(0, pthread_join(thread, nullptr)); in TestPthreadRwlockWakeupWriter() 109 pthread_create(&thread, nullptr, reinterpret_cast<void* (*)(void*)>(PthreadRwlockTimeoutHelper), arg)); in TestPthreadRwlockWakeupWriter() 111 EXPECT_EQ(0, pthread_join(thread, nullptr)); in TestPthreadRwlockWakeupWriter() 129 * @tc.desc: Set up a sleep thread to test the normal use of this interface in the current scenario 143 * in the sleep thread 177 * operation in the sleep thread 195 * operation in the sleep thread [all...] |
/third_party/openssl/test/ |
H A D | threadstest.c | 10 /* test_multi below tests the thread safety of a deprecated function */ 67 thread_t thread; in test_once() local 69 if (!TEST_true(run_thread(&thread, once_run_thread_cb)) in test_once() 70 || !TEST_true(wait_for_thread(thread)) in test_once() 112 thread_t thread; in test_thread_local() local 121 || !TEST_true(run_thread(&thread, thread_local_thread_cb)) in test_thread_local() 122 || !TEST_true(wait_for_thread(thread)) in test_thread_local() 568 * run with a thread sanitizer, should crash if the core provider code
|
/third_party/python/Lib/idlelib/ |
H A D | run.py | 16 import _thread as thread namespace 103 # the socket) and the main thread (which runs user code), plus global 104 # completion, exit and interruptable (the main thread) flags: 409 thread.interrupt_main() 428 thread.interrupt_main() 549 "Override SocketIO method - terminate wait on callback and exit thread" 552 thread.interrupt_main() 555 "interrupt awakened thread" 558 thread.interrupt_main() 607 thread [all...] |
/third_party/python/Lib/test/test_asyncio/ |
H A D | test_windows_events.py | 47 thread = threading.Thread(target=SIGINT_after_delay) 51 loop.call_soon(thread.start) 58 thread.join() 76 thread = threading.Thread(target=func) 77 thread.start() 78 thread.join() 219 # Start an operation in another thread so that the self-pipe is used.
|
/third_party/pulseaudio/src/modules/ |
H A D | module-null-sink.c | 41 #include <pulsecore/thread.h> 42 #include <pulsecore/thread-mq.h> 68 pa_thread *thread; member 115 /* Called from the IO thread. */ 134 /* Called from the IO thread. */ 156 /* Called from the IO thread. */ 424 if (!(u->thread = pa_thread_new("null-sink", thread_func, u))) { in pa__init() 425 pa_log("Failed to create thread."); in pa__init() 466 if (u->thread) { in pa__done() 468 pa_thread_free(u->thread); in pa__done() [all...] |
/third_party/pulseaudio/src/modules/jack/ |
H A D | module-jack-sink.c | 42 #include <pulsecore/thread.h> 43 #include <pulsecore/thread-mq.h> 50 * doesn't allow us to add our own event sources to the event thread 51 * we cannot use the JACK real-time thread for dispatching our PA 52 * work. Instead, we run an additional RT thread which does most of 53 * the PA handling, and have the JACK RT thread request data from it 94 pa_thread *thread; member 125 /* Handle the request from the JACK thread */ in sink_process_msg() 213 /* We just forward the request to our other RT thread */ in jack_process() 272 pa_log_info("JACK thread startin in jack_init() [all...] |
H A D | module-jack-source.c | 42 #include <pulsecore/thread.h> 43 #include <pulsecore/thread-mq.h> 82 pa_thread *thread; member 111 /* Handle the new block from the JACK thread */ in source_process_msg() 169 /* We interleave the data and pass it on to the other RT thread */ in jack_process() 230 pa_log_info("JACK thread starting up."); in jack_init() 239 pa_log_info("JACK thread shutting down.."); in jack_shutdown() 389 if (!(u->thread = pa_thread_new("jack-source", thread_func, u))) { in pa__init() 390 pa_log("Failed to create thread."); in pa__init() 462 if (u->thread) { in pa__done() [all...] |
/third_party/alsa-utils/alsaloop/ |
H A D | alsaloop.c | 41 pthread_t thread; member 63 static void my_exit(struct loopback_thread *thread, int exitcode) in my_exit() argument 67 for (i = 0; i < thread->loopbacks_count; i++) in my_exit() 68 pcmjob_done(thread->loopbacks[i]); in my_exit() 69 if (thread->threaded) { in my_exit() 70 thread->exitcode = exitcode; in my_exit() 196 "-T,--thread thread number (-1 = create unique)\n" in help() 384 {"thread", 1, NULL, 'T'}, in parse_config() 627 loop->thread in parse_config() 728 struct loopback_thread *thread = _data; thread_job1() local 802 thread_job(struct loopback_thread *thread) thread_job() argument 814 struct loopback_thread *thread; send_to_all() local 833 struct loopback_thread *thread; signal_handler_state() local [all...] |
/third_party/skia/tests/ |
H A D | StringTest.cpp | 15 #include <thread> 279 std::thread threads[5]; in DEF_TEST() 280 for (auto& thread : threads) { in DEF_TEST() 281 thread = std::thread([&] { in DEF_TEST() 286 for (auto& thread : threads) { in DEF_TEST() 287 thread.join(); in DEF_TEST()
|
/device/soc/rockchip/rk3588/hardware/codec/jpeg/include/ |
H A D | codec_jpeg_decoder.h | 22 #include <thread> 86 std::shared_ptr<std::thread> threadTask_;
|
/third_party/benchmark/src/ |
H A D | benchmark_runner.h | 18 #include <thread> 99 std::vector<std::thread> pool;
|