Home
last modified time | relevance | path

Searched refs:currentThread (Results 1 – 25 of 168) sorted by relevance

1234567

/libcore/ojluni/src/main/java/java/io/
DSerialCallbackContext.java51 this.thread = Thread.currentThread(); in SerialCallbackContext()
64 if (thread != null && thread != Thread.currentThread()) { in check()
66 "expected thread: " + thread + ", but got: " + Thread.currentThread()); in check()
71 if (thread != Thread.currentThread()) { in checkAndSetUsed()
DPrintStream.java562 Thread.currentThread().interrupt(); in write()
595 Thread.currentThread().interrupt(); in write()
686 Thread.currentThread().interrupt(); in write()
711 Thread.currentThread().interrupt(); in writeln()
732 Thread.currentThread().interrupt(); in write()
758 Thread.currentThread().interrupt(); in writeln()
779 Thread.currentThread().interrupt(); in newLine()
1244 Thread.currentThread().interrupt(); in format()
1301 Thread.currentThread().interrupt(); in format()
DPrintWriter.java485 Thread.currentThread().interrupt(); in write()
511 Thread.currentThread().interrupt(); in write()
546 Thread.currentThread().interrupt(); in write()
572 Thread.currentThread().interrupt(); in newLine()
997 Thread.currentThread().interrupt(); in format()
1056 Thread.currentThread().interrupt(); in format()
DPipedInputStream.java205 writeSide = Thread.currentThread(); in receive()
230 writeSide = Thread.currentThread(); in receive()
318 readSide = Thread.currentThread(); in read()
/libcore/ojluni/src/main/java/java/util/concurrent/locks/
DReentrantLock.java126 Thread current = Thread.currentThread(); in tryLock()
174 if (getExclusiveOwnerThread() != Thread.currentThread()) in tryRelease()
186 return getExclusiveOwnerThread() == Thread.currentThread(); in isHeldExclusively()
224 Thread current = Thread.currentThread(); in initialTryLock()
243 setExclusiveOwnerThread(Thread.currentThread()); in tryAcquire()
260 Thread current = Thread.currentThread(); in initialTryLock()
282 setExclusiveOwnerThread(Thread.currentThread()); in tryAcquire()
DLockSupport.java161 U.putReferenceOpaque(Thread.currentThread(), PARKBLOCKER, blocker); in setCurrentBlocker()
209 Thread t = Thread.currentThread(); in park()
250 Thread t = Thread.currentThread(); in parkNanos()
291 Thread t = Thread.currentThread(); in parkUntil()
DReentrantReadWriteLock.java280 final long tid = LockSupport.getThreadId(Thread.currentThread());
394 Thread current = Thread.currentThread(); in tryAcquire()
416 Thread current = Thread.currentThread(); in tryReleaseShared()
469 Thread current = Thread.currentThread(); in tryAcquireShared()
565 Thread current = Thread.currentThread(); in tryWriteLock()
587 Thread current = Thread.currentThread(); in tryReadLock()
619 return getExclusiveOwnerThread() == Thread.currentThread(); in isHeldExclusively()
651 Thread current = Thread.currentThread(); in getReadHoldCount()
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/lang/
DThreadTest.java86 while (!Thread.currentThread().isInterrupted()) { in run()
268 Thread.currentThread().countStackFrames(); in test_countStackFrames()
275 assertNotNull(Thread.currentThread()); in test_currentThread()
380 t.getContextClassLoader() == Thread.currentThread() in test_getContextClassLoader()
483 ct = new ChildThread1(Thread.currentThread(), "Interrupt Test1", in test_interrupt()
496 ct = new ChildThread1(Thread.currentThread(), "Interrupt Test2", in test_interrupt()
517 Thread.currentThread().interrupt(); in test_interrupted()
552 assertEquals(Thread.currentThread().isDaemon(), st.isDaemon()); in test_isDaemon()
572 while (!Thread.currentThread().isInterrupted()) in test_isInterrupted()
663 final Thread main = Thread.currentThread(); in test_joinJ()
[all …]
/libcore/ojluni/src/main/java/java/nio/channels/spi/
DAbstractInterruptibleChannel.java169 Thread me = Thread.currentThread(); in begin()
198 if (interrupted != null && interrupted == Thread.currentThread()) { in end()
211 Thread.currentThread().blockedOn(intr); in blockedOn()
/libcore/luni/src/test/java/libcore/java/nio/file/
DFileSystemsTest.java105 Thread.currentThread().getContextClassLoader()); in test_newFileSystem$URI$Map$ClassLoader()
111 Thread.currentThread().getContextClassLoader()); in test_newFileSystem$URI$Map$ClassLoader()
126 Thread.currentThread().getContextClassLoader().loadClass("mypackage.MockFileSystem"); in test_newFileSystem$URI$Map$ClassLoader_customClassLoader()
144 FileSystems.newFileSystem(testPath, Thread.currentThread().getContextClassLoader()); in test_newFileSystem$Path$ClassLoader()
149 FileSystems.newFileSystem(null, Thread.currentThread().getContextClassLoader()); in test_newFileSystem$Path$ClassLoader()
163 Thread.currentThread().getContextClassLoader().loadClass( in test_newFileSystem$Path$ClassLoader_customClassLoader()
/libcore/dalvik/test-rules/src/main/java/libcore/dalvik/system/
DCloseGuardSupport.java159 private final Thread testThread = Thread.currentThread();
163 if (Thread.currentThread() == testThread) {
261 private final Thread callingThread = Thread.currentThread();
269 if (callingThread == Thread.currentThread()) {
277 if (callingThread == Thread.currentThread()) {
/libcore/ojluni/src/main/java/java/util/concurrent/
DForkJoinTask.java294 if ((t = a.thread) != Thread.currentThread() && t != null) in signalWaiters()
333 Aux h = new Aux(Thread.currentThread(), ex), p = null; in trySetThrown()
404 if ((t = Thread.currentThread()) instanceof ForkJoinWorkerThread) { in awaitDone()
483 node = new Aux(Thread.currentThread(), null); in awaitDone()
515 Thread.currentThread().interrupt(); in awaitDone()
553 else if ((ex = a.ex) != null && a.thread != Thread.currentThread()) { in getThrowableException()
653 if ((t = Thread.currentThread()) instanceof ForkJoinWorkerThread) in fork()
1073 if ((t = Thread.currentThread()) instanceof ForkJoinWorkerThread && in helpQuiesce()
1112 return (((t = Thread.currentThread()) instanceof ForkJoinWorkerThread) ? in getPool()
1125 return Thread.currentThread() instanceof ForkJoinWorkerThread; in inForkJoinPool()
[all …]
DThreadLocalRandom.java173 Thread t = Thread.currentThread(); in localInit()
186 if (U.getInt(Thread.currentThread(), PROBE) == 0) in current()
220 U.putLong(t = Thread.currentThread(), SEED, in nextSeed()
263 return U.getInt(Thread.currentThread(), PROBE); in getProbe()
274 U.putInt(Thread.currentThread(), PROBE, probe); in advanceProbe()
283 Thread t = Thread.currentThread(); in nextSecondarySeed()
334 fields.put("rnd", U.getLong(Thread.currentThread(), SEED)); in writeObject()
/libcore/ojluni/src/test/java/nio/channels/Selector/
DSelectWithConsumer.java63 Thread callerThread = Thread.currentThread(); in testActionInvoked()
83 assertTrue(Thread.currentThread() == callerThread); in testActionInvoked()
96 assertTrue(Thread.currentThread() == callerThread); in testActionInvoked()
109 assertTrue(Thread.currentThread() == callerThread); in testActionInvoked()
372 Thread.currentThread().interrupt(); in testInterruptBeforeSelect()
375 assertTrue(Thread.currentThread().isInterrupted()); in testInterruptBeforeSelect()
378 Thread.currentThread().interrupted(); // clear interrupt status in testInterruptBeforeSelect()
383 Thread.currentThread().interrupt(); in testInterruptBeforeSelect()
389 assertTrue(Thread.currentThread().isInterrupted()); in testInterruptBeforeSelect()
392 Thread.currentThread().interrupted(); // clear interrupt status in testInterruptBeforeSelect()
[all …]
/libcore/luni/src/test/java/libcore/java/util/concurrent/
DLockSupportTest.java34 assertSame(val, LockSupport.getBlocker(Thread.currentThread())); in testSetCurrentBlocker()
36 assertNull(LockSupport.getBlocker(Thread.currentThread())); in testSetCurrentBlocker()
/libcore/ojluni/src/test/java/util/concurrent/tck/
DRecursiveActionTest.java95 Thread.currentThread().interrupt(); in checkNotDone()
102 Thread.currentThread().interrupt(); in checkNotDone()
289 final Thread currentThread = Thread.currentThread(); in testJoinIgnoresInterrupts()
293 currentThread.interrupt(); in testJoinIgnoresInterrupts()
302 currentThread.interrupt(); in testJoinIgnoresInterrupts()
314 currentThread.interrupt(); in testJoinIgnoresInterrupts()
326 currentThread.interrupt(); in testJoinIgnoresInterrupts()
335 currentThread.interrupt(); in testJoinIgnoresInterrupts()
343 currentThread.interrupt(); in testJoinIgnoresInterrupts()
383 final Thread currentThread = Thread.currentThread(); in testJoinIgnoresInterruptsOutsideForkJoinPool()
[all …]
DPhaserTest.java490 Thread.currentThread().interrupt();
507 Thread.currentThread().interrupt();
544 Thread.currentThread().interrupt();
548 assertTrue(Thread.currentThread().isInterrupted());
558 Thread.currentThread().interrupt();
575 assertFalse(Thread.currentThread().isInterrupted());
587 Thread.currentThread().interrupt();
602 Thread.currentThread().interrupt();
605 assertTrue(Thread.currentThread().isInterrupted());
612 Thread.currentThread().interrupt();
[all …]
DLockSupportTest.java220 } while (! Thread.currentThread().isInterrupted()); in testParkBeforeInterrupt()
258 assertTrue(Thread.currentThread().isInterrupted()); in testParkAfterInterrupt()
260 assertTrue(Thread.currentThread().isInterrupted()); in testParkAfterInterrupt()
325 Thread t = Thread.currentThread(); in testGetBlocker()
332 } while (! Thread.currentThread().isInterrupted()); in testGetBlocker()
/libcore/ojluni/src/test/java/lang/StackWalker/
DDumpStackTest.java97 assertStackTrace(Thread.currentThread().getStackTrace(), callStack); in test()
129 assertStackTrace(Thread.currentThread().getStackTrace(), callStack); in testThread()
162 assertStackTrace(Thread.currentThread().getStackTrace(), callStack); in consumeLambda()
194 assertStackTrace(Thread.currentThread().getStackTrace(), callStack); in methodInvoke()
223 assertStackTrace(Thread.currentThread().getStackTrace(), callStack); in methodHandle()
DMultiThreadStackWalk.java225 System.out.println("Thread "+ Thread.currentThread().getName() in walk()
296 String threadName = Thread.currentThread().getName(); in checkTest()
301 … throw new RuntimeException(Thread.currentThread().getName() + ": Marker was not called."); in checkTest()
304 throw new RuntimeException(Thread.currentThread().getName() in checkTest()
313 throw new RuntimeException(Thread.currentThread().getName() in checkTest()
317 throw new RuntimeException(Thread.currentThread().getName() in checkTest()
/libcore/jsr166-tests/src/test/java/jsr166/
DPhaserTest.java466 Thread.currentThread().interrupt();
483 Thread.currentThread().interrupt();
520 Thread.currentThread().interrupt();
524 assertTrue(Thread.currentThread().isInterrupted());
534 Thread.currentThread().interrupt();
551 assertFalse(Thread.currentThread().isInterrupted());
563 Thread.currentThread().interrupt();
578 Thread.currentThread().interrupt();
581 assertTrue(Thread.currentThread().isInterrupted());
588 Thread.currentThread().interrupt();
[all …]
DLockSupportTest.java196 } while (! Thread.currentThread().isInterrupted()); in testParkBeforeInterrupt()
234 assertTrue(Thread.currentThread().isInterrupted()); in testParkAfterInterrupt()
236 assertTrue(Thread.currentThread().isInterrupted()); in testParkAfterInterrupt()
301 Thread t = Thread.currentThread(); in testGetBlocker()
308 } while (! Thread.currentThread().isInterrupted()); in testGetBlocker()
/libcore/luni/src/main/java/javax/xml/xpath/
DXPathFactory.java143 ClassLoader classLoader = Thread.currentThread().getContextClassLoader(); in newInstance()
179 classLoader = Thread.currentThread().getContextClassLoader(); in newInstance()
/libcore/ojluni/src/test/java/lang/Thread/
DITLConstructor.java60 Thread child = new Thread(Thread.currentThread().getThreadGroup(), in test()
96 Thread child = new Thread(Thread.currentThread().getThreadGroup(), in run()
/libcore/ojluni/src/main/java/java/lang/
DThread.java316 public static native Thread currentThread(); in currentThread() method in Thread
439 Object lock = currentThread().lock; in sleep()
517 Thread parent = currentThread(); in Thread()
715 init2(currentThread(), true); in Thread()
1141 if (this != Thread.currentThread()) { in interrupt()
1434 return currentThread().getThreadGroup().activeCount(); in activeCount()
1464 return currentThread().getThreadGroup().enumerate(tarray); in enumerate()

1234567