| /system/extras/memory_replay/ |
| Threads.cpp | 30 #include "Thread.h"
34 Thread* thread = reinterpret_cast<Thread*>(data); local
36 thread->WaitForPending();
37 Action* action = thread->GetAction();
38 thread->AddTimeNsecs(action->Execute(thread->pointers()));
40 thread->ClearPending();
51 data_size_ = (max_threads_ * sizeof(Thread) + pagesize - 1) & ~(pagesize - 1)
80 Thread* thread = FindEmptyEntry(tid); local
[all...] |
| /tools/tradefederation/core/src/com/android/tradefed/util/ |
| Alarm.java | 24 * A thread which waits for a period of time and then interrupts a specific other thread.
25 * Can call {@link Thread#interrupt()} to get a thread out of a blocking wait, or
26 * {@link Socket#close()} to stop a thread from blocking on a socket read or write.
30 public class Alarm extends Thread {
31 private final List<Thread> mInterruptThreads = new ArrayList<Thread>();
54 public void addThread(Thread intThread) {
69 Thread.sleep(mTimeoutTime)
[all...] |
| /art/test/051-thread/src/ |
| Main.java | 23 * Test some basic thread stuff.
28 System.out.println("thread test starting");
36 System.out.println("thread test done");
40 * Simple thread capacity test.
48 for (TestCapacityThread thread : threads) {
49 thread.start();
51 for (TestCapacityThread thread : threads) {
52 thread.join();
55 System.out.println("testThreadCapacity thread count: " + TestCapacityThread.mCount);
58 private static class TestCapacityThread extends Thread {
126 Thread thread = new Thread() { local
[all...] |
| /external/junit/src/main/java/org/junit/internal/runners/statements/ |
| FailOnTimeout.java | 63 * thread. This can be useful for disabling timeouts in environments
100 Thread thread = new Thread(task, "Time-limited test"); local
101 thread.setDaemon(true);
102 thread.start();
104 Throwable throwable = getResult(task, thread);
115 private Throwable getResult(FutureTask<Throwable> task, Thread thread) {
123 return e; // caller will re-throw; no need to call Thread.interrupt(
[all...] |
| /external/mockftpserver/MockFtpServer/src/test/java/org/mockftpserver/core/session/ |
| DefaultSession_RunTest.java | 36 * Tests for the DefaultSession class that require the session (thread) to be running/active.
93 Thread thread = new Thread(session);
local
94 thread.start();
95 Thread.sleep(1000L);
98 thread.join();
219 * @throws InterruptedException - if the thread sleep is interrupted
225 Thread thread = new Thread(session); local
[all...] |
| /external/mockftpserver/branches/1.x_Branch/src/test/java/org/mockftpserver/core/session/ |
| DefaultSession_RunTest.java | 41 * Tests for the DefaultSession class that require the session (thread) to be running/active.
229 Thread thread = new Thread(session);
local
230 thread.start();
233 Thread.sleep(50L);
237 thread.join();
|
| /frameworks/opt/setupwizard/library/test/instrumentation/src/com/android/setupwizardlib/test/ |
| SystemBarHelperTest.java | 160 final HandlerThread thread = new HandlerThread("SystemBarHelperTest"); local
161 thread.start();
162 final Handler handler = new Handler(thread.getLooper());
170 thread.quit();
|
| /frameworks/support/compat/src/androidTest/java/androidx/core/provider/ |
| SelfDestructiveThreadTest.java | 51 private void waitUntilDestruction(SelfDestructiveThread thread, long timeoutMs) {
52 if (!thread.isRunning()) {
60 Thread.sleep(timeSliceMs);
64 if (!thread.isRunning()) {
68 throw new RuntimeException("Timeout for waiting thread destruction.");
79 Thread.sleep(TimeUnit.NANOSECONDS.toMillis(deadlineNanoTime - now));
89 final SelfDestructiveThread thread = new SelfDestructiveThread( local
91 thread.postAndWait(new Callable<Object>() {
97 waitUntilDestruction(thread, DEFAULT_TIMEOUT);
98 assertFalse(thread.isRunning())
104 final SelfDestructiveThread thread = new SelfDestructiveThread( local
127 final SelfDestructiveThread thread = new SelfDestructiveThread( local
151 final SelfDestructiveThread thread = new SelfDestructiveThread( local
179 final SelfDestructiveThread thread = new SelfDestructiveThread( local
266 final SelfDestructiveThread thread = new SelfDestructiveThread( local
[all...] |
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/lang/ |
| ProcessManagerTest.java | 31 Thread thread = null; field in class:ProcessManagerTest
60 thread = new Thread() {
77 Thread interruptThread = new Thread() {
85 thread.interrupt();
88 thread.start();
96 Thread.sleep(100);
101 thread.interrupt()
138 Thread thread = new Thread() { local
[all...] |
| /libcore/luni/src/test/java/libcore/java/io/ |
| InterruptedStreamTest.java | 40 * Test that interrupting a thread blocked on I/O causes that thread to throw
52 Thread.interrupted();
61 Thread.interrupted(); // clear interrupted bit
121 Thread thread = interruptMeLater(); local
127 confirmInterrupted(thread);
132 Thread thread = interruptMeLater(); local
138 confirmInterrupted(thread);
143 Thread thread = interruptMeLater(); local
154 Thread thread = interruptMeLater(); local
167 Thread thread = interruptMeLater(); local
180 Thread thread = interruptMeLater(); local
195 Thread thread = new Thread(new Runnable () { local
[all...] |
| /libcore/luni/src/test/java/libcore/java/nio/channels/ |
| OldServerSocketChannelTest.java | 83 class MyThread extends Thread {
97 MyThread thread = new MyThread(); local
98 thread.start();
100 Thread.currentThread().sleep(TIME_UNIT);
101 thread.interrupt();
105 if (thread.errMsg != null) {
106 fail(thread.errMsg);
|
| /libcore/luni/src/test/java/org/apache/harmony/crypto/tests/javax/crypto/func/ |
| CipherThread.java | 75 Thread thread = null; local
83 thread = new Thread(this);
84 thread.start();
86 thread.join();
|
| /packages/apps/Dialer/java/com/android/dialer/simulator/impl/ |
| SimulatorRemoteVideo.java | 37 @NonNull private final RenderThread thread; field in class:SimulatorRemoteVideo
41 thread = new RenderThread(new Renderer(surface));
47 thread.start();
53 thread.quitSafely();
58 return thread.getRenderer();
|
| /external/guava/guava-tests/test/com/google/common/cache/ |
| LocalLoadingCacheTest.java | 32 import java.lang.Thread.UncaughtExceptionHandler;
345 Thread thread = new Thread() { local
355 thread.setUncaughtExceptionHandler(new UncaughtExceptionHandler() {
357 public void uncaughtException(Thread t, Throwable e) {}
359 thread.start();
364 for (StackTraceElement trace : thread.getStackTrace()) {
|
| /frameworks/support/emoji/core/src/androidTest/java/androidx/emoji/text/ |
| FontRequestEmojiCompatConfigTest.java | 269 HandlerThread thread = new HandlerThread("testThread"); local
270 thread.start();
272 Handler handler = new Handler(thread.getLooper());
284 // To avoid race condition, change the fetchFonts result on the handler thread.
307 thread.quit();
326 HandlerThread thread = new HandlerThread("testThread"); local
327 thread.start();
329 Handler handler = new Handler(thread.getLooper());
346 // To avoid race condition, change the fetchFonts result on the handler thread.
364 thread.quit()
382 HandlerThread thread = new HandlerThread("testThread"); local
438 HandlerThread thread = new HandlerThread("testThread"); local
[all...] |
| /libcore/luni/src/test/java/libcore/java/net/ |
| ServerSocketConcurrentCloseTest.java | 62 // implAccept() on background thread to prevent this test hanging
65 Thread thread = new Thread("implAccept() closed ServerSocket") { local
80 thread.start();
88 thread.join();
125 * <p>Spawns a server and client thread that continuously connect to each
142 Thread serverThread = new Thread(serverRunnable, TAG + " (server)");
145 Thread clientThread = new Thread(clientRunnable, TAG + " (client)")
[all...] |
| /art/runtime/native/ |
| dalvik_system_VMStack.cc | 39 typename std::result_of<T(Thread*, const ScopedFastNativeObjectAccess&)>::type>
49 // Never allow suspending the heap task thread since it may deadlock if allocations are
51 Thread* heap_task_thread =
57 // Suspend thread to build stack trace.
61 Thread* thread = thread_list->SuspendThreadByPeer(peer, local
65 if (thread != nullptr) {
69 trace = fn(thread, soa);
71 // Restart suspended thread.
72 bool resumed = thread_list->Resume(thread, SuspendReason::kInternal)
[all...] |
| /art/test/114-ParallelGC/src/ |
| Main.java | 24 // Timeout in minutes. Make it larger than the run-test timeout to get a native thread dump by
38 Thread[] threads = new Thread[THREAD_COUNT];
46 threads[i] = new Thread(new Main(startBarrier));
51 for (Thread thread : threads) {
52 thread.join();
131 System.out.println("Waited too long for the last thread.");
136 Thread.sleep(25);
|
| /bionic/tests/ |
| leak_test.cpp | 29 #include <thread>
113 pthread_t thread; local
114 ASSERT_EQ(0, pthread_create(&thread, nullptr, [](void*) -> void* { return nullptr; }, nullptr));
115 ASSERT_EQ(0, pthread_join(thread, nullptr));
145 pthread_t thread; local
146 ASSERT_EQ(0, pthread_create(&thread, nullptr, thread_function, &threads[i]));
147 ASSERT_EQ(0, pthread_detach(thread));
|
| pty_test.cpp | 126 // 2. Make master thread and slave thread running on different cpus:
127 // master thread uses first available cpu, and slave thread uses other cpus.
138 // 3. Create thread for slave reader.
139 pthread_t thread; local
143 ASSERT_EQ(0, pthread_create(&thread, nullptr,
153 // by the reader thread on another cpu.
163 ASSERT_EQ(0, pthread_join(thread, nullptr));
|
| /device/google/cuttlefish_common/guest/hals/gps/ |
| gps_thread.h | 38 // Control commands to GPS thread
46 pthread_t thread; member in struct:__anon2007
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
| test_thread.py | 5 thread = test_support.import_module('thread')
variable
16 _print_mutex = thread.allocate_lock()
28 self.done_mutex = thread.allocate_lock()
30 self.running_mutex = thread.allocate_lock()
31 self.random_mutex = thread.allocate_lock()
43 thread.start_new_thread(self.task, (self.next_ident,))
59 # Basic test for thread creation.
68 self.assertEqual(thread.stack_size(), 0, "initial stack size is not 0")
70 thread.stack_size(0)
[all...] |
| /external/boringssl/src/crypto/ |
| thread_test.cc | 54 static int wait_for_thread(thread_t thread) {
55 return WaitForSingleObject(thread, INFINITE) == 0;
77 static int wait_for_thread(thread_t thread) {
78 return pthread_join(thread, NULL) == 0;
159 << "Thread-local data was non-NULL at start.";
161 thread_t thread; local
162 ASSERT_TRUE(run_thread(&thread, []() {
174 ASSERT_TRUE(wait_for_thread(thread));
176 EXPECT_TRUE(g_test_thread_ok) << "Thread-local data didn't work in thread."
192 thread_t thread; local
[all...] |
| /external/chromium-trace/catapult/systrace/atrace_helper/jni/ |
| atrace_process_dump.cc | 213 const ThreadInfo* thread = &(thread_it->second); local
214 fprintf(out_, "\"%d\":{", thread->tid);
215 fprintf(out_, "\"name\":\"%s\"", thread->name);
|
| /external/deqp/framework/delibs/dethread/unix/ |
| deThreadUnix.c | 2 * drawElements Thread Library
21 * \brief Unix implementation of thread management.
53 pthread_t thread; member in struct:Thread_s
56 } Thread;
58 DE_STATIC_ASSERT(sizeof(deThread) >= sizeof(Thread*));
62 Thread* thread = (Thread*)entryPtr; local
63 deThreadFunc func = thread->func;
64 void* arg = thread->arg
75 Thread* thread = (Thread*)deCalloc(sizeof(Thread)); local
114 Thread* thread = (Thread*)threadptr; local
132 Thread* thread = (Thread*)threadptr; local
[all...] |
