使用 Java Executor 实现多线程

Question

我被以下问题困扰。 假设我有一个包含 1000 个项目的请求，我想利用 Java Executor 来解决这个问题。

这是主要方法

public static void main(String[] args) {

     //Assume that I have request object that contain arrayList of names
     //and VectorList is container for each request result

     ExecutorService threadExecutor = Executors.newFixedThreadPool(3);
     Vector<Result> vectorList = new Vector<Result();

     for (int i=0;i<request.size();i++) {
          threadExecutor.execute(new QueryTask(request.get(i).getNames, vectorList)
     }

      threadExecutor.shutdown();

      response.setResult(vectorList)

}

这是 QueryTask 类

public QueryTask() implements Runnable {

    private String names;
    private Vector<Result> vectorList;

    public QueryTask(String names, Vector<Result> vectorList) {
          this.names = names;
          this.vectorList = vectorList;
    }

    public void run() {
         // do something with names, for example, query database
         Result result = process names;

         //add result to vectorList
         vectorList.add(result);
    }


}

因此，基于上面的示例，我想为请求中的每个数据创建线程池，同时运行它，并将结果添加到 VectorList。 在该过程结束时，我希望所有结果都已在向量列表中。

我在响应中不断得到不一致的结果。 例如，如果我传递包含 10 个名称的请求，我只会返回 3 或 4 个名称，或者有时在响应中什么也没有。 我原以为如果我通过了10分，那么我就会拿回10分。

有谁知道导致问题的原因是什么？

任何帮助将不胜感激。

谢谢

Answer 1

简单的解决方案是添加对 ExecutorService.awaitTermination() 的调用

public static void main(String[] args) {

     //Assume that I have request object that contain arrayList of names
     //and VectorList is container for each request result

     ExecutorService threadExecutor = Executors.newFixedThreadPool(3);
     Vector<Result> vectorList = new Vector<Result();

     for (int i=0;i<request.size();i++) {
          threadExecutor.execute(new QueryTask(request.get(i).getNames, vectorList)
     }

      threadExecutor.shutdown();
      threadExecutor.awaitTermination(aReallyLongTime,TimeUnit.SECONDS);

      response.setResult(vectorList)

}

Answer 2

您需要将 threadExecutor.shutdown(); 替换为 threadExecutor.awaitTermination();。 调用 threadExecutor.shutdown()< /code>，您还需要调用threadExecutor.awaitTermination()。前者是非阻塞调用，仅启动关闭，而后者是阻塞调用，实际上等待所有任务完成。由于您使用的是前者，因此您可能会在所有任务完成之前返回，这就是为什么您并不总是能返回所有结果。 Java API 不太清楚，因此有人提交了一个关于此的 bug 。

Answer 3

这里至少有两个问题。

1. 在您的 main 中，您关闭 ExecutorService，然后尝试立即获取结果。执行器服务将异步执行您的作业，因此很有可能您的所有作业尚未完成。当您调用response.setResult(vectorList)时，vectorList未完全填充。

<罢工>2。您正在从所有可运行对象中同时访问同一个 Vector 对象。这可能会导致 ConcurrentModificationExceptions，或者只是破坏向量中的内容。您需要手动同步 QueryTask 内部的向量，或者传入线程安全容器，例如 Collections.synchronizedList( new ArrayList() );