简单地创建Threads来并行执行一些任务并将每个任务分配给ThreadPool是非常困难的.

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();

}}