温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

Runnable、Callable、Future、FutureTask 及应用是怎样的

发布时间:2022-01-04 16:58:46 来源:亿速云 阅读:175 作者:柒染 栏目:大数据

Runnable、Callable、Future、FutureTask 及应用是怎样的,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。

一般创建线程只有两种方式,一种是继承Thread,一种是实现Runnable接口。但是这两种创建方式有一个致命的缺点就是没有返回值,没返回值就让人很苦恼了啊。得用共享变量或者其他通信方式才能得到线程处理完的结果,就有点麻烦。

还有一般不提倡使用继承Thread来创建线程方式,因为Java只有单继承,不能继承多个。但是Runnable是接口,所以可以让你的实现类同时实现多个接口。而且之后要上线程池,如果之前你是用Runnable来实现的,那就可以直接传入Runnable给线程池进行管理了!

在Java1.5之后就有了Callable、Future。这二种可以提供线程执行完的结果!

接下来简单介绍下Runnable、Callable 、Future、 FutureTask。

Runnable

Runnable 是一个接口,简单就一个方法,实现run方法,在run方法里面编写你要执行的代码就行了,但是没有任务返回接口,并且无法抛出异常。

Runnable、Callable、Future、FutureTask 及应用是怎样的

请点击输入图片描述

简单应用

Runnable、Callable、Future、FutureTask 及应用是怎样的

请点击输入图片描述

Callable

Callable也是一个接口,很简单就一个call方法,在call方法里面编写你要执行的代码就行了,返回的就是执行的结果了。和Runnable 差别就是它有返回的结果,并且可以抛出异常!一般配合ThreadPoolExecutor使用的。

Runnable、Callable、Future、FutureTask 及应用是怎样的

简单应用,它不能直接配合Thread 使用。

Runnable、Callable、Future、FutureTask 及应用是怎样的

Future

Future也是一个接口,它可以对具体的Runnable或者Callable任务进行取消、判断任务是否已取消、查询任务是否完成、获取任务结果。如果是Runnable的话返回的结果是null(下面会剖析为什么Runnable的任务,Future还能返回结果)。接口里面有以下几个方法。注意两个get方法都会阻塞当前调用get的线程,直到返回结果或者超时才会唤醒当前的线程。

Runnable、Callable、Future、FutureTask 及应用是怎样的

简单应用

Runnable、Callable、Future、FutureTask 及应用是怎样的

FutureTask

因为Future只是一个接口,所以是无法直接用来创建对象使用的,因此就有了下面的FutureTask。

FutureTask不是接口了,是个class。它实现了RunnableFuture接口

public class FutureTask<V> implements RunnableFuture<V>

而RunnableFuture接口又继承了Runnable和Future

public interface RunnableFuture<V> extends Runnable, Future<V>

因此它可以作为Runnable被线程执行,又可以有Future的那些操作。它的两个构造器如下

Runnable、Callable、Future、FutureTask 及应用是怎样的

简单应用

Runnable、Callable、Future、FutureTask 及应用是怎样的

线程池应用

一般情况我们在用多线程的时候都会上线程池,而且一般我们使用ThreadPoolExecutor来创建线程池,我的上篇文章已经讲述了ThreadPoolExecutor,这里再补充一下submit用法。

Runnable、Callable、Future、FutureTask 及应用是怎样的

也就是说如果我们需要返回任务的执行结果我们就得调用submit方法而不是execute。

submit也不神秘就是封装了一下我们的任务再execute

Runnable、Callable、Future、FutureTask 及应用是怎样的

newTaskFor方法是new了一个FutureTask返回。

所以三个方法其实都是把task转成FutureTask,如果task是Callable,就直接赋值。如果是Runnable 就转为Callable再赋值

task是Callable的情况

Runnable、Callable、Future、FutureTask 及应用是怎样的

task是Runnable 的情况

Runnable、Callable、Future、FutureTask 及应用是怎样的

看了源码就揭开了神秘面纱了,就是因为Future需要返回结果,所以内部task必须是Callable,如果task是Runnable 我就造个假,偷天换日,在Runnable 外面包个Callable马甲,返回的结果在构造时就写好。

如果是调用Future<?> submit(Runnable task);提交任务,构造的时候就直接是RunnableFuture<Void> ftask = newTaskFor(task, null);直接塞了个null。所以调用Future.get时,拿到的就是null。

所以这样有什么用呢?就只用能来判断任务已经执行完毕,就类似于Thread.join。

这还有个<T> Future<T> submit(Runnable task, T result);你可能会奇怪这有啥用啊,你传入一个result,Future.get的时候返回的不还是这个result嘛。是个没错,但是这样用就行了!

Runnable、Callable、Future、FutureTask 及应用是怎样的

这样就可以得到修改后的结果了!

看完上述内容,你们掌握Runnable、Callable、Future、FutureTask 及应用是怎样的的方法了吗?如果还想学到更多技能或想了解更多相关内容,欢迎关注亿速云行业资讯频道,感谢各位的阅读!

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI