崇信县门户网站最新留言,wordpress门户,云盘网站如何做,网站个人微信收款方案1. Future的应用场景 在并发编程中#xff0c;我们经常用到非阻塞的模型#xff0c;在之前的多线程的三种实现中#xff0c;不管是继承thread类还是实现runnable接口#xff0c;都无法保证获取到之前的执行结果。通过实现Callback接口#xff0c;并用Future可以来接收多线…1. Future的应用场景 在并发编程中我们经常用到非阻塞的模型在之前的多线程的三种实现中不管是继承thread类还是实现runnable接口都无法保证获取到之前的执行结果。通过实现Callback接口并用Future可以来接收多线程的执行结果。
Future表示一个可能还没有完成的异步任务的结果针对这个结果可以添加Callback以便在任务执行成功或失败后作出相应的操作。 举个例子比如去吃早点时点了包子和凉菜包子需要等3分钟凉菜只需1分钟如果是串行的一个执行在吃上早点的时候需要等待4分钟但是因为你在等包子的时候可以同时准备凉菜所以在准备凉菜的过程中可以同时准备包子这样只需要等待3分钟。那Future这种模式就是后面这种执行模式。
2. Future的类图结构
Future接口定义了主要的5个接口方法有RunnableFuture和SchedualFuture继承这个接口以及CompleteFuture和ForkJoinTask继承这个接口。 RunnableFuture 这个接口同时继承Future接口和Runnable接口在成功执行run方法后可以通过Future访问执行结果。这个接口都实现类是FutureTask,一个可取消的异步计算这个类提供了Future的基本实现后面我们的demo也是用这个类实现它实现了启动和取消一个计算查询这个计算是否已完成恢复计算结果。计算的结果只能在计算已经完成的情况下恢复。如果计算没有完成get方法会阻塞一旦计算完成这个计算将不能被重启和取消除非调用runAndReset方法。 FutureTask能用来包装一个Callable或Runnable对象因为它实现了Runnable接口而且它能被传递到Executor进行执行。为了提供单例类这个类在创建自定义的工作类时提供了protected构造函数。
SchedualFuture
这个接口表示一个延时的行为可以被取消。通常一个安排好的future是定时任务SchedualedExecutorService的结果
CompleteFuture
一个Future类是显示的完成而且能被用作一个完成等级通过它的完成触发支持的依赖函数和行为。当两个或多个线程要执行完成或取消操作时只有一个能够成功。
ForkJoinTask
基于任务的抽象类可以通过ForkJoinPool来执行。一个ForkJoinTask是类似于线程实体但是相对于线程实体是轻量级的。大量的任务和子任务会被ForkJoinPool池中的真实线程挂起来以某些使用限制为代价。 3. Future的主要方法
Future接口主要包括5个方法 get()方法可以当任务结束后返回一个结果如果调用时工作还没有结束则会阻塞线程直到任务执行完毕
get(long timeout,TimeUnit unit)做多等待timeout的时间就会返回结果
cancel(boolean mayInterruptIfRunning)方法可以用来停止一个任务如果任务可以停止通过mayInterruptIfRunning来进行判断则可以返回true,如果任务已经完成或者已经停止或者这个任务无法停止则会返回false.
isDone()方法判断当前方法是否完成
isCancel()方法判断当前方法是否取消
4. Future示例demo
需求场景等早餐过程中包子需要3秒凉菜需要1秒普通的多线程需要四秒才能完成。先等凉菜再等包子因为等凉菜时普通多线程启动start()方法执行run()中具体方法时没有返回结果所以如果要等有返回结果必须是要1秒结束后才知道结果。
普通多线程
public class BumThread extends Thread{Overridepublic void run() {try {Thread.sleep(1000*3);System.out.println(包子准备完毕);} catch (InterruptedException e) {e.printStackTrace();}}}public class ColdDishThread extends Thread{Overridepublic void run() {try {Thread.sleep(1000);System.out.println(凉菜准备完毕);} catch (InterruptedException e) {e.printStackTrace();}}}public static void main(String[] args) throws InterruptedException {long start System.currentTimeMillis();// 等凉菜 -- 必须要等待返回的结果所以要调用join方法Thread t1 new ColdDishThread();t1.start();t1.join();// 等包子 -- 必须要等待返回的结果所以要调用join方法Thread t2 new BumThread();t2.start();t2.join();long end System.currentTimeMillis();System.out.println(准备完毕时间(end-start));
}采用Future模式
public static void main(String[] args) throws InterruptedException, ExecutionException {long start System.currentTimeMillis();// 等凉菜 Callable ca1 new Callable(){Overridepublic String call() throws Exception {try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}return 凉菜准备完毕;}};FutureTaskString ft1 new FutureTaskString(ca1);new Thread(ft1).start();// 等包子 -- 必须要等待返回的结果所以要调用join方法Callable ca2 new Callable(){Overridepublic Object call() throws Exception {try {Thread.sleep(1000*3);} catch (InterruptedException e) {e.printStackTrace();}return 包子准备完毕;}};FutureTaskString ft2 new FutureTaskString(ca2);new Thread(ft2).start();System.out.println(ft1.get());System.out.println(ft2.get());long end System.currentTimeMillis();System.out.println(准备完毕时间(end-start));
}--------------------- 作者波波仔86 来源CSDN 原文https://blog.csdn.net/bobozai86/article/details/123978048 版权声明本文为作者原创文章转载请附上博文链接 内容解析ByCSDN,CNBLOG博客文章一键转载插件
