TimedLatch latch = new TimedLatch(/* countdownInMillis= */ 50);
    requestInterruptIn(10);
    latch.awaitSuccessfully();
    assertInterrupted();
  }

  public void testAwaitTimeoutSingleInterruptNoExpire() {
    TimedLatch latch = new TimedLatch(/* countdownInMillis= */ 50);
    requestInterruptIn(10);
    latch.awaitSuccessfully(LONG_DELAY_MS);
    assertInterrupted();
  }

    TimedLatch latch = new TimedLatch(/* countdownInMillis= */ 50);
    requestInterruptIn(10);
    latch.awaitSuccessfully();
    assertInterrupted();
  }

  public void testAwaitTimeoutSingleInterruptNoExpire() {
    TimedLatch latch = new TimedLatch(/* countdownInMillis= */ 50);
    requestInterruptIn(10);
    latch.awaitSuccessfully(LONG_DELAY_MS);
    assertInterrupted();
  }

      }
    }

    void stopInterrupting() {
      shouldStop = true;
    }
  }

  /** Interrupts the current thread after sleeping for the specified delay. */
  static void requestInterruptIn(long time, TimeUnit unit) {
    checkNotNull(unit);
    Thread interruptee = Thread.currentThread();
    new Thread(
            () -> {
              try {
                unit.sleep(time);

      }
    }

    void stopInterrupting() {
      shouldStop = true;
    }
  }

  /** Interrupts the current thread after sleeping for the specified delay. */
  static void requestInterruptIn(long time, TimeUnit unit) {
    checkNotNull(unit);
    Thread interruptee = Thread.currentThread();
    new Thread(
            () -> {
              try {
                unit.sleep(time);

     * 6. Now the result becomes available.
     * 7. We expect get() to return this result.
     * 8. We expect the test thread's interrupt state to be false.
     */
    InterruptionUtil.requestInterruptIn(200, MILLISECONDS);

    assertFalse(Thread.interrupted());
    try {
      delayedFuture.get(20000, MILLISECONDS);
      fail("expected to be interrupted");
    } catch (InterruptedException expected) {