神刀安全网

源码|newTaskFor()和适配器模式

AbstractExecutorService提供了一个创建任务的工厂方法——newTaskFor()。工厂方法大家很熟悉了,但newTaskFor()中用到的适配器模式却少有人提到。

JDK版本:oracle java 1.8.0_102

高能预警!这篇,又!短!又!没!用!

newTaskFor()和工厂方法模式

在AbstractExecutorService中,可以提交三种形式的task:

public Future<?> submit(Runnable task) {     if (task == null) throw new NullPointerException();     RunnableFuture<Void> ftask = newTaskFor(task, null);     execute(ftask);     return ftask; } public <T> Future<T> submit(Runnable task, T result) {     if (task == null) throw new NullPointerException();     RunnableFuture<T> ftask = newTaskFor(task, result);     execute(ftask);     return ftask; } public <T> Future<T> submit(Callable<T> task) {     if (task == null) throw new NullPointerException();     RunnableFuture<T> ftask = newTaskFor(task);     execute(ftask);     return ftask; } 

三种形式类似,主要区别在于工厂方法AbstractExecutorService#newTaskFor():

protected <T> RunnableFuture<T> newTaskFor(Runnable runnable, T value) {     return new FutureTask<T>(runnable, value); } protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable) {     return new FutureTask<T>(callable); } 

直接调用了FutureTask的有参构造函数。

FutureTask实现了RunnableFuture接口:

public class FutureTask<V> implements RunnableFuture<V>  

该接口继承了Runnable、Future接口,并只有一个run方法。看下FutureTask的构造方法:

public FutureTask(Callable<V> callable) {     if (callable == null)         throw new NullPointerException();     this.callable = callable;     this.state = NEW;       // ensure visibility of callable } public FutureTask(Runnable runnable, V result) {     this.callable = Executors.callable(runnable, result);     this.state = NEW;       // ensure visibility of callable } 

8行是一个适配器模式:

this.callable = Executors.callable(runnable, result); 

通过静态工厂方法兼适配器Executors.callable()将Runnbale实例和result适配为Callable实例。

callable()和适配器模式

public static <T> Callable<T> callable(Runnable task, T result) {     if (task == null)         throw new NullPointerException();     return new RunnableAdapter<T>(task, result); } 

RunnableAdapter完成实际的适配工作:

static final class RunnableAdapter<T> implements Callable<T> {     final Runnable task;     final T result;     RunnableAdapter(Runnable task, T result) {         this.task = task;         this.result = result;     }     public T call() {         task.run();         return result;     } } 

通过RunnableAdapter实例调用Callable#call()方法时,RunnableAdapter仅仅先调用Runnable#run(),再返回result。框架并没有什么地方会操作result——换句话说,这个适配器仅仅是让Runable实例能够被提交到ExecutorService中,与返回值并没有半分钱的关系

对,就是这么没用,但是用来讲适配器还是阔以的。

总结

通过AbstractExecutorService#newTaskFor()学习工厂方法模式,通过Executors.callable()学习适配器模式——嗯,,,虽然这个适配器没什么用。

另外,注意到AbstractExecutorService#newTaskFor()的访问权限为protected,我们可以在扩展类中覆写或直接使用该方法。如ForkJoinPool:

protected <T> RunnableFuture<T> newTaskFor(Runnable runnable, T value) {    return new ForkJoinTask.AdaptedRunnable<T>(runnable, value); } protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable) {    return new ForkJoinTask.AdaptedCallable<T>(callable); } 

适配器走起。


本文链接:源码|newTaskFor()和适配器模式
作者:猴子007
出处:https://monkeysayhi.github.io
本文基于 知识共享署名-相同方式共享 4.0 国际许可协议发布,欢迎转载,演绎或用于商业目的,但是必须保留本文的署名及链接。

转载本站任何文章请注明:转载至神刀安全网,谢谢神刀安全网 » 源码|newTaskFor()和适配器模式

分享到:更多 ()

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址