为什么我的多线程任务不能正常工作？

Question

我正在尝试使用批处理操作从 facebook 获取帖子。 我想过让这个任务多线程来加速操作。 基本上，我向 facebook 发送批量请求，在等待响应时，我的任务是做其他需要做的事情。 当我（慢慢地）调试任务时，我得到了我想要测试的 2000 个结果.... 但是当我运行它或让它在请求操作后调试和暂停时，它会小于 2000。

    String[] str = new String[2000];
    ExecutorService exec = Executors.newFixedThreadPool(10);
    List<BatchRequest> request= new CopyOnWriteArrayList<BatchRequest>();
    List <BatchResponse> batchResponses = new ArrayList<BatchResponse>();



    int i=1;
    for(int j=0 ; j<2000; j++) {

        if (i < 50) {
            BatchRequest batch = new BatchRequestBuilder(str[i]).build();
            request.add(batch);
            i++;
            counter++;
        } else {
            i = 1;
            exec.execute(new Runnable() {

                //thread that gets information from facebook into a list of responses
                public void run() {
                    // TODO Auto-generated method stub
                    System.out.println("running");
                    batchResponses.addAll(fc.executeBatch(request));
                    System.out.println("done");

                }

            });
            request.clear();
        }
    }
    exec.shutdown();
    exec.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);

我已经删除了所有不必要的东西。希望它仍然有意义。

我的代码有什么问题？

编辑：我编辑了代码以使其更有意义。有人吗？

Answer 1

除了@OldCurmudgeon 的回答，我可以说ArrayList 不是线程安全类。您可以使用其他容器，使用Collections.synchronizedList() 包装它或将同步添加到您的代码中。

还要确保您的 fc 变量引用线程安全类。

Answer 2

counter 和 i 之间的代码似乎有些混淆。也许如果你解释为什么你需要这两个东西会变得更清楚。

就代码而言，主要问题是您永远不会将counter 设置回零。这将导致前 500 个在其自己的线程中作为一批执行，但其余的每个将单独执行。

Answer 3

一些问题： batchResponses 正在线程内部被访问，并且您正在主线程中推送它。 batchResponses 也不是线程安全的，所以需要同步。

你也在主线程中做 request.clear ......这是一个错误，因为你不能保证新线程已经执行，可能是在你清除它之后新线程运行。新线程会看到 request.size(0) = 0。

主 if 块和 else 块具有相同的线程代码，这有点令人困惑。 if(i== 50) 你进入 else 块并执行请求。 当您的计数器为 500 时，您已经访问了 else 块 10 次，因此您可能有空请求或您插入的最后 50 个。

这段代码有些地方不清楚。