@Test
  public void concurrentDeleteTest() throws Exception {
    int extraBlobCount = 2000 / PUT_RECORD_SIZE + 1;
    put(extraBlobCount, PUT_RECORD_SIZE, Utils.Infinite_Time);
    List<Deleter> deleters = new ArrayList<>(liveKeys.size());
    for (MockId id : liveKeys) {
      deleters.add(new Deleter(id, false));
    }
    ExecutorService executorService = Executors.newFixedThreadPool(deleters.size());
    try {
      List<Future<CallableResult>> futures = executorService.invokeAll(deleters);
      verifyDeleteFutures(deleters, futures);
    } finally {
      executorService.shutdownNow();
    }
  }
Tests the case where there are many concurrent DELETEs.
@throws Exception
ambry-store/src/test/java/com/github/ambry/store/BlobStoreTest.java