| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | MonitorTestCase.java | 52 private TestThread<Monitor> thread1; field in MonitorTestCase
63 tearDownStack.addTearDown(thread1 = new TestThread<>(monitor, "TestThread #1")); in setUp()
101 thread1.callAndAssertReturns(enter()); in testMutualExclusion()
103 thread1.callAndAssertReturns(leave()); in testMutualExclusion()
108 thread1.callAndAssertReturns(true, tryEnter()); in testTryEnter()
110 thread1.callAndAssertReturns(true, tryEnter()); in testTryEnter()
112 thread1.callAndAssertReturns(leave()); in testTryEnter()
114 thread1.callAndAssertReturns(leave()); in testTryEnter()
120 thread1.callAndAssertReturns(enter()); in testSystemStateMethods()
122 thread1.callAndAssertReturns(enter()); in testSystemStateMethods()
[all …]
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | MonitorTestCase.java | 52 private TestThread<Monitor> thread1; field in MonitorTestCase
63 tearDownStack.addTearDown(thread1 = new TestThread<>(monitor, "TestThread #1")); in setUp()
101 thread1.callAndAssertReturns(enter()); in testMutualExclusion()
103 thread1.callAndAssertReturns(leave()); in testMutualExclusion()
108 thread1.callAndAssertReturns(true, tryEnter()); in testTryEnter()
110 thread1.callAndAssertReturns(true, tryEnter()); in testTryEnter()
112 thread1.callAndAssertReturns(leave()); in testTryEnter()
114 thread1.callAndAssertReturns(leave()); in testTryEnter()
120 thread1.callAndAssertReturns(enter()); in testSystemStateMethods()
122 thread1.callAndAssertReturns(enter()); in testSystemStateMethods()
[all …]
|
| /external/webrtc/rtc_base/ |
| D | platform_thread_unittest.cc | 41 PlatformThread thread1; in TEST() local
42 PlatformThread thread2 = std::move(thread1); in TEST()
43 EXPECT_TRUE(thread1.empty()); in TEST()
48 PlatformThread thread1 = PlatformThread::SpawnJoinable([] {}, "1"); in TEST() local
49 PlatformThread thread2 = std::move(thread1); in TEST()
50 EXPECT_TRUE(thread1.empty()); in TEST()
53 thread1 = PlatformThread::SpawnDetached([&] { done.Set(); }, "2"); in TEST()
54 thread2 = std::move(thread1); in TEST()
55 EXPECT_TRUE(thread1.empty()); in TEST()
62 PlatformThread thread1 = PlatformThread(); in TEST() local
[all …]
|
| D | thread_unittest.cc | 301 auto thread1 = Thread::CreateWithSocketServer(); in TEST() local
304 thread1->PostTask( in TEST()
305 [&]() { EXPECT_TRUE(thread1->IsInvokeToThreadAllowed(thread2.get())); }); in TEST()
312 auto thread1 = Thread::CreateWithSocketServer(); in TEST() local
317 thread1->AllowInvokesToThread(thread2.get()); in TEST()
318 thread1->AllowInvokesToThread(thread3.get()); in TEST()
320 thread1->PostTask([&]() { in TEST()
321 EXPECT_TRUE(thread1->IsInvokeToThreadAllowed(thread2.get())); in TEST()
322 EXPECT_TRUE(thread1->IsInvokeToThreadAllowed(thread3.get())); in TEST()
323 EXPECT_FALSE(thread1->IsInvokeToThreadAllowed(thread4.get())); in TEST()
[all …]
|
| /external/apache-commons-io/src/test/java/org/apache/commons/io/ |
| D | FileUtilsWaitForTest.java | 49 final Thread thread1 = new Thread(() -> { in testWaitForInterrupted() local
54 thread1.start(); in testWaitForInterrupted()
57 thread1.interrupt(); in testWaitForInterrupted()
59 thread1.join(); in testWaitForInterrupted()
|
| /external/perfetto/src/tracing/test/ |
| D | platform_unittest.cc | 70 auto thread1 = platform->CreateTaskRunner(tr_args); in TEST() local
71 ASSERT_TRUE(thread1); in TEST()
78 thread1->PostTask([] { GetTLS()->generation = 101; }); in TEST()
87 thread1->PostTask([&] { in TEST()
111 thread1.reset(); in TEST()
|
| /external/libchrome/base/ |
| D | deferred_sequenced_task_runner_unittest.cc | 119 Thread thread1("DeferredSequencedTaskRunnerTestThread1"); in TEST_F() local
121 thread1.Start(); in TEST_F()
124 thread1.task_runner()->PostTask( in TEST_F()
131 thread1.task_runner()->PostTask( in TEST_F()
184 Thread thread1("DeferredSequencedTaskRunnerTestThread1"); in TEST_F() local
185 thread1.Start(); in TEST_F()
188 thread1.task_runner()->PostTask( in TEST_F()
|
| D | tools_sanity_unittest.cc | 300 TOOLS_SANITY_TEST_CONCURRENT_THREAD thread1(shared), thread2(shared); in DataRace() local
301 RunInParallel(&thread1, &thread2); in DataRace()
322 TOOLS_SANITY_TEST_CONCURRENT_THREAD thread1(&shared), thread2(&shared); in TEST() local
323 RunInParallel(&thread1, &thread2); in TEST()
329 ReleaseStoreThread thread1(&shared); in TEST() local
331 RunInParallel(&thread1, &thread2); in TEST()
|
| /external/elfutils/tests/ |
| D | dwfl-proc-attach.c | 44 static pthread_t thread1; variable
80 if ((err = pthread_create (&thread1, NULL, sleeper, NULL)) != 0) in main()
102 pthread_cancel (thread1); in main()
104 pthread_join (thread1, NULL); in main()
|
| /external/cronet/stable/base/task/ |
| D | deferred_sequenced_task_runner_unittest.cc | 132 Thread thread1("DeferredSequencedTaskRunnerTestThread1"); in TEST_F() local
134 thread1.Start(); in TEST_F()
137 thread1.task_runner()->PostTask( in TEST_F()
147 thread1.task_runner()->PostTask( in TEST_F()
203 Thread thread1("DeferredSequencedTaskRunnerTestThread1"); in TEST_F() local
204 thread1.Start(); in TEST_F()
207 thread1.task_runner()->PostTask( in TEST_F()
|
| /external/cronet/tot/base/task/ |
| D | deferred_sequenced_task_runner_unittest.cc | 132 Thread thread1("DeferredSequencedTaskRunnerTestThread1"); in TEST_F() local
134 thread1.Start(); in TEST_F()
137 thread1.task_runner()->PostTask( in TEST_F()
147 thread1.task_runner()->PostTask( in TEST_F()
203 Thread thread1("DeferredSequencedTaskRunnerTestThread1"); in TEST_F() local
204 thread1.Start(); in TEST_F()
207 thread1.task_runner()->PostTask( in TEST_F()
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_wait/ |
| D | 3-1.c | 25 static pthread_t thread1; variable
34 pthread_cancel(thread1); in alarm_handler()
91 if (pthread_create(&thread1, NULL, t1_func, NULL) != 0) { in main()
113 pthread_join(thread1, NULL); in main()
|
| D | 1-1.c | 26 static pthread_t thread1; variable
35 pthread_cancel(thread1); in alarm_handler()
81 if (pthread_create(&thread1, NULL, t1_func, NULL) != 0) { in main()
113 pthread_join(thread1, NULL); in main()
|
| D | 2-1.c | 26 static pthread_t thread1; variable
35 pthread_cancel(thread1); in alarm_handler()
94 if (pthread_create(&thread1, NULL, t1_func, NULL) != 0) { in main()
126 pthread_join(thread1, NULL); in main()
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_mutexattr_settype/ |
| D | 3-2.c | 33 static pthread_t thread1; variable
74 if (pthread_create(&thread1, NULL, a_thread_func, NULL) != 0) { in main()
80 pthread_join(thread1, NULL); in main()
|
| /external/libyuv/unit_test/ |
| D | cpu_thread_test.cc | 45 pthread_t thread1; in TEST() local
49 ret = pthread_create(&thread1, nullptr, ThreadMain, &cpu_flags1); in TEST()
53 ret = pthread_join(thread1, nullptr); in TEST()
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_timedwait/ |
| D | 4-1.c | 68 pthread_t thread1; in main() local
80 if (pthread_create(&thread1, NULL, t1_func, NULL) != 0) { in main()
87 pthread_join(thread1, &th_ret); in main()
|
| D | 2-3.c | 70 pthread_t thread1; in main() local
83 if (pthread_create(&thread1, NULL, t1_func, NULL) != 0) { in main()
93 if (pthread_join(thread1, (void *)&th_ret) != 0) { in main()
|
| D | 2-2.c | 79 pthread_t thread1; in main() local
92 if (pthread_create(&thread1, NULL, t1_func, NULL) != 0) { in main()
115 if (pthread_join(thread1, &th_ret) != 0) { in main()
|
| D | 3-1.c | 85 pthread_t thread1; in main() local
97 if (pthread_create(&thread1, NULL, t1_func, NULL) != 0) { in main()
122 pthread_join(thread1, NULL); in main()
|
| /external/sdv/vsomeip/third_party/boost/thread/test/ |
| D | test_7571.cpp | 65 boost::thread thread1(threadFunc, 1, boost::ref(exceptionOccurred1)); in main() local
74 if (!thread1.timed_join(timeout)) { in main()
76 thread1.interrupt(); in main()
|
| /external/webrtc/rtc_tools/ |
| D | sanitizers_unittest.cc | 107 IncrementThread thread1(&value); in DataRace() local
109 thread1.Start(); in DataRace()
111 thread1.Join(); in DataRace()
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_rwlock_timedrdlock/ |
| D | 2-1.c | 90 pthread_t thread1; in main() local
108 if (pthread_create(&thread1, NULL, fn_rd, NULL) != 0) { in main()
143 if (pthread_join(thread1, NULL) != 0) { in main()
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_rwlock_timedwrlock/ |
| D | 2-1.c | 95 pthread_t thread1; in main() local
112 if (pthread_create(&thread1, NULL, fn, NULL) != 0) { in main()
151 if (pthread_join(thread1, NULL) != 0) { in main()
|
| /external/tensorflow/tensorflow/core/profiler/convert/ |
| D | xplane_to_trace_events_test.cc | 32 XLineBuilder thread1 = host_plane.GetOrCreateLine(10); in CreateXSpace() local
33 thread1.SetName("thread1"); in CreateXSpace()
35 thread1.AddEvent(*host_plane.GetOrCreateEventMetadata("event1")); in CreateXSpace()
|