JDK文档描述Callable:
public interface Callable<V>返回结果并且可能抛出异常的任务。实现者定义了一个不带任何参数的叫做 call 的方法。 Callable 接口类似于 Runnable,两者都是为那些其实例可能被另一个线程执行的类设计的。但是 Runnable 不会返回结果,并且无法抛出经过检查的异常。 Executors 类包含一些从其他普通形式转换成 Callable 类的实用方法
唯一的一个方法是:
call V call() throws Exception计算结果,如果无法计算结果,则抛出一个异常。 返回: 计算的结果 抛出: Exception - 如果无法计算结果
JDK文档描述Future:
public interface Future<V>Future 表示异步计算的结果。它提供了检查计算是否完成的方法,以等待计算的完成,并获取计算的结果。计算完成后只能使用 get 方法来获取结果,如有必要,计算完成前可以阻塞此方法。取消则由 cancel 方法来执行。还提供了其他方法,以确定任务是正常完成还是被取消了。一旦计算完成,就不能再取消计算。如果为了可取消性而使用 Future 但又不提供可用的结果,则可以声明 Future<?> 形式类型、并返回 null 作为底层任务的结果。
主要的方法有:
方法摘要 | |
boolean | cancel(boolean mayInterruptIfRunning) 试图取消对此任务的执行 |
V | get() 如有必要,等待计算完成,然后获取其结果。 |
V | get(long timeout, TimeUnit unit) 如有必要,最多等待为使计算完成所给定的时间之后,获取其结果(如果结果可用)。 |
boolean | isCancelled() 如果在任务正常完成前将其取消,则返回 true。 |
boolean | isDone() 如果任务已完成,则返回 true。 |
例子:
import java.util.Random; import java.util.concurrent.Callable; import java.util.concurrent.CompletionService; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorCompletionService; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; public class ThreadPool2 { public static void main(String[] args) { test1(); } private static void test1(){ ExecutorService es = Executors.newFixedThreadPool(2); for(int i=1 ; i<=5; i++){ final int task = i; Future<Integer> future = es.submit(new Callable<Integer>() { @Override public Integer call() throws Exception { try { Thread.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("Callable 任务【" + task + "】运行"); return new Random().nextInt(100); } }); System.out.println("当前提交第【" + i + "】返回结果的任务"); try { System.out.println("任务【" + i + "】返回的结果:" + future.get()); } catch (Exception e) { e.printStackTrace(); } } System.out.println("我是for循环后面的代码----------"); es.shutdown(); } }
运行结果:
当前提交第【1】返回结果的任务 Callable 任务【1】运行 任务【1】返回的结果:49 当前提交第【2】返回结果的任务 Callable 任务【2】运行 任务【2】返回的结果:92 当前提交第【3】返回结果的任务 Callable 任务【3】运行 任务【3】返回的结果:17 当前提交第【4】返回结果的任务 Callable 任务【4】运行 任务【4】返回的结果:96 当前提交第【5】返回结果的任务 Callable 任务【5】运行 任务【5】返回的结果:14 我是for循环后面的代码----------
时间: 2024-10-18 01:07:00