在Java中使用多线程实现for循环的并行化

Question

    for(SellerNames sellerNames : sellerDataList) {
        for(String selleName : sellerNames) {
        //getSellerAddress(sellerName)
        //parallize this task
        }
    }

sellerDataList的大小=1000，sellerNames的大小=5000。

现在我想创建10个线程，并为每个线程分配相等的任务块。对于第一个sellerDataList,第一个线程应该获得500个名称的地址,第二个线程应该获得下一个500个名称的地址,依此类推。
完成这项工作的最佳方法是什么？

Answer 1

有两种方法可以使它并行运行：流和执行器。

您可以使用并行流，而将其余的留给JVM。在这种情况下，你没有太多的控制什么时候发生。另一方面，您的代码将易于阅读和维护：

    sellerDataList.stream().forEach(sellerNames -> {
        Stream<String> stream = StreamSupport.stream(sellerNames.spliterator(), true); // true means use parallel stream
        stream.forEach(sellerName -> {
            getSellerAddress(sellerName);
        });
    });

假设，您希望有5个线程，并且希望能够等待任务完成。然后，您可以使用包含5个线程的固定线程池，并使用future-s，这样您就可以等待它们完成。

    final ExecutorService executor = Executors.newFixedThreadPool(5); // it's just an arbitrary number
    final List<Future<?>> futures = new ArrayList<>();
    for (SellerNames sellerNames : sellerDataList) {
        for (final String sellerName : sellerNames) {
            Future<?> future = executor.submit(() -> {
                getSellerAddress(sellerName);
            });
            futures.add(future);
        }
    }
    try {
        for (Future<?> future : futures) {
            future.get(); // do anything you need, e.g. isDone(), ...
        }
    } catch (InterruptedException | ExecutionException e) {
        e.printStackTrace();
    }