Java 执行器.pdfVIP

Java 执⾏器 Java线程教程 - Java执⾏器 框架提供了⼀种将任务提交与任务执⾏分离的⽅法。 java.util.concurrent包中的Executor接⼜是执⾏器框架的基础。 它是⼀个只 ⼀个⽅法的接⼜，如图所⽰： public interface Executor { void execute (Runnable command); } import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; class RunnableTask implements Runnable { private int task d; private int loopCounter; public RunnableTask(int task d, int loopCounter) { this.task d = task d; this.loopCounter = loopCounter; } public void run() { for (int i = 1; i = loopCounter; i++) { try { System.out.println(Task # + this.task d + - teration Thread.sleep(1000); } catch (Exception e) { System.out.println(Task # + this.task d + has been interrupted.); break; } } } } public class Main { public static void main(String[] args) { final int THREAD_COUNT = 3; final int LOOP_COUNT = 3; final int TASK_COUNT = 5; // Get an executor with three threads in its thread pool ExecutorService exec = Executors.newFixedThreadPool(THREAD_COU // Create five tasks and submit them to the executor for (int i = 1; i = TASK_COUNT; i++) { RunnableTask task = new RunnableTask(i, LOOP_COUNT); exec.submit(task); } exec.shutdown(); } } 上⾯的代码⽣成以下结果。 结果承载任务 要在任务完成时获取任务的结果，请使⽤Callable接⼜的实例。 类型参数V是任务的结果的类型。 Callable接⼜ ⼀个call()⽅法。它可以返回任何类型的值。 它允许你抛出异常。它声明如下： public interface CallableV { V call() throws Exception; } import java.util.concurrent.Callable; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; class CallableTask implements Callable nteger { private int task d; public CallableTask(int task d) { this.task d = task d; } public nteger call() throws nterruptedException { int total = task d; try { System.out.println(Tas