for (ScheduledThreadPoolExecutor executor : executors) {
      log.info("IssueGenMatchingEventConsumer remained executor queue size before shutdown: {}", executor.getQueue().size());
      executor.shutdown();
      executor.awaitTermination(TERMINATION_TIMEOUT_MS, TimeUnit.MILLISECONDS);
      List<Runnable> runnables = executor.shutdownNow();
      int executedCnt = 0;
      for (Runnable runnable : runnables) {
        try {
          PriceIssueGenMatchingEventWorker priceIssueGenMatchingEventWorker = (PriceIssueGenMatchingEventWorker) FutureTaskObjectExtractor.extractActualObject(runnable);
          if (priceIssueGenMatchingEventWorker != null) {
            if (priceIssueGenMatchingEventWorker.getEventPivotId() != null) {
              pivotIdSet.add(priceIssueGenMatchingEventWorker.getEventPivotId());
              executedCnt++;
            }
          }
        } catch (Exception e) {
          log.error("IssueGenMatchingEventConsumer Save to unprocessed_events throw exception", e);
        }
      }
      log.info("IssueGenMatchingEventConsumer remained executor queue size after shutdown: {}, executedCnt: {}", runnables.size(), executedCnt);
    }