Home
last modified time | relevance | path

Searched refs:thread (Results 1 – 25 of 47) sorted by relevance

12

/libcore/dalvik/src/main/java/dalvik/system/profiler/
DSamplingProfiler.java374 for (Thread thread : currentThreads) { in run()
375 if (thread == null) { in run()
378 if (thread == timerThread) { in run()
382 StackTraceElement[] stackFrames = threadSampler.getStackTrace(thread); in run()
386 recordStackTrace(thread, stackFrames); in run()
394 private void recordStackTrace(Thread thread, StackTraceElement[] stackFrames) { in recordStackTrace() argument
395 Integer threadId = threadIds.get(thread); in recordStackTrace()
397 throw new IllegalArgumentException("Unknown thread " + thread); in recordStackTrace()
429 for (Thread thread : added) { in updateThreadHistory()
430 if (thread == null) { in updateThreadHistory()
[all …]
DPortableThreadSampler.java33 @Override public StackTraceElement[] getStackTrace(Thread thread) { in getStackTrace() argument
34 StackTraceElement[] stackFrames = thread.getStackTrace(); in getStackTrace()
DDalvikThreadSampler.java39 @Override public StackTraceElement[] getStackTrace(Thread thread) { in getStackTrace() argument
40 int count = VMStack.fillStackTraceElements(thread, mutableStackTraceElements[depth]); in getStackTrace()
/libcore/luni/src/test/java/libcore/java/io/
DInterruptedStreamTest.java121 Thread thread = interruptMeLater(); in testInterruptInputStream() local
127 confirmInterrupted(thread); in testInterruptInputStream()
132 Thread thread = interruptMeLater(); in testInterruptReader() local
138 confirmInterrupted(thread); in testInterruptReader()
143 Thread thread = interruptMeLater(); in testInterruptReadableChannel() local
149 confirmInterrupted(thread); in testInterruptReadableChannel()
154 Thread thread = interruptMeLater(); in testInterruptOutputStream() local
162 confirmInterrupted(thread); in testInterruptOutputStream()
167 Thread thread = interruptMeLater(); in testInterruptWriter() local
175 confirmInterrupted(thread); in testInterruptWriter()
[all …]
/libcore/libart/src/main/java/java/lang/
DThreadGroup.java125 for (Thread thread : threads) { in activeCount()
126 if (thread.isAlive()) { in activeCount()
342 Thread thread = threadRefs.get(i).get(); in enumerateGeneric() local
343 if (thread != null && thread.isAlive()) { in enumerateGeneric()
347 enumeration[enumerationIndex++] = thread; in enumerateGeneric()
414 for (Thread thread : threads) { in interrupt()
415 thread.interrupt(); in interrupt()
473 for (Thread thread : threads) { in list()
475 System.out.println(thread); in list()
542 for (Thread thread : threads) { in resume()
[all …]
DDaemons.java61 private Thread thread; field in Daemons.Daemon
64 if (thread != null) { in start()
67 thread = new Thread(ThreadGroup.systemThreadGroup, this, getClass().getSimpleName()); in start()
68 thread.setDaemon(true); in start()
69 thread.start(); in start()
79 return thread != null; in isRunning()
83 if (thread == null) { in interrupt()
86 thread.interrupt(); in interrupt()
96 threadToStop = thread; in stop()
97 thread = null; in stop()
[all …]
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/text/
DLoadLocaleProviderTestHelper.java29 Thread thread = new Thread(this); in LoadLocaleProviderTestHelper() local
30 thread.setContextClassLoader(loader); in LoadLocaleProviderTestHelper()
31 thread.start(); in LoadLocaleProviderTestHelper()
32 thread.join(); in LoadLocaleProviderTestHelper()
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/lang/
DThreadGroupTest.java511 Thread thread = new Thread(testRoot, null, "suicidal thread") { in test_uncaughtException_threadDeath() local
517 thread.start(); in test_uncaughtException_threadDeath()
518 waitForThreadToDieUninterrupted(thread); in test_uncaughtException_threadDeath()
519 testThreadDefaultUncaughtExceptionHandler.assertWasCalled(thread, threadDeath); in test_uncaughtException_threadDeath()
545 Thread thread = new Thread(testRoot, null, "no-op thread"); in test_uncaughtException_naturalDeath() local
546 thread.start(); in test_uncaughtException_naturalDeath()
547 waitForThreadToDieUninterrupted(thread); in test_uncaughtException_naturalDeath()
579 Thread thread = new Thread(testRoot, null, "RuntimeException thread") { in test_uncaughtException_runtimeException() local
585 thread.start(); in test_uncaughtException_runtimeException()
586 waitForThreadToDieUninterrupted(thread); in test_uncaughtException_runtimeException()
[all …]
DProcessManagerTest.java31 Thread thread = null; field in ProcessManagerTest
60 thread = new Thread() { in testSleep()
85 thread.interrupt(); in testSleep()
88 thread.start(); in testSleep()
101 thread.interrupt(); in testSleep()
138 Thread thread = new Thread() { in logErrors() local
153 thread.setDaemon(true); in logErrors()
154 thread.start(); in logErrors()
/libcore/luni/src/test/java/libcore/java/util/logging/
DOldLogRecordTest.java53 MockThread thread = new MockThread(); in testGetSetThreadID_DifferentThread() local
54 thread.start(); in testGetSetThreadID_DifferentThread()
56 thread.join(); in testGetSetThreadID_DifferentThread()
70 assertTrue(lr.getThreadID() != thread.lr.getThreadID()); in testGetSetThreadID_DifferentThread()
72 assertTrue(thread.lr.getThreadID() != thread2.lr.getThreadID()); in testGetSetThreadID_DifferentThread()
/libcore/luni/src/test/java/libcore/java/nio/channels/
DOldServerSocketChannelTest.java97 MyThread thread = new MyThread(); in test_accept_Block_NoConnect_interrupt() local
98 thread.start(); in test_accept_Block_NoConnect_interrupt()
101 thread.interrupt(); in test_accept_Block_NoConnect_interrupt()
105 if (thread.errMsg != null) { in test_accept_Block_NoConnect_interrupt()
106 fail(thread.errMsg); in test_accept_Block_NoConnect_interrupt()
/libcore/luni/src/test/java/org/apache/harmony/crypto/tests/javax/crypto/func/
DTestThread.java34 Thread thread = null; in launcher() local
38 thread = new Thread(this); in launcher()
39 thread.start(); in launcher()
41 thread.join(); in launcher()
DCipherThread.java75 Thread thread = null; in launcher() local
83 thread = new Thread(this); in launcher()
84 thread.start(); in launcher()
86 thread.join(); in launcher()
/libcore/luni/src/test/java/libcore/java/lang/
DOldInheritableThreadLocalTest.java38 Thread thread = new Thread() { in test_Ljava_lang_InheritableThreadLocal() local
43 thread.start(); in test_Ljava_lang_InheritableThreadLocal()
44 thread.join(); in test_Ljava_lang_InheritableThreadLocal()
DOldThreadTest.java157 Thread thread = new Thread() { in launchFiveSecondDummyThread() local
167 thread.start(); in launchFiveSecondDummyThread()
169 return thread; in launchFiveSecondDummyThread()
391 Thread thread = launchFiveSecondDummyThread(); in test_stop() local
400 thread.stop(); in test_stop()
418 Thread thread = new Thread() { in test_stopLjava_lang_Throwable_subtest0() local
428 thread.start(); in test_stopLjava_lang_Throwable_subtest0()
436 thread.stop(new Exception("Oops!")); in test_stopLjava_lang_Throwable_subtest0()
444 Thread thread = launchFiveSecondDummyThread(); in test_suspend() local
453 thread.suspend(); in test_suspend()
DOldThreadGroupTest.java139 for(MyThread thread : newThreads) { in test_enumerateLThreadArrayLZtest_enumerateLThreadArrayLZ()
140 thread.start(); in test_enumerateLThreadArrayLZtest_enumerateLThreadArrayLZ()
153 for(MyThread thread : newThreads) { in test_enumerateLThreadArrayLZtest_enumerateLThreadArrayLZ()
154 thread.interrupt(); in test_enumerateLThreadArrayLZtest_enumerateLThreadArrayLZ()
286 Thread thread = launchFiveSecondDummyThread(group); in test_resume() local
302 Thread thread = new Thread(group, "Bar") { in launchFiveSecondDummyThread() local
312 thread.start(); in launchFiveSecondDummyThread()
314 return thread; in launchFiveSecondDummyThread()
/libcore/luni/src/main/java/java/util/concurrent/locks/
DAbstractQueuedSynchronizer.java445 volatile Thread thread; field in AbstractQueuedSynchronizer.Node
484 Node(Thread thread, Node mode) { // Used by addWaiter in Node() argument
486 this.thread = thread; in Node()
489 Node(Thread thread, int waitStatus) { // Used by Condition in Node() argument
491 this.thread = thread; in Node()
608 node.thread = null; in setHead()
641 LockSupport.unpark(s.thread); in unparkSuccessor()
724 node.thread = null; in cancelAcquire()
751 pred.thread != null) { in cancelAcquire()
1386 s.prev == head && (st = s.thread) != null) || in fullGetFirstQueuedThread()
[all …]
DAbstractQueuedLongSynchronizer.java215 volatile Thread thread; field in AbstractQueuedLongSynchronizer.Node
254 Node(Thread thread, Node mode) { // Used by addWaiter in Node() argument
256 this.thread = thread; in Node()
259 Node(Thread thread, int waitStatus) { // Used by Condition in Node() argument
261 this.thread = thread; in Node()
378 node.thread = null; in setHead()
411 LockSupport.unpark(s.thread); in unparkSuccessor()
494 node.thread = null; in cancelAcquire()
521 pred.thread != null) { in cancelAcquire()
1156 s.prev == head && (st = s.thread) != null) || in fullGetFirstQueuedThread()
[all …]
DLockSupport.java121 public static void unpark(Thread thread) { in unpark() argument
122 if (thread != null) in unpark()
123 unsafe.unpark(thread); in unpark()
/libcore/luni/src/main/java/java/util/concurrent/
DFutureTask.java326 volatile Thread thread; field in FutureTask.WaitNode
328 WaitNode() { thread = Thread.currentThread(); } in WaitNode()
340 Thread t = q.thread; in finishCompletion()
342 q.thread = null; in finishCompletion()
381 q.thread = null; in awaitDone()
416 node.thread = null; in removeWaiter()
421 if (q.thread != null) in removeWaiter()
425 if (pred.thread == null) // check for race in removeWaiter()
DPhaser.java951 (t = q.thread) != null) { in releaseWaiters()
952 q.thread = null; in releaseWaiters()
973 if (q == null || ((t = q.thread) != null && q.phase == p)) in abortWait()
976 q.thread = null; in abortWait()
1046 if (node.thread != null) in internalAwaitAdvance()
1047 node.thread = null; // avoid need for unpark() in internalAwaitAdvance()
1068 volatile Thread thread; // nulled to cancel wait field in Phaser.QNode
1079 thread = Thread.currentThread(); in QNode()
1083 if (thread == null) in isReleasable()
1086 thread = null; in isReleasable()
[all …]
/libcore/jsr166-tests/src/test/java/jsr166/
DJSR166TestCase.java213 Thread thread = survivors[i]; in checkForkJoinPoolThreadLeaks() local
214 String name = thread.getName(); in checkForkJoinPoolThreadLeaks()
217 thread.join(LONG_DELAY_MS); in checkForkJoinPoolThreadLeaks()
218 if (!thread.isAlive()) continue; in checkForkJoinPoolThreadLeaks()
219 thread.stop(); in checkForkJoinPoolThreadLeaks()
401 void assertThreadStaysAlive(Thread thread) { in assertThreadStaysAlive() argument
402 assertThreadStaysAlive(thread, timeoutMillis()); in assertThreadStaysAlive()
408 void assertThreadStaysAlive(Thread thread, long millis) { in assertThreadStaysAlive() argument
412 assertTrue(thread.isAlive()); in assertThreadStaysAlive()
433 for (Thread thread : threads) in assertThreadsStayAlive()
[all …]
DPhaserTest.java307 for (Thread thread : threads) in testArrive2()
308 awaitTermination(thread); in testArrive2()
628 for (Thread thread : threads)
629 awaitTermination(thread);
659 for (Thread thread : threads)
660 awaitTermination(thread);
734 for (Thread thread : threads)
735 awaitTermination(thread);
775 for (Thread thread : threads)
776 waitForThreadToEnterWaitState(thread, SHORT_DELAY_MS);
[all …]
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/org/apache/harmony/kernel/dalvik/
DThreadsTest.java262 private final Thread thread; field in ThreadsTest.WaitAndUnpark
264 public WaitAndUnpark(CyclicBarrier barrier, long waitMillis, Thread thread) { in WaitAndUnpark() argument
267 this.thread = thread; in WaitAndUnpark()
282 UNSAFE.unpark(thread); in run()
/libcore/luni/src/test/java/libcore/java/net/
DOldDatagramPacketTest.java32 Thread thread = new Thread(new Runnable() { in test_getPort() local
44 thread.start(); in test_getPort()

12