SettableFuture<String> input = SettableFuture.create();
    CountDownLatch inFunction = new CountDownLatch(1);
    CountDownLatch shouldCompleteFunction = new CountDownLatch(1);
    CountDownLatch gotException = new CountDownLatch(1);
    AsyncFunction<String, String> function =
        unused -> {
          inFunction.countDown();
          try {

    SettableFuture<String> input = SettableFuture.create();
    CountDownLatch inFunction = new CountDownLatch(1);
    CountDownLatch shouldCompleteFunction = new CountDownLatch(1);
    CountDownLatch gotException = new CountDownLatch(1);
    AsyncFunction<String, String> function =
        unused -> {
          inFunction.countDown();
          try {

    assertThat(map).hasSize(1);
  }

  public void testCopyEntry_computing() {
    CountDownLatch startSignal = new CountDownLatch(1);
    CountDownLatch computingSignal = new CountDownLatch(1);
    CountDownLatch doneSignal = new CountDownLatch(2);
    Object computedObject = new Object();

    CacheLoader<Object, Object> loader =
        new CacheLoader<Object, Object>() {

    assertThat(notifications).isEmpty();
  }

  public void testCopyEntry_computing() {
    CountDownLatch startSignal = new CountDownLatch(1);
    CountDownLatch computingSignal = new CountDownLatch(1);
    CountDownLatch doneSignal = new CountDownLatch(2);
    Object computedObject = new Object();

    CacheLoader<Object, Object> loader =
        new CacheLoader<Object, Object>() {

     */
    CountDownLatch whenClosedCountDown() {
      if (closed) {
        return new CountDownLatch(0);
      }
      synchronized (this) {
        if (closed) {
          return new CountDownLatch(0);
        }
        checkState(whenClosed == null);
        return whenClosed = new CountDownLatch(1);
      }
    }
  }

  /**

import java.net.UnknownHostException
import java.net.UnknownServiceException
import java.time.Duration
import java.util.Arrays
import java.util.concurrent.BlockingQueue
import java.util.concurrent.CountDownLatch
import java.util.concurrent.Executors
import java.util.concurrent.SynchronousQueue
import java.util.concurrent.TimeUnit
import java.util.concurrent.atomic.AtomicBoolean
import java.util.concurrent.atomic.AtomicInteger