| /external/jmdns/src/javax/jmdns/impl/ |
| DNSStatefulObject.java | 18 * <b>Implementation note:</b> This interface is accessed from multiple threads. The implementation must be thread safe.
25 * This class define a semaphore. On this multiple threads can wait the arrival of one event. Thread wait for a maximum defined by the timeout.
37 private final ConcurrentMap<Thread, Semaphore> _semaphores;
46 _semaphores = new ConcurrentHashMap<Thread, Semaphore>(50);
50 * Blocks the current thread until the event arrives or the timeout expires.
56 Thread thread = Thread.currentThread(); local
57 Semaphore semaphore = _semaphores.get(thread);
61 _semaphores.putIfAbsent(thread, semaphore)
[all...] |
| /external/smack/src/org/xbill/DNS/ |
| SimpleResolver.java | 321 Thread thread = new ResolveThread(this, query, id, listener); local
322 thread.setName(name);
323 thread.setDaemon(true);
324 thread.start();
|
| /packages/services/Mms/src/com/android/mms/service/ |
| MmsService.java | 102 * A thread-based request queue for executing the MMS requests in serial order
252 Log.e(TAG, "deleteStoredConversation: invalid thread id");
287 Log.e(TAG, "archiveStoredConversation: invalid thread id");
352 final HandlerThread thread = local
354 thread.start();
355 mRequestQueues[queueIndex] = new RequestQueue(thread.getLooper());
[all...] |
| /packages/services/Telephony/src/com/android/phone/ |
| SimContacts.java | 96 private class ImportAllSimContactsThread extends Thread
280 ImportAllSimContactsThread thread = new ImportAllSimContactsThread(); local
292 getString(R.string.cancel), thread);
297 thread.start();
|
| /development/samples/JetBoy/src/com/example/android/jetboy/ |
| JetBoyView.java | 125 class JetBoyThread extends Thread implements OnJetEventListener {
215 /** Message handler used by thread to interact with TextView */
433 // JET info: inthis animation thread object.
1293 private JetBoyThread thread; field in class:JetBoyView
[all...] |
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/lang/ |
| ThreadGroupTest.java | 27 private Thread.UncaughtExceptionHandler originalThreadDefaultUncaughtExceptionHandler;
31 initialThreadGroup = Thread.currentThread().getThreadGroup();
42 originalThreadDefaultUncaughtExceptionHandler = Thread.getDefaultUncaughtExceptionHandler();
44 Thread.setDefaultUncaughtExceptionHandler(testThreadDefaultUncaughtExceptionHandler);
50 Thread.setDefaultUncaughtExceptionHandler(originalThreadDefaultUncaughtExceptionHandler);
80 newGroup.getParent() == Thread.currentThread().getThreadGroup());
103 Thread t1 = new Thread(tg, new Runnable() {
106 Thread.sleep(5000);
181 Thread noOp = new Thread(testRoot, null, "no-op thread")
511 Thread thread = new Thread(testRoot, null, "suicidal thread") { local
545 Thread thread = new Thread(testRoot, null, "no-op thread"); local
579 Thread thread = new Thread(testRoot, null, "RuntimeException thread") { local
616 Thread thread = new Thread(testRoot, null, "RuntimeException thread") { local
648 Thread thread = new Thread(testRoot, null, "no-op thread") { local
775 private Thread thread; field in class:ThreadGroupTest.TestThreadDefaultUncaughtExceptionHandler
[all...] |
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| JSR166TestCase.java | 57 * them. These methods are used to clear and check for thread
64 * small amounts of computation (creating a thread, calling a few
162 * harness thread, triggering a test case failure. Only the first
177 * Triggers test case failure if any thread assertions have failed,
178 * by rethrowing, in the test harness thread, any exception recorded
181 * Triggers test case failure if interrupt status is set in the main thread.
200 if (Thread.interrupted())
201 throw new AssertionFailedError("interrupt status set in main thread");
210 Thread[] survivors = new Thread[5]
213 Thread thread = survivors[i]; local
[all...] |
| /device/google/accessory/demokit/app/src/com/google/android/DemoKit/ |
| DemoKitActivity.java | 225 Thread thread = new Thread(null, this, "DemoKit"); local
226 thread.start();
|
| /external/nist-sip/java/gov/nist/javax/sip/stack/ |
| TCPMessageChannel.java | 53 * It starts a message parser in its own thread and talks to the message parser via a pipe. The
71 protected InputStream myClientInputStream; // just to pass to thread.
81 private Thread mythread;
131 mythread = new Thread(this);
148 * Zurich) sent in a bug fix for this method. A thread was being uncessarily created.
270 Thread thread = new Thread(this); local
271 thread.setDaemon(true);
272 thread.setName("TCPMessageChannelThread")
[all...] |
| /frameworks/base/core/java/android/preference/ |
| SeekBarVolumizer.java | 78 HandlerThread thread = new HandlerThread(TAG + ".CallbackHandler"); local
79 thread.start();
80 mHandler = new Handler(thread.getLooper(), this);
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/statusbar/policy/ |
| FlashlightController.java | 124 HandlerThread thread = new HandlerThread(TAG, Process.THREAD_PRIORITY_BACKGROUND); local
125 thread.start();
126 mHandler = new Handler(thread.getLooper());
|
| /frameworks/opt/net/wifi/service/java/com/android/server/wifi/ |
| RttService.java | 119 HandlerThread thread = new HandlerThread("WifiRttService"); local
120 thread.start();
122 mClientHandler = new ClientHandler(thread.getLooper());
123 mStateMachine = new RttStateMachine(thread.getLooper());
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/ |
| BufferedInputStreamTest.java | 222 Thread thread = new Thread(new Runnable() { local
225 Thread.sleep(1000);
232 thread.start();
|
| /packages/apps/Bluetooth/src/com/android/bluetooth/gatt/ |
| AdvertiseManager.java | 82 HandlerThread thread = new HandlerThread("BluetoothAdvertiseManager"); local
83 thread.start();
84 mHandler = new ClientHandler(thread.getLooper());
131 // the mClientHandler thread will be blocked till timeout.
|
| /packages/apps/Bluetooth/src/com/android/bluetooth/map/ |
| BluetoothMnsObexClient.java | 37 * The Message Notification Service class runs its own message handler thread,
38 * to avoid executing long operations on the MAP service Thread.
41 * from this thread.
75 HandlerThread thread = new HandlerThread("BluetoothMnsObexClient"); local
76 thread.start();
79 Looper looper = thread.getLooper();
152 /* should shutdown handler thread first to make sure
156 // Shut down the thread
183 * this thread as Handler.
|
| /packages/apps/Calendar/tests/src/com/android/calendar/ |
| AsyncQueryServiceTest.java | 481 // run in a separate thread but call the same code
482 HandlerThread thread = new HandlerThread("TestAsyncQueryService"); local
483 thread.start();
484 super.setTestHandler(new Handler(thread.getLooper()) {
496 Log.d(TAG, "onQueryComplete tid=" + Thread.currentThread().getId());
515 Log.d(TAG, "onInsertComplete tid=" + Thread.currentThread().getId());
528 Log.d(TAG, "onUpdateComplete tid=" + Thread.currentThread().getId());
541 Log.d(TAG, "onDeleteComplete tid=" + Thread.currentThread().getId());
554 Log.d(TAG, "onBatchComplete tid=" + Thread.currentThread().getId());
572 Log.d(TAG, "waitForCompletion tid=" + Thread.currentThread().getId())
[all...] |
| /frameworks/base/services/core/java/com/android/server/am/ |
| ActivityStack.java | [all...] |
| /art/runtime/ |
| debugger.h | 48 class Thread;
57 receiver(NULL), thread(NULL), klass(NULL), method(NULL),
67 /* boolean; set if the JDWP thread wants this thread to do work */
72 mirror::Object* thread; member in struct:art::DebugInvokeReq
98 // Thread local data-structure that holds fields for controlling single-stepping.
113 // A single-step is initiated in a suspended thread. We save here the current method and the
216 // Return the DebugInvokeReq for the current thread.
219 static Thread* GetDebugThread();
304 static bool MatchThread(JDWP::ObjectId expected_thread_id, Thread* event_thread
[all...] |
| fault_handler.cc | 25 #include "thread-inl.h"
45 // thread running the signal handler.
47 // 4. save the thread's state to the TLS of the current thread using 'setjmp'
57 // thread. This results in a return with a non-zero value from 'setjmp'. We detect this
204 // We can only be running Java code in the current thread if it
207 Thread* thread = Thread::Current(); local
208 if (thread == nullptr)
[all...] |
| /development/ndk/sources/android/native_app_glue/ |
| android_native_app_glue.h | 36 * by the Activity's main thread when certain events occur.
44 * loop in a different thread instead. Here's how it works:
47 * will be called when the activity is created, in a new thread that is
48 * distinct from the activity's main thread.
106 * in its own thread separate from the main thread of the process.
107 * It is not required that this thread be associated with the Java
142 // The ALooper associated with the app's thread.
161 // destroyed and waiting for the app thread to complete.
173 pthread_t thread; member in struct:android_app
[all...] |
| /external/chromium_org/chrome/renderer/ |
| chrome_render_process_observer.cc | 195 // No worker threads so just send out the main thread data right away.
268 RenderThread* thread = RenderThread::Get(); local
270 thread->SetResourceDispatcherDelegate(resource_delegate_.get());
|
| /external/chromium_org/content/browser/ |
| histogram_synchronizer.cc | 13 #include "base/threading/thread.h"
38 // the UI. All methods are accessible on UI thread.
305 base::MessageLoop* thread = NULL; local
311 thread = callback_thread_;
315 InternalPostTask(thread, callback);
318 void HistogramSynchronizer::InternalPostTask(base::MessageLoop* thread,
320 if (callback.is_null() || !thread)
322 thread->PostTask(FROM_HERE, callback);
|
| /external/chromium_org/media/audio/win/ |
| audio_output_win_unittest.cc | 275 // Test another potential deadlock situation if the thread that calls Start()
559 // from a potentially remote thread.
607 // This thread provides the data that the SyncSocketSource above needs
679 HANDLE thread = ::CreateThread(NULL, 0, SyncSocketThread, local
684 ::WaitForSingleObject(thread, INFINITE);
685 ::CloseHandle(thread);
|
| /external/chromium_org/mojo/examples/html_viewer/ |
| blink_platform_impl.cc | 175 WebThreadImplForMessageLoop* thread = local
177 if (thread)
178 return (thread);
185 thread = new WebThreadImplForMessageLoop(message_loop.get());
186 current_thread_slot_.Set(thread);
187 return thread;
206 void BlinkPlatformImpl::DestroyCurrentThread(void* thread) {
208 static_cast<WebThreadImplForMessageLoop*>(thread);
|
| /external/chromium_org/net/disk_cache/blockfile/ |
| stress_cache.cc | 35 #include "base/threading/thread.h"
100 // This thread will loop forever, adding and removing entries from the cache.
111 base::Thread cache_thread("CacheThread");
113 base::Thread::Options(base::MessageLoop::TYPE_IO, 0)))
190 // We want to prevent the timer thread from killing the process while we are
225 base::Thread* thread = new base::Thread("party_crasher"); local
226 if (!thread->Start())
229 RunSoon(thread->message_loop())
[all...] |
