如何正确使用线程池并从线程中获取结果？

Question

我正在尝试尝试多线程编程（对我来说是新的），但我有一些问题。

我正在使用一个带有 TestTask 的 ThreadPoolTask​​Executor，该 TestTask 实现了 Runnable 和一个休眠 X 秒的 run 方法。一切都很顺利，我的所有测试任务都在不同的线程中执行。好的。 现在棘手的部分是我想知道线程中操作的结果。所以我在 Google/stack/etc 上阅读了一些内容，并尝试使用 Future。它不再工作正常了：/

我使用 get 方法来获取（哦，真的吗？）call 方法的结果，该部分正在工作，但 TestTask 被执行一个接一个（而不是像以前那样同时进行）。所以我猜我没有正确理解一些东西，但我不知道是什么......这就是为什么我需要你的帮助！

启动测试的类：

public void test(String test) {

    int max = 5;
    for (int i = 0; i < max; i++) {
        TestThreadService.launch(i);
    }
    System.out.println("END");

}

TestThreadService 类：

public class TestThreadService {

private ThreadPoolTaskExecutor taskExecutor;

public void launch(int i) {
    System.out.println("ThreadNumber : "+i);
    taskExecutor.setWaitForTasksToCompleteOnShutdown(false);
    TestTask testTask = new TestTask(i);
    FutureTask<Integer> futureOne = new FutureTask<Integer>(testTask);
    taskExecutor.submit(futureOne);
    try {
        Integer result = futureOne.get();
        System.out.println("LAUNCH result : "+i+" - "+result);
    } catch (Exception e) {
        e.printStackTrace();
    }
  }

public void setTaskExecutor(ThreadPoolTaskExecutor taskExecutor) {
  this.taskExecutor = taskExecutor;
}

}

和 TestTask 类：

public class TestTask implements Callable<Integer> {

public Integer threadNumber;
private Integer valeur;

  public TestTask(int i) {
    this.threadNumber = i;
  }

  public void setThreadNumber(Integer threadNumber) {
    this.threadNumber = threadNumber;
  }

    @Override
    public Integer call() throws Exception {
        System.out.println("Thread start " + threadNumber);
        // generate sleeping time
        Random r = new Random();
        valeur = 5000 + r.nextInt(15000 - 5000);
        System.out.println("Thread pause " + threadNumber + " " + valeur);
        try {
            Thread.sleep(valeur);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("Thread stop" + threadNumber);
        return this.valeur;
    }

}

我在 Java 方面还不错，但这是我第一次尝试使用不同的线程，所以这对我来说是一种新的体验。

我做错了什么？

谢谢 ！

Answer 1

在您的 test 方法中，

TestThreadService.launch(1);

但可能应该是

TestThreadService.launch(i);

主要的事情

Integer result = futureOne.get();

尽管是在 launch 方法中进行调用， 。对 FutureTask 调用 get() 是一个阻塞操作，这意味着在任务完成之前它不会返回。这就是您看到串行行为的原因。您正在模拟的用例（处理一堆活动并等待它们完成）并不是 ThreadPoolTask​​Executor 非常适合的用例。它不具有原始线程所具有的“连接”功能。也就是说，你想要做的就是

public Future<Integer> launch(int i) {
    System.out.println("ThreadNumber : "+i);
    taskExecutor.setWaitForTasksToCompleteOnShutdown(false);
    TestTask testTask = new TestTask(i);
    FutureTask<Integer> futureOne = new FutureTask<Integer>(testTask);
    return taskExecutor.submit(futureOne);
  }

在你的测试方法中

public void test(String test) {
    List<Future<Integer>> tasks = new ArrayList<Future<Integer>>();
    int max = 5;
    for (int i = 0; i < max; i++) {
        tasks.add(TestThreadService.launch(i));
    }
    for (Future<Integer> task : tasks) {
        System.out.println("LAUNCH result : " + task.get());
    }
    System.out.println("END");

}

Answer 2

您也可以将 setWaitForTasksToCompleteOnShutdown(false) 移动到另一个方法中，因为每次启动线程时都不会被调用，正如我所见，（不是很多线程），但在另一种情况下，有更多任务：不必要的和昂贵的工作。

您还可以在服务上创建一个公共方法，称为：configure();或者，预启动()；在开始创建线程之前。

幸灾乐祸！