| /external/chromium_org/third_party/libjingle/source/talk/base/ |
| thread_unittest.cc | 33 #include "talk/base/thread.h"
70 Thread* post_thread, MessageHandler* phandler)
96 Thread* post_thread_;
103 MessageClient(Thread* pth, Socket* socket)
119 Thread* thread_;
123 class CustomThread : public talk_base::Thread {
131 // A thread that does nothing when it runs and signals an event
133 class SignalWhenDestroyedThread : public Thread {
152 // Function objects to test Thread::Invoke.
168 // Create the messaging client on its own thread
210 Thread *thread; local
232 Thread *thread; local
276 Thread* thread = new SignalWhenDestroyedThread(event.get()); local
289 Thread thread; local
324 Thread* thread = new ComThread(); local
[all...] |
| thread.cc | 28 #include "talk/base/thread.h"
58 Thread* Thread::Current() {
71 // maintaining thread safety using immutability within context of GCD dispatch
92 Thread *ThreadManager::CurrentThread() {
93 return static_cast<Thread *>(pthread_getspecific(key_));
96 void ThreadManager::SetCurrentThread(Thread *thread) {
97 pthread_setspecific(key_, thread);
114 Thread *ThreadManager::CurrentThread()
141 Thread* thread; member in struct:talk_base::ThreadInit
394 AutoThread thread; local
[all...] |
| /libcore/luni/src/test/java/tests/api/org/apache/harmony/kernel/dalvik/ |
| ThreadsTest.java | 54 Thread parkerThread = new Thread(parker);
55 Thread waiterThread =
56 new Thread(new WaitAndUnpark(barrier, 1000, parkerThread));
69 Thread parkerThread = new Thread(parker);
70 Thread waiterThread =
71 new Thread(new WaitAndUnpark(barrier, 300, parkerThread));
80 /** Test the case where the thread is preemptively unparked. */
84 Thread parkerThread = new Thread(parker)
262 private final Thread thread; field in class:ThreadsTest.WaitAndUnpark
[all...] |
| /libcore/libart/src/main/java/java/lang/ |
| ThreadGroup.java | 28 * This class is obsolete. See <i>Effective Java</i> Item 73, "Avoid thread groups" for details.
29 * @see Thread
31 public class ThreadGroup implements Thread.UncaughtExceptionHandler {
38 private int maxPriority = Thread.MAX_PRIORITY;
48 private final List<WeakReference<Thread>> threadRefs = new ArrayList<WeakReference<Thread>>(5);
54 private final Iterable<Thread> threads = CollectionUtils.dereferenceIterable(threadRefs, true);
57 * Thread groups. Access is guarded by synchronizing on this field.
73 * will be child of the {@code ThreadGroup} to which the calling thread belongs.
76 * @see Thread#currentThrea
342 Thread thread = threadRefs.get(i).get(); local
[all...] |
| /libcore/libdvm/src/main/java/java/lang/ |
| ThreadGroup.java | 28 * This class is obsolete. See <i>Effective Java</i> Item 73, "Avoid thread groups" for details.
29 * @see Thread
31 public class ThreadGroup implements Thread.UncaughtExceptionHandler {
38 private int maxPriority = Thread.MAX_PRIORITY;
48 private final List<WeakReference<Thread>> threadRefs = new ArrayList<WeakReference<Thread>>(5);
54 private final Iterable<Thread> threads = CollectionUtils.dereferenceIterable(threadRefs, true);
57 * Thread groups. Access is guarded by synchronizing on this field.
73 * will be child of the {@code ThreadGroup} to which the calling thread belongs.
76 * @see Thread#currentThrea
342 Thread thread = threadRefs.get(i).get(); local
[all...] |
| /art/runtime/ |
| thread_pool.h | 65 // Returns the number of threads in the thread pool.
71 void StartWorkers(Thread* self);
74 void StopWorkers(Thread* self);
78 void AddTask(Thread* self, Task* task);
84 void Wait(Thread* self, bool do_work, bool may_hold_locks);
86 size_t GetTaskCount(Thread* self);
94 // thread count of the thread pool.
99 virtual Task* GetTask(Thread* self);
102 Task* TryGetTask(Thread* self)
[all...] |
| thread_pool_test.cc | 30 void Run(Thread* self) {
42 LOG(INFO) << "Finalizing: " << *Thread::Current();
59 // Check that the thread pool actually runs tasks that you assign it.
61 Thread* self = Thread::Current();
76 Thread* self = Thread::Current();
110 void Run(Thread* self) {
131 Thread* self = Thread::Current()
[all...] |
| /art/runtime/entrypoints/portable/ |
| portable_jni_entrypoints.cc | 20 #include "thread-inl.h"
25 extern "C" uint32_t art_portable_jni_method_start(Thread* self)
34 extern "C" uint32_t art_portable_jni_method_start_synchronized(jobject to_lock, Thread* self)
40 static void PopLocalReferences(uint32_t saved_local_ref_cookie, Thread* self) {
46 extern "C" void art_portable_jni_method_end(uint32_t saved_local_ref_cookie, Thread* self)
55 Thread* self)
64 Thread* self)
82 Thread* self)
|
| /art/runtime/entrypoints/quick/ |
| quick_jni_entrypoints.cc | 26 #include "thread.h"
31 extern uint32_t JniMethodStart(Thread* self) {
40 extern uint32_t JniMethodStartSynchronized(jobject to_lock, Thread* self) {
45 static void PopLocalReferences(uint32_t saved_local_ref_cookie, Thread* self) {
52 extern void JniMethodEnd(uint32_t saved_local_ref_cookie, Thread* self) {
59 Thread* self) {
66 Thread* self) {
82 jobject locked, Thread* self) {
|
| quick_throw_entrypoints.cc | 21 #include "thread.h"
26 // Deliver an exception that's pending on thread helping set up a callee save frame on the way.
27 extern "C" void artDeliverPendingExceptionFromCode(Thread* thread, mirror::ArtMethod** sp)
29 FinishCalleeSaveFrameSetup(thread, sp, Runtime::kSaveAll);
30 thread->QuickDeliverException();
34 extern "C" void artDeliverExceptionFromCode(mirror::Throwable* exception, Thread* self,
42 * exception_ in thread and delivering the exception.
56 extern "C" void artThrowNullPointerExceptionFromCode(Thread* self,
66 extern "C" void artThrowDivZeroFromCode(Thread* self
[all...] |
| /development/samples/training/threadsample/src/com/example/android/threadsample/ |
| PhotoDecodeRunnable.java | 62 * Sets the Thread that this instance is running on
63 * @param currentThread the current Thread
65 void setImageDecodeThread(Thread currentThread);
109 * Defines this object's task, which is a set of instructions designed to be run on a Thread.
115 * Stores the current Thread in the the PhotoTask instance, so that the instance
116 * can interrupt the Thread.
118 mPhotoTask.setImageDecodeThread(Thread.currentThread());
126 // Defines the Bitmap object that this thread will create
152 // Before continuing, checks to see that the Thread hasn't
154 if (Thread.interrupted())
[all...] |
| PhotoDownloadRunnable.java | 63 * Sets the Thread that this instance is running on
64 * @param currentThread the current Thread
66 void setDownloadThread(Thread currentThread);
104 * Defines this object's task, which is a set of instructions designed to be run on a Thread.
111 * Stores the current Thread in the the PhotoTask instance, so that the instance
112 * can interrupt the Thread.
114 mPhotoTask.setDownloadThread(Thread.currentThread());
116 // Moves the current Thread into the background
131 // Before continuing, checks to see that the Thread hasn't been
133 if (Thread.interrupted())
[all...] |
| /external/chromium/third_party/libjingle/source/talk/session/phone/ |
| audiomonitor.cc | 40 talk_base::Thread *monitor_thread) {
67 assert(talk_base::Thread::Current() == voice_channel_->worker_thread());
75 assert(talk_base::Thread::Current() == voice_channel_->worker_thread());
83 assert(talk_base::Thread::Current() == voice_channel_->worker_thread());
89 assert(talk_base::Thread::Current() == monitoring_thread_);
101 assert(talk_base::Thread::Current() == voice_channel_->worker_thread());
108 // Signal the monitoring thread, start another poll timer
117 talk_base::Thread *AudioMonitor::monitor_thread() {
|
| /external/chromium_org/third_party/libjingle/source/talk/session/media/ |
| audiomonitor.cc | 40 talk_base::Thread *monitor_thread) {
67 assert(talk_base::Thread::Current() == voice_channel_->worker_thread());
75 assert(talk_base::Thread::Current() == voice_channel_->worker_thread());
83 assert(talk_base::Thread::Current() == voice_channel_->worker_thread());
89 assert(talk_base::Thread::Current() == monitoring_thread_);
101 assert(talk_base::Thread::Current() == voice_channel_->worker_thread());
108 // Signal the monitoring thread, start another poll timer
117 talk_base::Thread *AudioMonitor::monitor_thread() {
|
| /art/runtime/jdwp/ |
| object_registry.cc | 50 ScopedObjectAccessUnchecked soa(Thread::Current());
83 Thread* self = Thread::Current();
89 Thread* self = Thread::Current();
110 Thread* self = Thread::Current();
121 Thread* self = Thread::Current();
130 Thread* self = Thread::Current()
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
| transportchannelproxy.cc | 31 #include "talk/base/thread.h"
47 worker_thread_ = talk_base::Thread::Current();
58 ASSERT(talk_base::Thread::Current() == worker_thread_);
107 ASSERT(talk_base::Thread::Current() == worker_thread_);
116 ASSERT(talk_base::Thread::Current() == worker_thread_);
125 ASSERT(talk_base::Thread::Current() == worker_thread_);
133 ASSERT(talk_base::Thread::Current() == worker_thread_);
141 ASSERT(talk_base::Thread::Current() == worker_thread_);
149 ASSERT(talk_base::Thread::Current() == worker_thread_);
157 ASSERT(talk_base::Thread::Current() == worker_thread_)
[all...] |
| /external/guava/guava-tests/test/com/google/common/collect/ |
| SynchronizedMultimapTest.java | 53 assertTrue(Thread.holdsLock(mutex));
58 assertTrue(Thread.holdsLock(mutex));
63 assertTrue(Thread.holdsLock(mutex));
68 assertTrue(Thread.holdsLock(mutex));
73 assertTrue(Thread.holdsLock(mutex));
78 assertTrue(Thread.holdsLock(mutex));
83 assertTrue(Thread.holdsLock(mutex));
89 assertTrue(Thread.holdsLock(mutex));
94 assertTrue(Thread.holdsLock(mutex));
100 assertTrue(Thread.holdsLock(mutex))
[all...] |
| /external/guava/guava-tests/test/com/google/common/testing/ |
| GcFinalizationTest.java | 82 class Interruptenator extends Thread {
84 Interruptenator(final Thread interruptee) {
87 Interruptenator(final Thread interruptee,
93 Thread.yield();
101 Thread.yield();
112 Interruptenator interruptenator = new Interruptenator(Thread.currentThread());
123 Thread.interrupted();
128 Interruptenator interruptenator = new Interruptenator(Thread.currentThread());
139 Thread.interrupted();
144 Interruptenator interruptenator = new Interruptenator(Thread.currentThread())
[all...] |
| /libcore/luni/src/main/java/java/util/concurrent/locks/ |
| ReentrantLock.java | 17 * <p>A {@code ReentrantLock} is <em>owned</em> by the thread last
18 * successfully locking, but not yet unlocking it. A thread invoking
20 * the lock is not owned by another thread. The method will return
21 * immediately if the current thread already owns the lock. This can
28 * thread. Otherwise this lock does not guarantee any particular
34 * fairness of thread scheduling. Thus, one of many threads using a
71 * the same thread. Attempts to exceed this limit result in
101 final Thread current = Thread.currentThread();
121 if (Thread.currentThread() != getExclusiveOwnerThread()
[all...] |
| /art/test/051-thread/src/ |
| Main.java | 20 * Test some basic thread stuff.
31 for (MyThread thread : threads) {
32 thread.start();
34 for (MyThread thread : threads) {
35 thread.join();
38 System.out.println("Thread count: " + MyThread.mCount);
41 System.out.println("thread test done");
45 Thread t = new Thread(null, new ThreadTestSub(), "Thready", 7168);
49 System.out.print("Starting thread '" + t.getName() + "'\n")
[all...] |
| /art/test/109-suspend-check/src/ |
| Main.java | 44 Thread.sleep(ms);
51 class InfiniteWhileLoop extends Thread {
64 class InfiniteDoWhileLoop extends Thread {
77 class InfiniteForLoop extends Thread {
92 class MakeGarbage extends Thread {
|
| /dalvik/tests/051-thread/src/ |
| Main.java | 20 * Test some basic thread stuff.
31 for (MyThread thread : threads) {
32 thread.start();
34 for (MyThread thread : threads) {
35 thread.join();
38 System.out.println("Thread count: " + MyThread.mCount);
41 System.out.println("thread test done");
45 Thread t = new Thread(null, new ThreadTestSub(), "Thready", 7168);
49 System.out.print("Starting thread '" + t.getName() + "'\n")
[all...] |
| /dalvik/tests/097-suspend-check/src/ |
| Main.java | 44 Thread.sleep(ms);
51 class InfiniteWhileLoop extends Thread {
64 class InfiniteDoWhileLoop extends Thread {
77 class InfiniteForLoop extends Thread {
92 class MakeGarbage extends Thread {
|
| /external/chromium/chrome/browser/sync/ |
| profile_sync_test_util.h | 23 class Thread;
48 explicit ThreadNotificationService(base::Thread* notification_thread);
61 base::Thread* notification_thread_;
68 explicit ThreadNotifier(base::Thread* notify_thread);
85 base::Thread* notify_thread_;
|
| /external/chromium/third_party/libjingle/source/talk/p2p/client/ |
| socketmonitor.h | 35 #include "talk/base/thread.h"
62 talk_base::Thread* worker_thread,
63 talk_base::Thread* monitor_thread);
69 talk_base::Thread *monitor_thread() { return monitoring_thread_; }
82 talk_base::Thread* channel_thread_;
83 talk_base::Thread* monitoring_thread_;
|
