Method join

future-java/src/main/java/io/trane/future/Promise.java:438–448

(final Duration timeout)

  }

  @Override
  public final void join(final Duration timeout) throws CheckedFutureException {
    final ReleaseOnRunLatch latch = new ReleaseOnRunLatch();
    ensure(latch);
    try {
      if (!latch.tryAcquireSharedNanos(1, timeout.toNanos()))
        throw new TimeoutException();
    } catch (final InterruptedException ex) {
      throw new CheckedFutureException(ex);
    }
  }

  private static class Map<T, R> extends Continuation<T, R> {
    private final Function<? super T, ? extends R> f;