public void reset() {
    lock.lock();
    try {
      cancellationException = null;
      clearElementsLocked();
    } finally {
      lock.unlock();
    }
  }
@Test(timeout = 10_000)
  public void runTestForMultipleConsumersAndProducers() throws Exception {
    CancellableQueue<String> queue = new CancellableQueue<>(100);
    runTestForMultipleConsumersAndProducers(queue);
    queue.reset();
    runTestForMultipleConsumersAndProducers(queue);
  }