13.ThreadPoolExecutor线程池之submit方法

jdk1.7.0_79 

  在上一篇《ThreadPoolExecutor线程池原理及其execute方法》中提到了线程池ThreadPoolExecutor的原理以及它的execute方法。本文解析ThreadPoolExecutor#submit。

  对于一个任务的执行有时我们不需要它返回结果,但是有我们需要它的返回执行结果。对于线程来讲,如果不需要它返回结果则实现Runnable,而如果需要执行结果的话则可以实现Callable。在线程池同样execute提供一个不需要返回结果的任务执行,而对于需要结果返回的则可调用其submit方法。

  回顾ThreadPoolExecutor的继承关系。

  

  在Executor接口中只定义了execute方法,而submit方法则是在ExecutorService接口中定义的。

  

//ExecutorService
public interface ExecutorService extends Executor {...<T> Future<T> submit(Callable<T> task);<T> Future<T> submit(Runnable task, T result);<T> Future<T> submit(Runnable task);...
}

  而在其子类AbstractExecutorService实现了submit方法。

//AbstractExecutorService
public abstract class AbstractExecutorService implements ExecutorService {...public <T> Future<T> submit(Callable<T> task) {if (task == null) throw new NullPointerException();RunnableFuture<T> ftask = newTaskFor(task);execute(ftask);return ftask;}public <T> Future<T> submit(Runnable task, T result) {if (task == null) throw new NullPointerException();RunnableFuture<T> ftask = newTaskFor(task);execute(ftask);return ftask;}public Future<?> submit(Runnable task) {if (task == null) throw new NullPointerExeption();RunnableFuture<Void> ftask = newTaskFor(task, null);execute(ftask);return ftask; }...
}

  在AbstractExecutorService实现的submit方法实际上是一个模板方法,定义了submit方法的算法骨架,其execute交给了子类。(可以看到在很多源码中,模板方法模式被大量运用,有关模板方法模式可参考《模板方法模式》)

  尽管submit方法能提供线程执行的返回值,但只有实现了Callable才会有返回值,而实现Runnable的线程则是没有返回值的,也就是说在上面的3个方法中,submit(Callable<T> task)能获取到它的返回值,submit(Runnable task, T result)能通过传入的载体result间接获得线程的返回值或者准确来说交给线程处理一下,而最后一个方法submit(Runnable task)则是没有返回值的,就算获取它的返回值也是null。

  下面给出3个例子,来感受下submit方法。

  submit(Callable<T> task)

package com.threadpoolexecutor;import java.util.concurrent.*;/*** ThreadPoolExecutor#sumit(Callable<T> task)* Created by yulinfeng on 6/17/17.*/
public class Sumit1 {public static void main(String[] args) throws ExecutionException, InterruptedException {Callable<String> callable = new Callable<String>() {public String call() throws Exception {System.out.println("This is ThreadPoolExetor#submit(Callable<T> task) method.");return "result";}};ExecutorService executor = Executors.newSingleThreadExecutor();Future<String> future = executor.submit(callable);System.out.println(future.get());}
}

  submit(Runnable task, T result)

package com.threadpoolexecutor;import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;/*** ThreadPoolExecutor#submit(Runnable task, T result)* Created by yulinfeng on 6/17/17.*/
public class Submit2 {public static void main(String[] args) throws ExecutionException, InterruptedException {ExecutorService executor = Executors.newSingleThreadExecutor();Data data = new Data();Future<Data> future = executor.submit(new Task(data), data);System.out.println(future.get().getName());}
}class Data {String name;public String getName() {return name;}public void setName(String name) {this.name = name;}
}class Task implements Runnable {Data data;public Task(Data data) {this.data = data;}public void run() {System.out.println("This is ThreadPoolExetor#submit(Runnable task, T result) method.");data.setName("kevin");}
}

  submit(Runnable task)

package com.threadpoolexecutor;import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;/*** ThreadPoolExecutor#sumit(Runnable runnables)* Created by yulinfeng on 6/17/17.*/
public class Submit {public static void main(String[] args) throws ExecutionException, InterruptedException {Runnable runnable = new Runnable() {public void run() {System.out.println("This is ThreadPoolExetor#submit(Runnable runnable) method.");}};ExecutorService executor = Executors.newSingleThreadExecutor();Future future = executor.submit(runnable);System.out.println(future.get());}
}

  通过上面的实例可以看到在调用submit(Runnable runnable)的时候是不需要其定义类型的,也就是说虽然在ExecutorService中对其定义的是泛型方法,而在AbstractExecutorService中则不是泛型方法,因为它没有返回值。(有关Object、T、?这三者的区别,可参考《Java中的Object、T(泛型)、?区别》)。

  从上面的源码可以看到,这三者方法几乎是一样的,关键就在于:

RunnableFuture<T> ftask = newTaskFor(task);
execute(ftask);

  它是如何将一个任务作为参数传递给了newTaskFor,然后调用execute方法,最后进而返回ftask的呢?

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

  看来是返回了一个FutureTask实例,FutureTask实现了Future和Runnable接口。Future接口是Java线程Future模式的实现,可用用来异步计算,实现Runnable接口表示可以作为一个线程执行。FutureTask实现了这两个接口意味着它代表异步计算的结果,同时可以作为一个线程交给Executor来执行。有关FutureTask放到下章来单独解析。所以本文对于线程池ThreadPoolExecutor线程池的submit方法解析并不完整,必须得了解Java线程的Future模式——《14.Java中的Future模式》。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/289949.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

java idea 模块_idea 多模块项目依赖父工程class找不到问题的方法

比如&#xff0c;我们有这么个过程&#xff0c;项目结构如下&#xff1a;a--b--ca是总结点&#xff0c;b是子节点&#xff0c;c是父节点b依赖父节点class&#xff0c;通过maven构建时通常我们会在子节点中添加父节点依赖&#xff0c;如&#xff1a;com.xxxc${project.version}虽…

关于OAuth2.0 Authorization Code+PKCE flow在原生客户端(Native App)下集成的思考

Working with Proof Key for Code Exchange (PKCE) - DEV Community写在前面前几天看了园友的一篇文章被广泛使用的OAuth2.0的密码模式已经废了&#xff0c;放弃吧 被再次提起&#xff1a;Implicit Flow Password Grant&#xff0c;均已被标记为Legacy&#xff0c;且OAuth2.1里…

详细类库排行榜网址

https://github.com/search?lObjective-C&qstars%3A%3E1&refsearchresults&typeRepositories 转载于:https://www.cnblogs.com/hsxblog/p/4953572.html

贪心算法之用优先队列(priority_queue)实现哈夫曼编码问题

1、问题 参考我的博客:贪心算法之哈夫曼编码问题 2、优先队列知识复习 参考我的博客: C++之STL之priority_queue 3、代码实现 #include <iostream> #include <queue>using namespace std;//最大字符编码数组长度 #define MAXCODELEN 100 //最大哈夫曼节点结…

【经典回放】多种语言系列数据结构算法:希尔排序(C/C#版)

原理&#xff1a;每隔sp&#xff08;整数&#xff09;个数即取数并判断大小&#xff0c;交换&#xff0c;先构造局部有序序列&#xff0c;直到sp为1&#xff0c;构造完整的有序序列。 给出一组数据&#xff0c;如下&#xff1a; 0 1 2 3 4 5 6 7 8 9 49 38 65 97 …

extjs 文件加载、解析流程

extjs版本&#xff1a;4.2.1在html中添加应用的启动脚本&#xff0c;如下&#xff1a;<script src"app.js"></script>2. 用户访问html的时候&#xff0c;会去加载app.js文件&#xff0c;app中定义了应用的名字&#xff0c;根路径等信息&#xff0c;并且调…

【131天】尚学堂高淇Java300集视频精华笔记(65-66)

第65集&#xff1a;常用类Date类的使用JDk源码分析 Date时间类&#xff08;java.util.Date&#xff09; 在标准Java类库中包含一个Date类。它的对象表示一个特定的瞬间&#xff0c;精确到毫秒。 Date()分配一个Date对象&#xff0c;并初始化此对象为当前的日期和时间精确到毫秒…

ArcGIS 10.2加载在线影像底图

两种方法&#xff1a; 一、File→ArcGIS Online→影像图→Open。 二、 效果&#xff1a;

分治算法之二分搜索

1、问题 一天晚上,我们在家里看电视,某大型娱乐节目在玩猜数游戏。主持人在女嘉宾的手心上写一个 10 以内的整数,让女嘉宾的老公猜是多少,而女嘉宾只能提示大了,还是小了,并且只有 3 次机会。主持人悄悄地在美女手心写了一个 8。老公:“2。”老婆:“小了。”老公:“3…

都说不要装箱,那装箱到底带来了什么开销?

相信很有朋友在面试时大多会被问到 装箱 的问题&#xff0c;也是一个经典的问题&#xff0c;可深可浅&#xff0c;那今天我们就从 汇编 和 内存 角度进行统一解读下。为了方便演示&#xff0c;先上一段装箱的代码。class Program{static void Main(string[] args){var i 10;va…

Java中方法的继承以及父类未被子类覆盖的方法调用的问题

在看java继承这一块的时候发现了一个问题&#xff0c;即父类未被子类覆盖的方法是如何调用的&#xff1f; 是子类拥有了父类的该方法只是没有显示表示&#xff0c;还是子类调用了父类的该方法。 为此做了一下验证 代码如下&#xff1a; public class One {protected void print…

数据结构实验之栈四:括号匹配

数据结构实验之栈四&#xff1a;括号匹配 Description 给你一串字符&#xff0c;不超过50个字符&#xff0c;可能包括括号、数字、字母、标点符号、空格&#xff0c;你的任务是检查这一串字符中的( ) ,[ ],{ }是否匹配。Input 输入数据有多组&#xff0c;处理到文件结束。Outpu…

10.29 工作笔记 ndk编译C++,提示找不到头文件(ndk-build error: string: No such file or directory)...

ndk编译C。提示找不到头文件&#xff08;ndk-build error: string: No such file or directory&#xff09; 被这个问题弄得愁眉苦脸啊。心想为啥一个string都找不到呢。。于是百度到了。。。遇到这个问题&#xff0c;就在所在的文件夹 Application.mk 文件里。加入&…

Excel VBA编程基础

一、程序基本调试方法 1、VB程序的三种状态:设计时、运行时和中断模式。 2、但不执行代码,快捷键为F8。 3、中断程序的方法: (1)使用断点 (2)使用Debug.Assert (3)使用监视条件 二、Excel Shape对象

分治算法之合并排序

1、问题 合并排序法是将两个(或两个以上)有序表合并成一个新的有序表,即把待排序序列分为若干个子序列,每个子序列是有序的。然后再把有序子序列合并为整体有序序列 2、思路 1、分解:将待排序元素分成大小大致相同的两个子序列 2、治理:对两个子序列进行合并排序 3、…

WPF 实现截屏控件之移动(二)(仿微信)

WPF开发者QQ群此群已满340500857 &#xff0c;请加新群458041663由于微信群人数太多入群请添加小编微信号yanjinhuawechat 或 W_Feng_aiQ 邀请入群需备注WPF开发者 接着上一篇&#xff0c;兼容屏幕缩放问题。01—代码如下一、创建ScreenCut.xaml代码如下。<ResourceDictiona…

构造不可变类及其优点

不可变类的优点 易于构造&#xff0c;测试和使用天然线程安全&#xff0c;没有同步问题不需要实现clone方法引用不可变类的实例时&#xff0c;不需要考虑实例的值发生变化的情况如何构造不可变类 不声明“setter”方法。所有属性设为private final。class声明为final&#xff0…

深入剖析阿里云推荐引擎——新架构,新体验

摘要&#xff1a;本文的整理自2017云栖大会-上海峰会上阿里云算法专家郑重&#xff08;卢梭&#xff09;的分享讲义&#xff0c;从2016年2月V2.0公开使用到现在&#xff0c;阿里云推荐引擎有了更大的进步。有着获取排序的在线计算&#xff0c;修正匹配的近线计算及匹配排序的离…

分治算法之快速排序

1、快速排序 通过一趟排序将要排序的数据分割成独立的两部分,其中一部分的所有数据都比另外一部分的所有数据都要小,然后再按此方法对这两部分数据分别进行快速排序 2、思路 ( 1 )分解:先从数列中取出一个元素作为基准元素。以基准元素为标准,将问题分解为两个子序列,使小于…

java程序结构_java程序结构

java是一门面向对象的语言&#xff0c;在编程过程中当然离不开对象的声明&#xff0c;而对象又是通过类定义的&#xff0c;所以java中最重要的就是各式各样的类&#xff0c;在java中&#xff0c;类也是一个程序的基本单位0x01&#xff1a;默认生成类在eclipse中创建好一个java类…