package t1;

import java.util.ArrayList;
import java.util.List;
import java.util.Random;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class TestThread13 {

public static void main(String[] args) {
ExecutorService executorService = Executors.newCachedThreadPool();
List<Future<String>> resultList = new ArrayList<Future<String>>();
for (int i = 0; i < 10; i++) {
Future<String> future = executorService.submit(new TaskWithResult(i));
resultList.add(future);
}
executorService.shutdown();

for (Future<String> future : resultList) {
try {
System.out.println("************" + future.get());
} catch (Exception e) {
executorService.shutdownNow();
return;
}
}
}
}

class TaskWithResult implements Callable<String> {
private int id;

public TaskWithResult(int id) {
this.id = id;
}

// 任务的具体过程，一旦任务传给ExecutorService的submit方法，则该方法自动在一个线程上执行。
@Override
public String call() throws Exception {
System.out.println("call()方法被自动调用，执行任务 " + Thread.currentThread().getName());
if (new Random().nextBoolean())
throw new TaskException("meet error in task " + Thread.currentThread().getName());
for (int i = 999999999; i > 0; i++)
;
return "call()方法被自动调用，任务的结果是：" + id + " " + Thread.currentThread().getName();
}
}

class TaskException extends Exception {
public TaskException(String msg) {
super(msg);
}
}

执行结果不定：