FutureTasks 和 CachedThreadPool 如何工作

Question

我目前有执行以下操作的代码：

private final static ExecutorService pool = Executors.newCachedThreadPool();
public void foo(){
    FutureTask<MyObject> first_task = createFutureTask();
    FutureTask<MyObject> second_task = createFutureTask();
    ...

    pool.execute(first_task);
    pool.execute(second_task);
    ....
    first_task.get();
    second_task.get();
    ...
    System.out.println(time taken);
}

我遇到的问题是我让每个未来任务打印出它们在进行计算时花费的时间，因此例如在控制台上我会看到

first_task : 20000ms
second_task : 18000ms
...

总时间 (< code>System.out.println(time take)) 比任何未来任务所花费的最长时间要大得多，因此根据此示例，方法 do 将花费大约 1 分钟（与 first_task 的 20 秒相比） ）。

我的印象是这些未来的任务是并行运行的，但从时间安排来看，它们似乎是一个接一个地运行的。我是否正确使用了这个 API？

Answer 1

您正确使用了 API，但请记住，每个任务都在单独的线程中运行，而不是单独的进程（因此不一定是并行的）。

每个线程必须在单独的 CPU 核心上运行才能同时执行。这是否可行取决于您的机器、其当前负载以及 JVM 和操作系统如何跨内核调度线程。