Home
last modified time | relevance | path

Searched refs:thread (Results 276 - 300 of 809) sorted by relevance

1...<<11121314151617181920>>...33

/third_party/benchmark/test/
H A Dinternal_threading_test.cc5 #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 Dthreads.cc3 #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 Dfs-metadata.sh47 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 Dtest_1_to_1_threads.c141 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 Dclocks.c60 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 DtestLockFreeQueue.cpp17 #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 Ddng_pthread.h96 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 Ddng_pthread.cpp215 // 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 Depoll.rs12 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 Dunix.rs26 use std::thread;
123 let server = thread::Builder::new() in test_unix()
130 let client = thread::Builder::new() in test_unix()
H A Dpoll.rs11 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 Dtest_smtplib.py191 # 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 Dbacktrace.c88 // 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 Ddwfl-proc-attach.c64 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 Dthread_rwlock_test.cpp9 #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 Dthreadstest.c10 /* 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 Drun.py16 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 Dtest_windows_events.py47 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 Dmodule-null-sink.c41 #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 Dmodule-jack-sink.c42 #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 Dmodule-jack-source.c42 #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 Dalsaloop.c41 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 DStringTest.cpp15 #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 Dcodec_jpeg_decoder.h22 #include <thread>
86 std::shared_ptr<std::thread> threadTask_;
/third_party/benchmark/src/
H A Dbenchmark_runner.h18 #include <thread>
99 std::vector<std::thread> pool;

Completed in 14 milliseconds

1...<<11121314151617181920>>...33