}
  }

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

  private void testDrainUninterruptiblyDoesNotThrow(BlockingQueue<Object> q) {
    Thread mainThread = currentThread();
    @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored