执行程序池不处理所有项目

Question

我需要执行一些动作5000万件物品。我写了下面的代码

 AtomicInteger failCounter = new AtomicInteger(0);
 long start = System.currentTimeMillis();
 ExecutorService es = Executors.newFixedThreadPool(30);

  List<String> allids = getItems();//50 million items from db

  log.info(getAction() + " Total items found: " + allids.size());

  allids.stream().forEach(s -> {
    es.execute(new MyRunnable(s, failCounter));
  });

  es.shutdownNow();
  try {
    if (!es.awaitTermination(100, TimeUnit.SECONDS)) {
      System.out.println("Still waiting...");
      System.exit(0);
    }
  } catch (InterruptedException e) {
    e.printStackTrace();
  }
  System.out.println("Exiting normally...");
  log.info("counter: " + failCounter.get());

public class MyRunnable implements Runnable {

    private final String id;
    private final AtomicInteger failCounter;

    RollupRunnable(String id, AtomicInteger failCounter) {
      this.id = id;
      this.failCounter = failCounter;
    }

    @Override
    public void run() {
      try {
        //perform some action        
      } catch (Exception exception) {
        failCounter.getAndIncrement();
        log.error(
            "Error in calling " + getAction() + " for id: " + id + "  of :" + this.getClass()
                .getSimpleName(),
            exception);
      }

    }
  }

但处理前30个项目后存在执行程序。

难道我做错了什么。

Answer 1

而不是es.shutdownNow();使用es.shutdown();

shutDownNow()停止处理所有任务，包括那些甚至没有执行的任务。

这就是为什么并非所有项都由Executor框架执行的原因。