多线程 submit与execute区别
(1)可以接受的任务类型
submit:
execute:
可以看出:
execute只能接受Runnable类型的任务
submit不管是Runnable还是Callable类型的任务都可以接受,但是Runnable返回值均为void,所以使用Future的get()获得的还是null
(2)返回值
由Callable和Runnable的区别可知:
execute没有返回值
submit有返回值,所以需要返回值的时候必须使用submit
(3)异常
1.execute中抛出异常
execute中的是Runnable接口的实现,所以只能使用try、catch来捕获CheckedException,通过实现UncaughtExceptionHande接口处理UncheckedException
即和普通线程的处理方式完全一致
2.submit中抛出异常
不管提交的是Runnable还是Callable类型的任务,如果不对返回值Future调用get()方法,都会吃掉异常
先来看下Callable定义
- public interface Callable<V> {
- V call() throws Exception;
- }
其中的call能够抛出Exception异常,所以不管是CheckedException还是UncheckedException,直接抛出即可
- import java.util.concurrent.Callable;
- import java.util.concurrent.ExecutionException;
- import java.util.concurrent.ExecutorService;
- import java.util.concurrent.Executors;
- import java.util.concurrent.Future;
- public class ThreadExceptionTest {
- public static void main(String[] args) {
- ExecutorService executor = Executors.newCachedThreadPool();
- Future<Boolean> future = executor.submit(new CallableTask());
- try {
- future.get();
- } catch (InterruptedException e) {
- e.printStackTrace();
- } catch (ExecutionException e) {
- e.printStackTrace();
- }
- executor.shutdown();//必须不能忘,否则会一致卡在那里
- }
- }
- class CallableTask implements Callable<Boolean>{
- public Boolean call() throws Exception {
- // InputStream in = new FileInputStream(new File("xx.pdf"));
- int num = 3/0;
- return false;
- }
- }
结果为:
java.util.concurrent.ExecutionException: java.lang.ArithmeticException: / by zero
at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:222)
at java.util.concurrent.FutureTask.get(FutureTask.java:83)
at my.ThreadExceptionTest.main(ThreadExceptionTest.java:21)
Caused by: java.lang.ArithmeticException: / by zero
at my.CallableTask.call(ThreadExceptionTest.java:57)
at my.CallableTask.call(ThreadExceptionTest.java:1)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:619)
--------------------- 本文来自 cpf2016 的CSDN 博客 ,全文地址请点击:https://blog.csdn.net/cpf2016/article/details/50150205?utm_source=copy
最新文章
- 调用webservice进行身份验证
- svn搭建,很简单
- full_case &; parallel_case
- MySQL v5.1.72 + v5.6.19
- web前端开发框架搜集
- Dynamics CRM2013 sub grid中数据翻页问题
- django 创建admin用户名跟密码
- laravel5.7 前后端分离开发 实现基于API请求的token认证
- 第49节:Java集合框架中底层文档的List与Set
- 将mnist数据集保存成numpy格式
- 听闻 kubernetes,快速了解一番
- Websocket通信过程
- <;转载>; 22种代码味道(Martin Fowler与Kent Beck) http://blog.csdn.net/lovelion/article/details/9301691
- setTimeout(fn, 0) 的作用
- php CURL 请求头和响应头获取
- elasticsearch简单的安装以及集群配置详解
- 【ios开发之疑难杂症】xcode运行出现SpringBoard 无法启动应用程序(错误:7)
- scrapy抓取学院新闻报告
- Linux查看服务和强制结束服务
- 建立新的acticity需要的注意的问题