| /frameworks/base/core/tests/coretests/src/android/database/sqlite/ |
| SQLiteConnectionPoolTest.java | 72 HandlerThread thread = new HandlerThread("test-close-idle-connections-thread"); local
73 Log.i(TAG, "Starting " + thread.getName());
74 thread.start();
76 pool.setupIdleConnectionHandler(thread.getLooper(), 100);
83 Thread.sleep(200);
89 thread.quit();
|
| /frameworks/opt/bitmap/src/com/android/bitmap/ |
| NamedThreadFactory.java | 34 public Thread newThread(final Runnable runnable) {
35 final Thread thread = mDefaultThreadFactory.newThread(runnable); local
36 thread.setName(mBaseName + "-" + mCount.getAndIncrement());
37 return thread;
|
| /hardware/interfaces/broadcastradio/common/tests/ |
| WorkerThread_test.cpp | 42 WorkerThread thread; local
45 thread.schedule(
62 WorkerThread thread; local
64 thread.schedule([&]() { executed2 = true; }, 100ms);
65 thread.schedule([&]() { executed1 = true; }, 25ms);
68 thread.cancelAll();
78 WorkerThread thread; local
80 thread.schedule(
87 thread.schedule(
94 thread.schedule
125 WorkerThread thread; local
[all...] |
| /prebuilts/gdb/darwin-x86/lib/python2.7/test/ |
| fork_wait.py | 5 We want fork1() semantics -- only the forking thread survives in the
17 thread = test_support.import_module('thread') variable
51 thread.start_new(self.f, (i,))
|
| test_threadsignals.py | 8 thread = import_module('thread') variable
14 signalled_all=thread.allocate_lock()
28 signal_blackboard[sig]['tripped_by'] = thread.get_ident()
30 # a function that will be spawned as a separate thread.
38 We spawn a thread, have the thread send two signals, and
40 and that they were run by the main thread.
49 # (it might even be after the thread exits
61 thread.get_ident()
[all...] |
| /prebuilts/gdb/linux-x86/lib/python2.7/test/ |
| fork_wait.py | 5 We want fork1() semantics -- only the forking thread survives in the
17 thread = test_support.import_module('thread') variable
51 thread.start_new(self.f, (i,))
|
| test_threadsignals.py | 8 thread = import_module('thread') variable
14 signalled_all=thread.allocate_lock()
28 signal_blackboard[sig]['tripped_by'] = thread.get_ident()
30 # a function that will be spawned as a separate thread.
38 We spawn a thread, have the thread send two signals, and
40 and that they were run by the main thread.
49 # (it might even be after the thread exits
61 thread.get_ident()
[all...] |
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| fork_wait.py | 5 We want fork1() semantics -- only the forking thread survives in the
17 thread = test_support.import_module('thread') variable
51 thread.start_new(self.f, (i,))
|
| test_threadsignals.py | 8 thread = import_module('thread') variable
14 signalled_all=thread.allocate_lock()
28 signal_blackboard[sig]['tripped_by'] = thread.get_ident()
30 # a function that will be spawned as a separate thread.
38 We spawn a thread, have the thread send two signals, and
40 and that they were run by the main thread.
49 # (it might even be after the thread exits
61 thread.get_ident()
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| fork_wait.py | 5 We want fork1() semantics -- only the forking thread survives in the
17 thread = test_support.import_module('thread') variable
51 thread.start_new(self.f, (i,))
|
| test_threadsignals.py | 8 thread = import_module('thread') variable
14 signalled_all=thread.allocate_lock()
28 signal_blackboard[sig]['tripped_by'] = thread.get_ident()
30 # a function that will be spawned as a separate thread.
38 We spawn a thread, have the thread send two signals, and
40 and that they were run by the main thread.
49 # (it might even be after the thread exits
61 thread.get_ident()
[all...] |
| /system/bt/osi/test/ |
| semaphore_test.cc | 12 #include "osi/include/thread.h"
74 thread_t* thread = thread_new("semaphore_test_thread"); local
75 ASSERT_TRUE(thread != NULL);
79 thread_post(thread, sleep_then_increment_counter, &sequence_helper);
85 thread_free(thread);
|
| /system/extras/memory_replay/tests/ |
| ThreadTest.cpp | 25 #include "Thread.h"
27 typedef std::pair<Thread*, volatile bool*> thread_data_t;
30 Thread thread; local
32 // A thread should be ready immediately. If not, this will hang forever.
33 thread.WaitForReady();
38 Thread* thread = thread_data->first; local
41 thread->WaitForReady();
48 Thread thread local
68 Thread* thread = thread_data->first; local
78 Thread thread; local
96 Thread thread; local
104 Thread thread; local
[all...] |
| ThreadsTest.cpp | 21 #include "Thread.h"
28 Thread* thread = threads.CreateThread(900); local
29 ASSERT_TRUE(thread != nullptr);
32 Thread* found_thread = threads.FindThread(900);
33 ASSERT_EQ(thread, found_thread);
35 thread->CreateAction(0x1234, "thread_done", "");
37 thread->SetPending();
39 threads.Finish(thread);
48 Thread* thread1 = threads.CreateThread(900)
90 Thread* thread = threads.CreateThread(900); local
117 Thread* thread = threads.CreateThread(900+i); local
[all...] |
| /cts/libs/deviceutillegacy/src/com/android/compatibility/common/util/ |
| SynchronousPixelCopy.java | 34 HandlerThread thread = new HandlerThread("PixelCopyHelper"); external variable declarations
35 thread.start();
36 sHandler = new Handler(thread.getLooper());
|
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/Events/ |
| MonitorContendedEnterAndEnteredDebuggee.java | 31 BlockedThread thread; field in class:MonitorContendedEnterAndEnteredDebuggee
35 thread = new BlockedThread(logWriter,TESTED_THREAD);
38 logWriter.println("--> Main thread : started");
45 logWriter.println("main thread: start tested thread");
46 thread.start();
48 // wait and hold the lock until the second thread blocks
49 while (!thread.getState().equals(Thread.State.valueOf("BLOCKED"))){
50 Thread.yield()
[all...] |
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| ThreadFactoryBuilderTest.java | 25 import java.lang.Thread.UncaughtExceptionHandler;
44 @Override public void uncaughtException(Thread t, Throwable e) {
58 Thread thread = threadFactory.newThread(monitoredRunnable); local
59 checkThreadPoolName(thread, 1);
61 Thread defaultThread =
63 assertEquals(defaultThread.isDaemon(), thread.isDaemon());
64 assertEquals(defaultThread.getPriority(), thread.getPriority());
65 assertSame(defaultThread.getThreadGroup(), thread.getThreadGroup());
67 thread.getUncaughtExceptionHandler())
116 Thread thread = factory.newThread(monitoredRunnable); local
122 Thread thread = factory.newThread(monitoredRunnable); local
129 Thread thread = factory.newThread(monitoredRunnable); local
193 Thread thread = builder.setThreadFactory(backingThreadFactory).build() local
[all...] |
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| MoreExecutorsDirectExecutorBenchmark.java | 66 Set<Thread> threads = new HashSet<Thread>();
71 Thread thread = new Thread() { local
80 threads.add(thread);
85 for (Thread thread : threads) {
86 thread.interrupt(); // try to get them to exit
106 for (Thread thread : threads)
[all...] |
| /external/icu/android_icu4j/src/main/tests/android/icu/dev/test/translit/ |
| ThreadTest.java | 39 Worker thread = new Worker(); local
40 threads.add(thread);
41 thread.start();
44 for (Worker thread: threads) {
46 thread.join();
48 expectedCount = thread.count;
50 if (expectedCount != thread.count) {
62 private class Worker extends Thread {
83 ArrayList<Thread> threads = new ArrayList<Thread>();
[all...] |
| /external/icu/icu4j/main/tests/translit/src/com/ibm/icu/dev/test/translit/ |
| ThreadTest.java | 36 Worker thread = new Worker(); local
37 threads.add(thread);
38 thread.start();
41 for (Worker thread: threads) {
43 thread.join();
45 expectedCount = thread.count;
47 if (expectedCount != thread.count) {
59 private class Worker extends Thread {
80 ArrayList<Thread> threads = new ArrayList<Thread>();
[all...] |
| /external/protobuf/java/util/src/test/java/com/google/protobuf/util/ |
| TimeUtilTest.java | 84 private class ParseTimestampThread extends Thread {
128 final List<Thread> threads = new ArrayList<Thread>();
133 Thread thread = new ParseTimestampThread( local
135 thread.start();
136 threads.add(thread);
138 Thread.sleep(RUNNING_TIME);
140 for (Thread thread : threads)
[all...] |
| /libcore/luni/src/test/java/libcore/java/util/logging/ |
| OldLogRecordTest.java | 33 Thread.sleep(2);
52 // Create and start the thread
53 MockThread thread = new MockThread(); local
54 thread.start();
56 thread.join();
70 assertTrue(lr.getThreadID() != thread.lr.getThreadID());
72 assertTrue(thread.lr.getThreadID() != thread2.lr.getThreadID());
75 public class MockThread extends Thread {
76 public LogRecord lr = null; //will be update by the thread
83 lr = new LogRecord(Level.CONFIG, "msg thread");
[all...] |
| /libcore/luni/src/test/java/org/apache/harmony/crypto/tests/javax/crypto/func/ |
| TestThread.java | 34 Thread thread = null; local
38 thread = new Thread(this);
39 thread.start();
41 thread.join();
|
| /packages/providers/DownloadProvider/src/com/android/providers/downloads/ |
| DownloadJobService.java | 60 // Spin up thread to handle this download
67 final DownloadThread thread; local
73 thread = new DownloadThread(this, params, info);
74 mActiveThreads.put(id, thread);
76 thread.start();
85 final DownloadThread thread; local
87 thread = mActiveThreads.removeReturnOld(id);
89 if (thread != null) {
90 // If the thread is still running, ask it to gracefully shutdown,
92 thread.requestShutdown()
[all...] |
| /cts/hostsidetests/incident/apps/batterystatsapp/src/com/android/server/cts/device/batterystats/ |
| SimpleForegroundService.java | 53 Thread.sleep(2000);
56 Thread.currentThread().interrupt();
67 // Start up the thread running the service. Note that we create a
68 // separate thread because the service normally runs in the process's
69 // main thread, which we don't want to block. We also make it
71 HandlerThread thread = new HandlerThread("ServiceStartArguments", local
73 thread.start();
76 mServiceLooper = thread.getLooper();
|
