我有一个关于如何的基本问题ExecutorService在 Java 中工作。
很难看出简单创建之间的区别Threads并行执行一些任务并将每个任务分配给ThreadPool.
The ExecutorService使用起来也看起来非常简单和高效，所以我想知道为什么我们不一直使用它。
这只是一种方法比另一种方法执行速度更快的问题吗？
这是两个非常简单的例子来展示两种方式之间的区别：
使用执行器服务：Hello World（任务）
static class HelloTask implements Runnable {
String msg;
public HelloTask(String msg) {
this.msg = msg;
}
public void run() {
long id = Thread.currentThread().getId();
System.out.println(msg + " from thread:" + id);
}
}
使用执行器服务：Hello World（创建执行器，提交）
static class HelloTask {
public static void main(String[] args) {
int ntasks = 1000;
ExecutorService exs = Executors.newFixedThreadPool(4);
for (int i=0; i<ntasks; i++) {
HelloTask t = new HelloTask("Hello from task " + i);
exs.submit(t);
}
exs.shutdown();
}
}
下面显示了一个类似的示例，但扩展了 Callable 接口，您能告诉我两者之间的区别以及在哪些情况下应该使用特定的一个而不是另一个？
使用执行器服务：计数器（任务）
static class HelloTaskRet implements Callable<Long> {
String msg;
public HelloTaskRet(String msg) {
this.msg = msg; }
public Long call() {
long tid = Thread.currentThread().getId();
System.out.println(msg + " from thread:" + tid);
return tid;
}
}
使用执行器服务：（创建、提交）
static class HelloTaskRet {
public static void main(String[] args) {
int ntasks = 1000;
ExecutorService exs = Executors.newFixedThreadPool(4);
Future<Long>[] futures = (Future<Long>[]) new Future[ntasks];
for (int i=0; i<ntasks; i++) {
HelloTaskRet t = new HelloTaskRet("Hello from task " + i);
futures[i] = exs.submit(t);
}
exs.shutdown();
}
}
