Home
last modified time | relevance | path

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

1234

/libcore/ojluni/src/main/java/java/nio/channels/spi/
DAbstractInterruptibleChannel.java143 private volatile Thread interrupted; field in AbstractInterruptibleChannel
161 interrupted = target; in begin()
197 Thread interrupted = this.interrupted; in end() local
198 if (interrupted != null && interrupted == Thread.currentThread()) { in end()
199 this.interrupted = null; in end()
/libcore/ojluni/src/main/java/java/util/concurrent/locks/
DAbstractQueuedSynchronizer.java640 boolean interrupted = false, first = false; in acquire()
674 cancelAcquire(node, interrupted, false); in acquire()
685 if (interrupted) in acquire()
721 if ((interrupted |= Thread.interrupted()) && interruptible) in acquire()
725 return cancelAcquire(node, interrupted, interruptible); in acquire()
770 private int cancelAcquire(Node node, boolean interrupted, in cancelAcquire() argument
778 if (interrupted) { in cancelAcquire()
957 if (Thread.interrupted() || in acquireInterruptibly()
981 if (!Thread.interrupted()) { in tryAcquireNanos()
1045 if (Thread.interrupted() || in acquireSharedInterruptibly()
[all …]
DAbstractQueuedLongSynchronizer.java275 boolean interrupted = false, first = false; in acquire()
309 cancelAcquire(node, interrupted, false); in acquire()
320 if (interrupted) in acquire()
356 if ((interrupted |= Thread.interrupted()) && interruptible) in acquire()
360 return cancelAcquire(node, interrupted, interruptible); in acquire()
404 private int cancelAcquire(Node node, boolean interrupted, in cancelAcquire() argument
412 if (interrupted) { in cancelAcquire()
591 if (Thread.interrupted() || in acquireInterruptibly()
615 if (!Thread.interrupted()) { in tryAcquireNanos()
679 if (Thread.interrupted() || in acquireSharedInterruptibly()
[all …]
DStampedLock.java509 if (!Thread.interrupted()) { in tryWriteLock()
534 if (!Thread.interrupted() && in writeLockInterruptibly()
583 if (!Thread.interrupted()) { in tryReadLock()
608 if (!Thread.interrupted() && in readLockInterruptibly()
1203 boolean interrupted = false, first = false; in acquireWrite()
1225 if (interrupted) in acquireWrite()
1257 if ((interrupted |= Thread.interrupted()) && interruptible) in acquireWrite()
1261 return cancelAcquire(node, interrupted); in acquireWrite()
1274 boolean interrupted = false; in acquireRead()
1321 interrupted |= Thread.interrupted(); in acquireRead()
[all …]
/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.java481 boolean interrupted = false; in test_interrupt()
490 interrupted = true; in test_interrupt()
492 assertTrue("Failed to Interrupt thread1", interrupted); in test_interrupt()
494 interrupted = false; in test_interrupt()
505 interrupted = true; in test_interrupt()
507 assertTrue("Failed to Interrupt thread2", interrupted); in test_interrupt()
516 .interrupted()); in test_interrupted()
518 assertTrue("Interrupted returned true for non-interrupted thread", Thread.interrupted()); in test_interrupted()
519 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