| /external/strace/tests-mx32/ |
| filter-unavailable.c | 39 thread(void *arg) function
60 assert(pthread_create(&t, NULL, thread, NULL) == 0);
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| worker_env.h | 24 namespace thread { namespace in namespace:tensorflow
26 } // namespace thread
66 thread::ThreadPool* compute_pool = nullptr;
|
| /external/tensorflow/tensorflow/core/profiler/internal/ |
| traceme_recorder.h | 56 const ThreadInfo thread; member in struct:tensorflow::profiler::TraceMeRecorder::ThreadEvents
|
| /external/testng/src/main/java/org/testng/internal/thread/graph/ |
| SuiteWorkerFactory.java | 1 package org.testng.internal.thread.graph;
|
| /external/testng/src/test/java/test/thread/ |
| DataProviderThreadPoolSizeSampleTest.java | 1 package test.thread;
52 long n = Thread.currentThread().getId();
59 long n = Thread.currentThread().getId();
|
| DataProviderThreadPoolSizeTest.java | 1 package test.thread;
|
| SuiteThreadCountTest.java | 1 package test.thread;
6 import org.testng.internal.thread.ThreadUtil;
13 * Test for test level thread-count.
|
| TestThreadCountTest.java | 1 package test.thread;
6 import org.testng.internal.thread.ThreadUtil;
13 * Test for test level thread-count.
|
| ThreadPoolSizeWithTimeOutTest.java | 1 package test.thread;
|
| TrueParallelSampleTest.java | 1 package test.thread;
14 Thread.sleep(random.nextInt(10));
16 Thread.yield();
|
| /external/webrtc/webrtc/examples/peerconnection/client/linux/ |
| main.cc | 19 #include "webrtc/base/thread.h"
23 CustomSocketServer(rtc::Thread* thread, GtkMainWnd* wnd)
24 : thread_(thread), wnd_(wnd), conductor_(NULL), client_(NULL) {}
34 // different thread. Alternatively we could look at merging the two loops
49 rtc::Thread* thread_;
81 rtc::Thread* thread = rtc::Thread::Current(); local
82 CustomSocketServer socket_server(thread, &wnd)
[all...] |
| /external/webrtc/webrtc/p2p/stunprober/ |
| main.cc | 26 #include "webrtc/base/thread.h"
88 void StopTrial(rtc::Thread* thread, StunProber* prober, int result) {
89 thread->Quit();
121 rtc::Thread* thread = rtc::ThreadManager::Instance()->WrapCurrentThread(); local
129 new StunProber(socket_factory.get(), rtc::Thread::Current(), networks);
130 auto finish_callback = [thread](StunProber* prober, int result) {
131 StopTrial(thread, prober, result);
136 thread->Run()
[all...] |
| /external/webrtc/webrtc/system_wrappers/source/ |
| critical_section_unittest.cc | 81 rtc::PlatformThread thread( variable
84 thread.Start();
89 // Thus, the thread should not be able to increment the count
91 crit_sect->Leave(); // This frees the thread to act.
93 thread.Stop();
108 rtc::PlatformThread thread( variable
111 thread.Start();
114 // The thread is capable of grabbing the lock multiple times,
120 // The thread does not increment while lock is held.
131 thread.Stop()
[all...] |
| /frameworks/av/media/libaaudio/tests/ |
| test_bad_disconnect.cpp | 24 #include <thread>
39 std::thread *thread = nullptr; member in struct:AudioEngine
123 s_AudioEngine.thread = nullptr;
131 // Handle stream restart on a separate thread
132 if (s_AudioEngine.thread == nullptr) {
133 s_AudioEngine.thread = new std::thread(s_StartThreadProc);
|
| /cts/hostsidetests/dumpsys/apps/storagedapp/src/com/android/server/cts/storaged/ |
| SimpleIOService.java | 68 Thread.sleep(100);
97 // Start up the thread running the service. Note that we create a
98 // separate thread because the service normally runs in the process's
99 // main thread, which we don't want to block. We also make it
101 HandlerThread thread = new HandlerThread("ServiceStartArguments", local
103 thread.start();
106 mServiceLooper = thread.getLooper();
|
| /cts/hostsidetests/statsd/apps/statsdapp/src/com/android/server/cts/device/statsd/ |
| StatsdCtsForegroundService.java | 57 Thread.sleep(SLEEP_OF_FOREGROUND_SERVICE);
60 Thread.currentThread().interrupt();
71 // Start up the thread running the service. Note that we create a
72 // separate thread because the service normally runs in the process's
73 // main thread, which we don't want to block. We also make it
75 HandlerThread thread = new HandlerThread("ServiceStartArguments", local
77 thread.start();
80 mServiceLooper = thread.getLooper();
|
| /cts/tests/tests/media/src/android/media/cts/ |
| ResourceManagerStubActivity.java | 78 Thread thread = new Thread() { local
87 Thread.sleep(5000); // wait for process to launch and allocate all codecs.
101 thread.start();
102 thread.join(20000 /* millis */);
104 Thread.sleep(5000); // give the gc a chance to release test activities.
|
| /external/guava/guava/src/com/google/common/base/internal/ |
| Finalizer.java | 29 * Thread that finalizes referents. All references should implement
38 * Google Collections, this thread would keep an indirect strong reference
59 * Starts the Finalizer thread. FinalizableReferenceQueue calls this method
63 * @param queue a reference queue that the thread will poll.
86 Thread thread = new Thread(finalizer); local
87 thread.setName(Finalizer.class.getName());
88 thread.setDaemon(true);
92 inheritableThreadLocals.set(thread, null)
[all...] |
| /external/guice/core/test/com/google/inject/internal/ |
| CycleDetectingLockTest.java | 51 if (Thread.currentThread().getName().equals("T2")) {
58 assertEquals("T1", Thread.currentThread().getName());
70 if (Thread.currentThread().getName().equals("T1")) {
78 assertEquals("T2", Thread.currentThread().getName());
89 Thread.currentThread().setName("T1");
104 Thread.currentThread().setName("T2");
123 * Thread A: lock a lock A (factory A)
124 * Thread B: lock a lock B (factory B)
125 * Thread A: lock a lock B (factory B)
126 * Thread B: lock a lock A (factory A
245 Thread thread = new Thread(future); local
[all...] |
| /external/ims/rcs/presencepolling/src/com/android/service/ims/presence/ |
| PersistService.java | 51 * This service essentially plays the role of a "worker thread", allowing us to store
69 // separate thread because the service normally runs in the process's
70 // main thread, which we don't want to block.
71 HandlerThread thread = new HandlerThread("PersistServiceThread", local
73 thread.start();
75 mServiceLooper = thread.getLooper();
125 logger.print( "Thread=" + Thread.currentThread().getName() + " received "
|
| /external/oj-libjdwp/src/share/classes/com/sun/tools/jdi/ |
| ThreadGroupReferenceImpl.java | 60 // static info is fetched twice (Thread group name
75 // static info is fetched twice (Thread group parent cannot
89 for (ThreadReference thread : threads()) {
90 thread.suspend();
99 for (ThreadReference thread : threads()) {
100 thread.resume();
|
| /external/testng/src/main/java/org/testng/internal/thread/ |
| ThreadUtil.java | 1 package org.testng.internal.thread;
24 * @return true if the current thread was created by TestNG.
27 return Thread.currentThread().getName().contains(THREAD_NAME);
51 public Thread newThread(Runnable r) {
52 Thread result = new Thread(r);
78 Thread.currentThread().interrupt();
85 * Returns a readable name of the current executing thread.
88 Thread thread= Thread.currentThread(); local
[all...] |
| /art/test/129-ThreadGetId/src/ |
| Main.java | 25 final Thread[] threads = new Thread[numberOfThreads];
27 threads[t] = new Thread(new Main());
30 for (Thread t : threads) {
39 static Thread getHeapTaskDaemon() throws Exception {
46 Thread[] array = new Thread[activeCount];
48 for (Thread thread : array) {
49 if (thread.getName().equals("HeapTaskDaemon") &
67 Thread thread = pair.getKey(); local
[all...] |
| /bionic/tests/ |
| semaphore_test.cpp | 208 pthread_t thread; local
209 ASSERT_EQ(0, pthread_create(&thread, nullptr, SemWaitEINTRThreadFn, &s));
210 // Give some time for the thread to run sem_wait.
212 ASSERT_EQ(0, pthread_kill(thread, SIGUSR1));
213 // Give some time for the thread to handle signal.
217 ASSERT_EQ(0, pthread_join(thread, &result));
231 pthread_t thread; local
232 ASSERT_EQ(0, pthread_create(&thread, nullptr, SemWaitEINTRThreadFn, &s));
233 // Give some time for the thread to run sem_wait.
235 ASSERT_EQ(0, pthread_kill(thread, SIGUSR1))
[all...] |
| /cts/tests/tests/rcs/src/android/telephony/ims/cts/ |
| Rcs1To1ThreadTest.java | 67 Rcs1To1Thread thread = mRcsMessageStore.createRcs1To1Thread(participant); local
69 assertThat(thread.isGroup()).isFalse();
75 Rcs1To1Thread thread = mRcsMessageStore.createRcs1To1Thread(participant); local
77 thread.setFallbackThreadId(2);
79 assertThat(thread.getFallbackThreadId()).isEqualTo(2);
|
