- Sort Score
- Num 10 results
- Language All
Results 1 - 6 of 6 for repeatedlyInterruptTestThread (0.22 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
TimedLatch latch = new TimedLatch(/* countdownInMillis= */ 100); repeatedlyInterruptTestThread(tearDownStack); latch.awaitSuccessfully(); assertInterrupted(); } public void testAwaitTimeoutMultiInterruptNoExpire() { TimedLatch latch = new TimedLatch(/* countdownInMillis= */ 100); repeatedlyInterruptTestThread(tearDownStack); latch.awaitSuccessfully(LONG_DELAY_MS); assertInterrupted();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 38.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
TimedLatch latch = new TimedLatch(/* countdownInMillis= */ 100); repeatedlyInterruptTestThread(tearDownStack); latch.awaitSuccessfully(); assertInterrupted(); } public void testAwaitTimeoutMultiInterruptNoExpire() { TimedLatch latch = new TimedLatch(/* countdownInMillis= */ 100); repeatedlyInterruptTestThread(tearDownStack); latch.awaitSuccessfully(LONG_DELAY_MS); assertInterrupted();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 38.1K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java
throw new AssertionError(wontHappen); } interruptee.interrupt(); }) .start(); } static void repeatedlyInterruptTestThread(TearDownAccepter tearDownAccepter) { Interruptenator interruptingTask = new Interruptenator(Thread.currentThread()); Thread interruptingThread = new Thread(interruptingTask); interruptingThread.start();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 15:38:30 GMT 2026 - 3.4K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java
throw new AssertionError(wontHappen); } interruptee.interrupt(); }) .start(); } static void repeatedlyInterruptTestThread(TearDownAccepter tearDownAccepter) { Interruptenator interruptingTask = new Interruptenator(Thread.currentThread()); Thread interruptingThread = new Thread(interruptingTask); interruptingThread.start();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 15:38:30 GMT 2026 - 3.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
* limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static com.google.common.util.concurrent.InterruptionUtil.repeatedlyInterruptTestThread; import static com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly; import static java.util.concurrent.Executors.newSingleThreadExecutor; import static java.util.concurrent.TimeUnit.MILLISECONDS;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 8.9K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
* limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static com.google.common.util.concurrent.InterruptionUtil.repeatedlyInterruptTestThread; import static com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly; import static java.util.concurrent.Executors.newSingleThreadExecutor; import static java.util.concurrent.TimeUnit.MILLISECONDS;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 8.9K bytes - Click Count (0)