| /sdk/eclipse/plugins/com.android.ide.eclipse.ddms/src/com/android/ide/eclipse/ddms/ |
| DdmsPlugin.java | 163 // because this can be run, in some cases, by a non UI thread, and because
165 // in the UI thread.
189 // dialog box only run in UI thread..
552 // starts the server in a thread in case this is blocking.
554 new Thread() {
613 * This is sent from a non UI thread.
633 * This is sent from a non UI thread.
668 * This is sent from a non UI thread.
737 // because the listener expect to receive this from the UI thread, and this is called
738 // from the AndroidDebugBridge notifications, we need to run this in the UI thread
[all...] |
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| ForkJoinPool.java | 38 import java.lang.Thread.UncaughtExceptionHandler;
194 * push and pop are called only from the owning thread (or, as
346 * All worker thread creation is on-demand, triggered by task
388 * new thread invokes registerWorker, where it constructs a
390 * (expanding the array if necessary). The thread is then started.
404 * the thread has not started yet, but do so for creating
489 * thread, as well as every other worker thereafter terminating,
511 * just let them block (as in Thread.join). We also cannot just
523 * thread to compensate for blocked joiners until they unblock.
528 * task being joined, the joining thread can do so directly
1158 ForkJoinWorkerThread thread = owner; local
3281 Thread thread = Thread.currentThread(); local
[all...] |
| /art/runtime/ |
| thread.cc | 17 #include "thread.h"
92 #include "thread-inl.h"
111 extern "C" NO_RETURN void artDeoptimize(Thread* self);
113 bool Thread::is_started_ = false;
114 pthread_key_t Thread::pthread_key_self_;
115 ConditionVariable* Thread::resume_cond_ = nullptr;
116 const size_t Thread::kStackOverflowImplicitCheckSize = GetStackOverflowReservedBytes(kRuntimeISA);
117 bool (*Thread::is_sensitive_thread_hook_)() = nullptr;
118 Thread* Thread::jit_sensitive_thread_ = nullptr
[all...] |
| thread.h | 96 class Thread;
100 // Thread priorities. These must match the Thread.MIN_PRIORITY,
101 // Thread.NORM_PRIORITY, and Thread.MAX_PRIORITY constants.
109 kSuspendRequest = 1, // If set implies that suspend_count_ > 0 and the Thread should enter the
111 kCheckpointRequest = 2, // Request that the thread do some checkpoint work and then continue.
112 kEmptyCheckpointRequest = 4, // Request that the thread do empty checkpoint and then continue.
131 // Thread's stack layout for implicit stack overflow checks:
150 // result in a segmentation fault signal. At any point, the thread's SP will be somewher
[all...] |
| /cts/tests/camera/src/android/hardware/cts/ |
| CameraGLTest.java | 130 new Thread() {
133 Log.v(TAG, "Start camera/surfacetexture thread");
136 // Save the looper so that we can terminate this thread
139 // These must be instantiated outside the UI thread, since the
140 // UI thread will be doing a lot of waiting, stopping callbacks.
152 Log.v(TAG, "Stop camera/surfacetexture thread");
163 * Terminates the message looper thread.
173 // the method. So we need to join the looper thread here.
[all...] |
| CameraTest.java | 155 new Thread() {
161 // Save the looper so that we can terminate this thread
194 * Terminates the message looper thread.
202 // the method. So we need to join the looper thread here.
470 Thread.sleep(1000);
[all...] |
| /cts/tests/tests/media/src/android/media/cts/ |
| MediaDrmClearkeyTest.java | 241 new Thread() {
251 // Save the looper so that we can terminate this thread
395 Thread.sleep(100);
419 Thread.sleep(SLEEP_TIME_MS);
[all...] |
| /external/antlr/antlr-3.4/tool/src/main/java/org/antlr/tool/ |
| ErrorManager.java | 255 /** Each thread might need it's own error listener; e.g., a GUI with
274 * per thread.
278 /** Each thread has its own ptr to a Tool object, which knows how
279 * to panic, for example. In a GUI, the thread might just throw an Error
471 ClassLoader cl = Thread.currentThread().getContextClassLoader();
495 * depending on the thread. I store a single listener per
496 * thread.
499 threadToListenerMap.put(Thread.currentThread(), listener);
503 threadToListenerMap.remove(Thread.currentThread());
507 threadToToolMap.put(Thread.currentThread(), tool)
[all...] |
| /external/clang/test/SemaCXX/ |
| typo-correction.cpp | 542 class Thread {
545 static void Stop(); // expected-note {{'Thread::Stop' declared here}}
555 // Don't suggest Thread::Start as a correction just because it has the same
560 Stop(); // expected-error {{use of undeclared identifier 'Stop'; did you mean 'Thread::Stop'?}}
|
| /external/robolectric-shadows/robolectric/src/test/java/org/robolectric/shadows/ |
| SQLiteDatabaseTest.java | 783 new Thread() {
[all...] |
| /external/webrtc/webrtc/examples/androidapp/src/org/appspot/apprtc/ |
| CallActivity.java | 142 Thread.setDefaultUncaughtExceptionHandler(
393 // Should be called from UI thread
485 // All callbacks are invoked from websocket signaling looper thread and
486 // are routed to UI thread.
582 // All callbacks are invoked from peer connection client looper thread and
583 // are routed to UI thread.
|
| /frameworks/base/core/java/android/database/sqlite/ |
| SQLiteConnectionPool.java | 58 * The connection pool is thread-safe (but the connections themselves are not).
154 * This flag indicates that the connection is needed by the UI thread.
520 // unless we started an extra Thread to function as a reference queue. Second,
706 waiter = obtainConnectionWaiterLocked(Thread.currentThread(), startTime,
741 // Park the thread until a connection is assigned or the pool is closed.
757 Thread.interrupted();
823 final Thread thread = Thread.currentThread(); local
[all...] |
| /frameworks/base/services/core/java/com/android/server/am/ |
| TaskPersister.java | 191 Thread.yield();
634 private class LazyTaskWriterThread extends Thread {
|
| /frameworks/rs/tests/java_api/ImageProcessing_jb/src/com/android/rs/image/ |
| ImageProcessingActivityJB.java | 149 // Processor is a helper thread for running the work without
150 // blocking the UI thread.
151 class Processor extends Thread {
482 static class spinner extends Thread {
493 Thread.yield();
753 // Calling from onResume() to make sure the operation is on the UI thread.
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/net/ |
| SocketTest.java | 120 Thread t;
125 Thread serverThread = new Thread(server);
130 Thread clientThread = new Thread(client);
823 Thread thread = new Thread(runnable, "Socket.getOutputStream"); local
824 thread.start();
833 Thread.sleep(200)
[all...] |
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/nio/channels/ |
| ServerSocketChannelTest.java | 374 // so must close the server channel with another thread.
375 new Thread() {
378 Thread.sleep(TIME_UNIT);
517 // check if the thread threw any exceptions
523 class WriteChannelThread extends Thread {
562 // check if the thread threw any exceptions
585 // check if the thread threw any exceptions
591 class WriteSocketThread extends Thread {
628 // check if the thread threw any exceptions
791 // when it is accepting in main thread
[all...] |
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| LinkedTransferQueueTest.java | 220 Thread t = newStartedThread(new CheckedRunnable() {
226 Thread.currentThread().interrupt();
231 assertFalse(Thread.interrupted());
238 assertFalse(Thread.interrupted());
294 Thread t = newStartedThread(new CheckedRunnable() {
315 * timed poll after thread interrupted throws InterruptedException
320 Thread t = newStartedThread(new CheckedRunnable() {
323 Thread.currentThread().interrupt();
700 Thread t = newStartedThread(new CheckedRunnable() {
743 Thread t = newStartedThread(new CheckedRunnable()
[all...] |
| ReentrantLockTest.java | 65 public Thread getOwner() {
68 public Collection<Thread> getQueuedThreads() {
71 public Collection<Thread> getWaitingThreads(Condition c) {
89 void waitForQueuedThread(PublicReentrantLock lock, Thread t) {
94 Thread.yield();
111 * Checks that lock is locked by the given thread.
113 void assertLockedBy(PublicReentrantLock lock, Thread t) {
116 assertEquals(t == Thread.currentThread(),
118 assertEquals(t == Thread.currentThread(),
123 * Checks that lock is locked by the current thread
[all...] |
| ReentrantReadWriteLockTest.java | 66 public Thread getOwner() {
69 public Collection<Thread> getQueuedThreads() {
72 public Collection<Thread> getWaitingThreads(Condition c) {
91 void waitForQueuedThread(PublicReentrantReadWriteLock lock, Thread t) {
96 Thread.yield();
115 * Checks that lock is write-locked by the given thread.
117 void assertWriteLockedBy(PublicReentrantReadWriteLock lock, Thread t) {
120 assertEquals(t == Thread.currentThread(),
122 assertEquals(t == Thread.currentThread(),
124 assertEquals(t == Thread.currentThread()
[all...] |
| ScheduledExecutorSubclassTest.java | 393 * thread becomes active
438 Thread.yield();
546 * setThreadFactory sets the thread factory returned by getThreadFactory
[all...] |
| ScheduledExecutorTest.java | 337 * thread becomes active
382 Thread.yield();
491 * setThreadFactory sets the thread factory returned by getThreadFactory
[all...] |
| ThreadPoolExecutorSubclassTest.java | 60 Thread thread; field in class:ThreadPoolExecutorSubclassTest.CustomTask
83 if (mayInterrupt && thread != null)
84 thread.interrupt();
96 thread = Thread.currentThread();
113 thread = null;
205 protected void beforeExecute(Thread t, Runnable r) {
228 public Thread newThread(Runnable r) {
230 return new Thread(r)
[all...] |
| ThreadPoolExecutorTest.java | 58 protected void beforeExecute(Thread t, Runnable r) {
81 public Thread newThread(Runnable r) {
83 return new Thread(r);
106 * thread becomes active
129 * prestartCoreThread starts a thread if under corePoolSize, else doesn't
205 Thread.yield();
253 * setThreadFactory sets the thread factory returned by getThreadFactory
[all...] |
| /libcore/luni/src/test/java/libcore/java/net/ |
| SocketTest.java | 129 Thread.sleep(1);
327 new Thread() {
413 // Wait sufficient time for the connectWorker thread to run and start connect().
414 Thread.sleep(2000);
599 new Thread(() -> {
|
| /packages/apps/Settings/src/com/android/settings/users/ |
| UserSettings.java | 681 new Thread() {
711 new Thread() {
[all...] |
