Home
last modified time | relevance | path

Searched refs:interrupted (Results 1 – 25 of 81) sorted by relevance

1234

/libcore/ojluni/src/main/java/java/nio/channels/spi/
DAbstractInterruptibleChannel.java146 private volatile Thread interrupted; field in AbstractInterruptibleChannel
164 interrupted = target; in begin()
200 Thread interrupted = this.interrupted; in end() local
201 if (interrupted != null && interrupted == Thread.currentThread()) { in end()
202 interrupted = null; in end()
/libcore/ojluni/src/main/java/java/util/concurrent/locks/
DAbstractQueuedLongSynchronizer.java403 return Thread.interrupted(); in parkAndCheckInterrupt()
425 boolean interrupted = false; in acquireQueued()
431 return interrupted; in acquireQueued()
435 interrupted = true; in acquireQueued()
497 if (Thread.interrupted()) in doAcquireNanos()
513 boolean interrupted = false; in doAcquireShared()
521 if (interrupted) in doAcquireShared()
528 interrupted = true; in doAcquireShared()
596 if (Thread.interrupted()) in doAcquireSharedNanos()
777 if (Thread.interrupted()) in acquireInterruptibly()
[all …]
DAbstractQueuedSynchronizer.java869 return Thread.interrupted(); in parkAndCheckInterrupt()
893 boolean interrupted = false; in acquireQueued()
899 return interrupted; in acquireQueued()
903 interrupted = true; in acquireQueued()
965 if (Thread.interrupted()) in doAcquireNanos()
981 boolean interrupted = false; in doAcquireShared()
989 if (interrupted) in doAcquireShared()
996 interrupted = true; in doAcquireShared()
1064 if (Thread.interrupted()) in doAcquireSharedNanos()
1247 if (Thread.interrupted()) in acquireInterruptibly()
[all …]
DStampedLock.java382 if (!Thread.interrupted()) { in tryWriteLock()
408 if (!Thread.interrupted() && in writeLockInterruptibly()
464 if (!Thread.interrupted()) { in tryReadLock()
495 if (!Thread.interrupted() && in readLockInterruptibly()
1122 if (Thread.interrupted()) { in acquireWrite()
1231 if (Thread.interrupted()) { in acquireRead()
1307 if (Thread.interrupted()) { in acquireRead()
1333 private long cancelWaiter(WNode node, WNode group, boolean interrupted) { in cancelWaiter() argument
1397 return (interrupted || Thread.interrupted()) ? INTERRUPTED : 0L; in cancelWaiter()
/libcore/ojluni/src/main/java/sun/nio/ch/
DNativeThreadSet.java86 boolean interrupted = false; in signalAndWait()
103 interrupted = true; in signalAndWait()
108 if (interrupted) in signalAndWait()
/libcore/jsr166-tests/src/test/java/jsr166/
DExchangerTest.java130 final CountDownLatch interrupted = new CountDownLatch(1); in testReplacementAfterExchange() local
141 interrupted.await(); in testReplacementAfterExchange()
146 interrupted.await(); in testReplacementAfterExchange()
153 interrupted.countDown(); in testReplacementAfterExchange()
DCountDownLatchTest.java124 assertFalse(Thread.interrupted()); in testAwait_Interruptible()
131 assertFalse(Thread.interrupted()); in testAwait_Interruptible()
155 assertFalse(Thread.interrupted()); in testTimedAwait_Interruptible()
162 assertFalse(Thread.interrupted()); in testTimedAwait_Interruptible()
DBlockingQueueTest.java234 assertFalse(Thread.interrupted()); in testTimedPollWithOffer()
241 assertFalse(Thread.interrupted()); in testTimedPollWithOffer()
270 assertFalse(Thread.interrupted());
292 assertFalse(Thread.interrupted());
311 assertFalse(Thread.interrupted());
333 assertFalse(Thread.interrupted());
DPhaserTest.java471 assertFalse(Thread.interrupted());
478 assertFalse(Thread.interrupted());
488 assertFalse(Thread.interrupted());
495 assertFalse(Thread.interrupted());
526 assertTrue(Thread.interrupted());
536 assertTrue(Thread.interrupted());
554 assertTrue(Thread.interrupted());
565 assertTrue(Thread.interrupted());
583 assertTrue(Thread.interrupted());
590 assertTrue(Thread.interrupted());
[all …]
DLinkedBlockingDequeTest.java590 assertFalse(Thread.interrupted()); in testBlockingPut()
597 assertFalse(Thread.interrupted()); in testBlockingPut()
628 assertFalse(Thread.interrupted()); in testPutWithTake()
695 assertFalse(Thread.interrupted()); in testBlockingTake()
702 assertFalse(Thread.interrupted()); in testBlockingTake()
820 assertFalse(Thread.interrupted()); in testBlockingPutFirst()
827 assertFalse(Thread.interrupted()); in testBlockingPutFirst()
858 assertFalse(Thread.interrupted()); in testPutFirstWithTake()
921 assertFalse(Thread.interrupted()); in testTakeFirstFromEmptyBlocksInterruptibly()
943 assertFalse(Thread.interrupted()); in testTakeFirstFromEmptyAfterInterrupt()
[all …]
DTimeUnitTest.java350 assertFalse(Thread.interrupted()); in testTimedWait_Interruptible()
359 assertFalse(Thread.interrupted()); in testTimedWait_Interruptible()
385 assertFalse(Thread.interrupted()); in testTimedJoin_Interruptible()
392 assertFalse(Thread.interrupted()); in testTimedJoin_Interruptible()
416 assertFalse(Thread.interrupted()); in testTimedSleep_Interruptible()
423 assertFalse(Thread.interrupted()); in testTimedSleep_Interruptible()
DRecursiveActionTest.java272 Thread.interrupted(); in testJoinIgnoresInterrupts()
285 Thread.interrupted(); in testJoinIgnoresInterrupts()
298 Thread.interrupted(); in testJoinIgnoresInterrupts()
308 Thread.interrupted(); in testJoinIgnoresInterrupts()
318 Thread.interrupted(); in testJoinIgnoresInterrupts()
327 Thread.interrupted(); in testJoinIgnoresInterrupts()
374 assertTrue(Thread.interrupted()); in testJoinIgnoresInterruptsOutsideForkJoinPool()
385 assertTrue(Thread.interrupted()); in testJoinIgnoresInterruptsOutsideForkJoinPool()
396 assertTrue(Thread.interrupted()); in testJoinIgnoresInterruptsOutsideForkJoinPool()
406 assertTrue(Thread.interrupted()); in testJoinIgnoresInterruptsOutsideForkJoinPool()
[all …]
/libcore/ojluni/src/test/java/util/concurrent/tck/
DExchangerTest.java153 final CountDownLatch interrupted = new CountDownLatch(1); in testReplacementAfterExchange() local
164 interrupted.await(); in testReplacementAfterExchange()
169 interrupted.await(); in testReplacementAfterExchange()
176 interrupted.countDown(); in testReplacementAfterExchange()
DCountDownLatchTest.java147 assertFalse(Thread.interrupted()); in testAwait_Interruptible()
154 assertFalse(Thread.interrupted()); in testAwait_Interruptible()
178 assertFalse(Thread.interrupted()); in testTimedAwait_Interruptible()
185 assertFalse(Thread.interrupted()); in testTimedAwait_Interruptible()
DBlockingQueueTest.java258 assertFalse(Thread.interrupted()); in testTimedPollWithOffer()
265 assertFalse(Thread.interrupted()); in testTimedPollWithOffer()
294 assertFalse(Thread.interrupted());
316 assertFalse(Thread.interrupted());
335 assertFalse(Thread.interrupted());
357 assertFalse(Thread.interrupted());
DPhaserTest.java495 assertFalse(Thread.interrupted());
502 assertFalse(Thread.interrupted());
512 assertFalse(Thread.interrupted());
519 assertFalse(Thread.interrupted());
550 assertTrue(Thread.interrupted());
560 assertTrue(Thread.interrupted());
578 assertTrue(Thread.interrupted());
589 assertTrue(Thread.interrupted());
607 assertTrue(Thread.interrupted());
614 assertTrue(Thread.interrupted());
[all …]
DLinkedBlockingDequeTest.java624 assertFalse(Thread.interrupted()); in testBlockingPut()
631 assertFalse(Thread.interrupted()); in testBlockingPut()
662 assertFalse(Thread.interrupted()); in testPutWithTake()
729 assertFalse(Thread.interrupted()); in testBlockingTake()
736 assertFalse(Thread.interrupted()); in testBlockingTake()
854 assertFalse(Thread.interrupted()); in testBlockingPutFirst()
861 assertFalse(Thread.interrupted()); in testBlockingPutFirst()
892 assertFalse(Thread.interrupted()); in testPutFirstWithTake()
955 assertFalse(Thread.interrupted()); in testTakeFirstFromEmptyBlocksInterruptibly()
977 assertFalse(Thread.interrupted()); in testTakeFirstFromEmptyAfterInterrupt()
[all …]
DRecursiveActionTest.java295 Thread.interrupted(); in testJoinIgnoresInterrupts()
307 Thread.interrupted(); in testJoinIgnoresInterrupts()
319 Thread.interrupted(); in testJoinIgnoresInterrupts()
328 Thread.interrupted(); in testJoinIgnoresInterrupts()
337 Thread.interrupted(); in testJoinIgnoresInterrupts()
345 Thread.interrupted(); in testJoinIgnoresInterrupts()
391 assertTrue(Thread.interrupted()); in testJoinIgnoresInterruptsOutsideForkJoinPool()
401 assertTrue(Thread.interrupted()); in testJoinIgnoresInterruptsOutsideForkJoinPool()
411 assertTrue(Thread.interrupted()); in testJoinIgnoresInterruptsOutsideForkJoinPool()
420 assertTrue(Thread.interrupted()); in testJoinIgnoresInterruptsOutsideForkJoinPool()
[all …]
/libcore/ojluni/src/main/java/sun/misc/
DResource.java96 boolean isInterrupted = Thread.interrupted(); in getBytes()
103 Thread.interrupted(); in getBytes()
126 Thread.interrupted(); in getBytes()
/libcore/ojluni/src/main/java/java/nio/channels/
DChannels.java236 boolean interrupted = false; in newInputStream()
244 interrupted = true; in newInputStream()
248 if (interrupted) in newInputStream()
308 boolean interrupted = false;
316 interrupted = true;
320 if (interrupted)
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/lang/
DThreadTest.java480 boolean interrupted = false; in test_interrupt()
489 interrupted = true; in test_interrupt()
491 assertTrue("Failed to Interrupt thread1", interrupted); in test_interrupt()
493 interrupted = false; in test_interrupt()
504 interrupted = true; in test_interrupt()
506 assertTrue("Failed to Interrupt thread2", interrupted); in test_interrupt()
515 .interrupted()); in test_interrupted()
517 assertTrue("Interrupted returned true for non-interrupted thread", Thread.interrupted()); in test_interrupted()
518 assertFalse("Failed to clear interrupted flag", Thread.interrupted()); in test_interrupted()
/libcore/luni/src/test/java/libcore/java/io/
DInterruptedStreamTest.java52 Thread.interrupted(); in setUp()
61 Thread.interrupted(); // clear interrupted bit in tearDown()
211 assertTrue(Thread.interrupted()); in confirmInterrupted()
/libcore/ojluni/src/main/java/sun/nio/fs/
DAbstractPoller.java192 boolean interrupted = false; in awaitResult()
198 interrupted = true; in awaitResult()
201 if (interrupted) in awaitResult()
/libcore/luni/src/test/java/libcore/java/nio/channels/
DFileIOInterruptTest.java94 Thread.interrupted(); in tearDown()
245 assertTrue(Thread.interrupted()); in testChannelRead_exceptionWhenAlreadyInterrupted()
377 assertTrue(Thread.interrupted()); in testChannelWrite_exceptionWhenAlreadyInterrupted()
476 wasInterrupted = Thread.interrupted(); in run()
513 wasInterrupted = Thread.interrupted(); in run()
564 wasInterrupted = Thread.interrupted(); in run()
615 wasInterrupted = Thread.interrupted(); in run()
/libcore/luni/src/test/java/libcore/java/lang/
DOldThreadGroupTest.java240 private static boolean interrupted = false; field in OldThreadGroupTest
254 assertFalse("Incorrect state of thread", interrupted); in test_interrupt()
256 assertFalse("Incorrect state of thread", interrupted); in test_interrupt()
262 assertTrue("Incorrect state of thread", interrupted); in test_interrupt()
316 interrupted = true; in uncaughtException()

1234