| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/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/ojluni/src/main/java/java/util/concurrent/ |
| TimeUnit.java | 358 * Performs a timed {@link Thread#join(long, int) Thread.join}
361 * form required by the {@code Thread.join} method.
363 * @param thread the thread to wait for
368 public void timedJoin(Thread thread, long timeout)
373 thread.join(ms, ns);
378 * Performs a {@link Thread#sleep(long, int) Thread.sleep} usin
[all...] |
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| SinkChannelImpl.java | 49 // ID of native thread doing write, for signalling
50 private volatile long thread = 0; field in class:SinkChannelImpl
52 // Lock held by current reading thread
55 // Lock held by any thread that modifies the state fields declared below
89 long th = thread;
165 thread = NativeThread.current();
171 thread = 0;
188 thread = NativeThread.current();
194 thread = 0;
|
| SourceChannelImpl.java | 50 // ID of native thread doing read, for signalling
51 private volatile long thread = 0; field in class:SourceChannelImpl
53 // Lock held by current reading thread
56 // Lock held by any thread that modifies the state fields declared below
90 long th = thread;
169 thread = NativeThread.current();
175 thread = 0;
200 thread = NativeThread.current();
206 thread = 0;
|
| /packages/apps/Gallery/src/com/android/camera/ |
| BitmapManager.java | 33 * decoding if another thread wants to cancel it, it calls the function
34 * cancelThreadDecoding() specifying the Thread which is in decoding.
55 s = "thread state = " + s + ", options = " + mOptions;
60 private final WeakHashMap<Thread, ThreadStatus> mThreadStatus =
61 new WeakHashMap<Thread, ThreadStatus>();
69 * Get thread status and create one if specified.
71 private synchronized ThreadStatus getOrCreateThreadStatus(Thread t) {
84 private synchronized void setDecodingOptions(Thread t,
89 synchronized void removeDecodingOptions(Thread t) {
95 * The following three methods are used to keep track of which thread
183 Thread thread = Thread.currentThread(); local
[all...] |
| /prebuilts/gdb/darwin-x86/lib/python2.7/logging/ |
| config.py | 31 import thread
34 thread = None variable
812 Returns a Thread object on which you can call start() to start the server,
816 if not thread:
[all...] |
| /prebuilts/gdb/darwin-x86/lib/python2.7/test/ |
| test_threading.py | 10 thread = test.test_support.import_module('thread') variable
31 class TestThread(threading.Thread):
33 threading.Thread.__init__(self, name=name)
89 t = TestThread("<thread %d>"%i, self, sema, mutex, numrunning)
108 # The ident still must work for the main thread and dummy threads.
115 thread.start_new_thread(f, ())
121 # run with a small(ish) thread stack size (256kB)
124 print 'with 256kB thread stack size...'
127 except thread.error
[all...] |
| /prebuilts/gdb/linux-x86/lib/python2.7/logging/ |
| config.py | 31 import thread
34 thread = None variable
812 Returns a Thread object on which you can call start() to start the server,
816 if not thread:
[all...] |
| /prebuilts/gdb/linux-x86/lib/python2.7/test/ |
| test_threading.py | 10 thread = test.test_support.import_module('thread') variable
31 class TestThread(threading.Thread):
33 threading.Thread.__init__(self, name=name)
89 t = TestThread("<thread %d>"%i, self, sema, mutex, numrunning)
108 # The ident still must work for the main thread and dummy threads.
115 thread.start_new_thread(f, ())
121 # run with a small(ish) thread stack size (256kB)
124 print 'with 256kB thread stack size...'
127 except thread.error
[all...] |
| /prebuilts/ndk/r16/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...] |
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/logging/ |
| config.py | 31 import thread
34 thread = None variable
812 Returns a Thread object on which you can call start() to start the server,
816 if not thread:
[all...] |
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| test_threading.py | 10 thread = test.test_support.import_module('thread') variable
31 class TestThread(threading.Thread):
33 threading.Thread.__init__(self, name=name)
89 t = TestThread("<thread %d>"%i, self, sema, mutex, numrunning)
108 # The ident still must work for the main thread and dummy threads.
115 thread.start_new_thread(f, ())
121 # run with a small(ish) thread stack size (256kB)
124 print 'with 256kB thread stack size...'
127 except thread.error
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/logging/ |
| config.py | 31 import thread
34 thread = None variable
812 Returns a Thread object on which you can call start() to start the server,
816 if not thread:
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_threading.py | 10 thread = test.test_support.import_module('thread') variable
31 class TestThread(threading.Thread):
33 threading.Thread.__init__(self, name=name)
89 t = TestThread("<thread %d>"%i, self, sema, mutex, numrunning)
108 # The ident still must work for the main thread and dummy threads.
115 thread.start_new_thread(f, ())
121 # run with a small(ish) thread stack size (256kB)
124 print 'with 256kB thread stack size...'
127 except thread.error
[all...] |
| /system/core/libbacktrace/ |
| backtrace_offline_test.cpp | 113 // Create a thread to generate the needed stack and registers information.
121 pthread_t thread; local
124 ASSERT_EQ(0, pthread_create(&thread, &attr, OfflineThreadFunc, &arg));
125 // Wait for the offline thread to generate the stack and context information.
131 ASSERT_EQ(0, pthread_join(thread, nullptr));
|
| /system/core/libutils/ |
| Threads.cpp | 21 #include <utils/Thread.h>
49 * Thread wrappers
60 * Create and run a new thread.
152 pthread_t thread; local
153 int result = pthread_create(&thread, &attr,
167 *threadId = (android_thread_id_t)thread; // XXX: this is not portable
173 static pthread_t android_thread_id_t_to_pthread(android_thread_id_t thread)
175 return (pthread_t) thread;
206 ALOG(LOG_VERBOSE, "thread", "thread exiting\n")
[all...] |
| /system/core/logd/ |
| main.cpp | 324 // Not multi-thread safe, we use sem_name to protect
453 // Reinit Thread
465 pthread_t thread; local
467 if (pthread_create(&thread, &attr, reinit_thread_start, nullptr)) {
|
| /system/extras/simpleperf/ |
| cmd_debug_unwind.cpp | 240 ThreadEntry* thread = thread_tree_.FindThreadOrNew(r.tid_data.pid, r.tid_data.tid); local
244 if (!offline_unwinder_.UnwindCallChain(*thread, regs, r.stack_user_data.data,
278 const ThreadEntry* thread = thread_tree_.FindThreadOrNew(r.tid_data.pid, r.tid_data.tid); local
280 const MapEntry* map = thread_tree_.FindMap(thread, ip, false);
|
| inplace_sampler_lib.cpp | 58 // Set up timers to send signals for each profiled thread regularly.
59 // Send thread info and map info to simpleperf.
222 // Skip sample thread.
354 pthread_t thread; local
355 if (pthread_create(&thread, &attr, CommunicationThread, nullptr) != 0) {
|
| sample_tree.h | 106 const ThreadEntry* thread = GetThreadOfSample(sample); local
109 if (thread != nullptr && (r.sample_type & PERF_SAMPLE_REGS_USER) &&
116 if (offline_unwinder_->UnwindCallChain(*thread, regs, r.stack_user_data.data,
|
| thread_tree.cpp | 49 ThreadEntry* thread = FindThreadOrNew(pid, tid); local
50 if (comm != thread->comm) {
53 thread->comm = thread_comm_storage_.back()->c_str();
88 // Share maps among threads in the same thread group.
92 ThreadEntry* thread = new ThreadEntry{ local
97 auto pair = thread_tree_.insert(std::make_pair(tid, std::unique_ptr<ThreadEntry>(thread)));
99 return thread;
132 ThreadEntry* thread = FindThreadOrNew(pid, tid); local
136 FixOverlappedMap(thread->maps, map);
137 auto pair = thread->maps->maps.insert(map)
[all...] |
| /system/libhwbinder/vts/performance/ |
| Latency.cpp | 130 // create a fifo thread to transact and wait it to finished
134 pthread_t thread; local
143 REQUIRE(!pthread_create(&thread, &attr, threadStart, &thread_arg));
144 REQUIRE(!pthread_join(thread, &dummy));
207 // 1. transaction by fifo thread
213 // 2. transaction by other thread
|
| /art/tools/ahat/src/test/com/android/ahat/ |
| InstanceTest.java | 455 // java.lang.Thread@12c03470 is marked as a thread root.
456 // Previously we had a bug where thread roots were not properly treated as
458 AhatInstance thread = snapshot.findInstance(0x12c03470); local
459 assertEquals("java.lang.Thread", thread.getClassName());
460 assertTrue(thread.isRoot());
|
| /cts/tests/tests/app.usage/src/android/app/usage/cts/ |
| NetworkUsageStatsTest.java | 769 HandlerThread thread = new HandlerThread("callback-thread"); local
[all...] |
| /external/drrickorang/LoopbackApp/app/src/main/java/org/drrickorang/loopback/ |
| NativeAudioThread.java | 28 * A thread/audio track based audio synth.
31 public class NativeAudioThread extends Thread {
155 setPriority(Thread.MAX_PRIORITY);
338 /** Set up parameters needed for GlitchDetectionThread, then create and run this thread. */
379 //start thread
381 Thread thread = new Thread(new Runnable() { local
392 thread.start();
|
