| /external/rust/crates/tokio/src/sync/tests/ |
| D | loom_broadcast.rs | 16 let th1 = thread::spawn(move || { in broadcast_send() localVariable
44 assert_ok!(th1.join()); in broadcast_send()
56 let th1 = thread::spawn(move || { in broadcast_two() localVariable
90 assert_ok!(th1.join()); in broadcast_two()
101 let th1 = thread::spawn(move || { in broadcast_wrap() localVariable
139 assert_ok!(th1.join()); in broadcast_wrap()
150 let th1 = thread::spawn(move || { in drop_rx() localVariable
177 assert_ok!(th1.join()); in drop_rx()
191 let th1 = thread::spawn(move || { in drop_multiple_rx_with_overflow() localVariable
204 assert_ok!(th1.join()); in drop_multiple_rx_with_overflow()
|
| D | loom_notify.rs | 86 let th1 = thread::spawn(move || { in notify_drop() localVariable
108 th1.join().unwrap(); in notify_drop()
|
| D | loom_mpsc.rs | 66 let th1 = thread::spawn(move || { in closing_and_sending() localVariable
80 assert_ok!(th1.join()); in closing_and_sending()
|
| /external/compiler-rt/test/tsan/ |
| D | fork_multithreaded3.cc | 23 pthread_t th1, th2; in main() local
24 pthread_create(&th1, 0, racer, &x); in main()
26 pthread_join(th1, 0); in main()
|
| D | cond.c | 44 pthread_t th1, th2; in main() local
48 pthread_create(&th1, 0, thr1, 0); in main()
50 pthread_join(th1, 0); in main()
|
| D | fork_deadlock.cc | 17 pthread_t th1; in main() local
18 pthread_create(&th1, 0, incrementer, 0); in main()
|
| /external/llvm-project/compiler-rt/test/tsan/ |
| D | fork_multithreaded3.cpp | 23 pthread_t th1, th2; in main() local
24 pthread_create(&th1, 0, racer, &x); in main()
26 pthread_join(th1, 0); in main()
|
| D | cond.c | 44 pthread_t th1, th2; in main() local
48 pthread_create(&th1, 0, thr1, 0); in main()
50 pthread_join(th1, 0); in main()
|
| D | fork_deadlock.cpp | 17 pthread_t th1; in main() local
18 pthread_create(&th1, 0, incrementer, 0); in main()
|
| /external/llvm-project/lldb/test/API/functionalities/gdb_remote_client/ |
| D | TestStopPCs.py | 43 th1 = process.GetThreadAtIndex(1)
45 self.assertEqual(th1.GetThreadID(), 0x2ff0d)
47 self.assertEqual(th1.GetFrameAtIndex(0).GetPC(), 0x10002bc00)
|
| /external/libcxx/test/std/thread/thread.condition/thread.condition.condvarany/ |
| D | destructor.pass.cpp | 56 std::thread th1(f); in main() local
57 th1.join(); in main()
|
| /external/libcxx/test/std/thread/thread.condition/thread.condition.condvar/ |
| D | destructor.pass.cpp | 55 std::thread th1(f); in main() local
56 th1.join(); in main()
|
| /external/llvm-project/libcxx/test/std/thread/thread.condition/thread.condition.condvarany/ |
| D | destructor.pass.cpp | 58 std::thread th1 = support::make_test_thread(f); in main() local
59 th1.join(); in main()
|
| /external/ltp/testcases/kernel/syscalls/futex/ |
| D | futex_wake04.c | 138 pthread_t th1, th2; in wakeup_thread2() local
166 res = pthread_create(&th1, NULL, wait_thread1, NULL); in wakeup_thread2()
189 res = pthread_join(th1, NULL); in wakeup_thread2()
|
| /external/llvm-project/libcxx/test/std/thread/thread.condition/thread.condition.condvar/ |
| D | destructor.pass.cpp | 57 std::thread th1 = support::make_test_thread(f); in main() local
58 th1.join(); in main()
|
| /external/llvm-project/compiler-rt/lib/asan/tests/ |
| D | asan_mac_test.cpp | 54 pthread_t th1, th2; in CFAllocator_PassMemoryToAnotherThread() local
55 PTHREAD_CREATE(&th1, NULL, CFAllocatorAllocateToGlob, NULL); in CFAllocator_PassMemoryToAnotherThread()
56 PTHREAD_JOIN(th1, NULL); in CFAllocator_PassMemoryToAnotherThread()
|
| /external/compiler-rt/lib/asan/tests/ |
| D | asan_mac_test.cc | 55 pthread_t th1, th2; in CFAllocator_PassMemoryToAnotherThread() local
56 PTHREAD_CREATE(&th1, NULL, CFAllocatorAllocateToGlob, NULL); in CFAllocator_PassMemoryToAnotherThread()
57 PTHREAD_JOIN(th1, NULL); in CFAllocator_PassMemoryToAnotherThread()
|
| /external/rust/crates/tokio/src/runtime/tests/ |
| D | loom_basic_scheduler.rs | 56 let th1 = thread::spawn(move || assert_at_most_num_polls(rt1, at_most)); in block_on_num_polls() localVariable
60 th1.join().unwrap(); in block_on_num_polls()
|
| D | loom_queue.rs | 140 let th1 = { in multi_stealer() localVariable
157 n += th1.join().unwrap(); in multi_stealer()
|
| /external/webrtc/rtc_base/ |
| D | thread_unittest.cc | 221 auto th1 = Thread::CreateWithSocketServer(); in TEST() local
223 th1->socketserver()->CreateAsyncSocket(addr.family(), SOCK_DGRAM); in TEST()
224 MessageClient msg_client(th1.get(), socket); in TEST()
230 SocketClient sock_client(asocket, addr, th1.get(), &msg_client); in TEST()
234 th1->Start(); in TEST()
238 th1->PostDelayed(RTC_FROM_HERE, 100, &msg_client, 0, new TestMessage(1)); in TEST()
247 th1->Stop(); in TEST()
|
| /external/tensorflow/tensorflow/core/common_runtime/eager/ |
| D | tensor_handle_test.cc | 315 TensorHandle* th1 = TensorHandle::CreateUnshapedRemoteHandle( in TEST() local
318 th1->resource_remote_device_incarnation())); in TEST()
323 th1->resource_remote_device_incarnation())); in TEST()
328 th1->Unref(); in TEST()
|
| /external/wayland/tests/ |
| D | display-test.c | 587 pthread_t th1, th2, th3; in threading_cancel_read() local
591 th1 = create_thread(c, thread_prepare_and_read); in threading_cancel_read()
603 pthread_join(th1, NULL); in threading_cancel_read()
626 pthread_t th1, th2, th3; in threading_read_eagain() local
630 th1 = create_thread(c, thread_prepare_and_read); in threading_read_eagain()
644 pthread_join(th1, NULL); in threading_read_eagain()
|
| /external/libxml2/ |
| D | regressions.py | 172 th1 = thread.start_new_thread(readPfile, (pout, outfile, th1Flag))
|
| /external/python/cpython2/Lib/test/ |
| D | test_decimal.py | 1249 th1 = threading.Thread(target=thfunc1, args=(self,))
1252 th1.start()
|
| /external/hyphenation-patterns/ga/ |
| D | hyph-ga.pat.txt | 1073 áth1
2785 hóth1
5995 úth1
|