}

  public void testDrainUninterruptiblyOverflow() {
    Queues.drainUninterruptibly(
        new SynchronousQueue<>(), new ArrayList<>(), /* numElements= */ 0, MAX_DURATION);
  }

  public void testZeroElements() throws Exception {
    for (BlockingQueue<Object> q : blockingQueues()) {
      checkZeroElements(q);
    }
  }

  private void checkZeroElements(BlockingQueue<Object> q) throws InterruptedException {