Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 6 of 6 for repeatedlyInterruptTestThread (0.2 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to Top