ExecutorService中submit和execute的区别
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/**
* Created by IntelliJ IDEA.
*
* @author leizhimin 2008-11-25 14:28:59
*/
publicclass TestCachedThreadPool {
publicstaticvoid main(String[] args) {
// ExecutorService executorService = Executors.newCachedThreadPool();
ExecutorService executorService = Executors.newFixedThreadPool(5);
for (int i = 0; i < 5; i++) {
executorService.execute(new TestRunnable());
System.out.println("************* a" + i + " *************");
}
executorService.shutdown();
}
}
class TestRunnable implements Runnable {
publicvoid run() {
System.out.println(Thread.currentThread().getName() + "线程被调用了。");
while (true) {
try {
Thread.sleep(5000);
System.out.println(Thread.currentThread().getName());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
************* a1 *************
pool-1-thread-2线程被调用了。
************* a2 *************
pool-1-thread-3线程被调用了。
pool-1-thread-1线程被调用了。
************* a3 *************
************* a4 *************
pool-1-thread-4线程被调用了。
pool-1-thread-5线程被调用了。
pool-1-thread-2
pool-1-thread-1
pool-1-thread-3
pool-1-thread-5
pool-1-thread-4
pool-1-thread-2
pool-1-thread-1
pool-1-thread-3
pool-1-thread-5
pool-1-thread-4
......
import java.util.ArrayList; import java.util.List; import java.util.concurrent.*; /** * Callable接口测试 * * @author leizhimin 2008-11-26 9:20:13 */ publicclass CallableDemo { publicstaticvoid main(String[] args) { ExecutorService executorService = Executors.newCachedThreadPool(); List<Future<String>> resultList = new ArrayList<Future<String>>(); //创建10个任务并执行 for (int i = 0; i < 10; i++) { //使用ExecutorService执行Callable类型的任务,并将结果保存在future变量中 Future<String> future = executorService.submit(new TaskWithResult(i)); //将任务执行结果存储到List中 resultList.add(future); } //遍历任务的结果 for (Future<String> fs : resultList) { try { System.out.println(fs.get()); //打印各个线程(任务)执行的结果 } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } finally { //启动一次顺序关闭,执行以前提交的任务,但不接受新任务。如果已经关闭,则调用没有其他作用。 executorService.shutdown(); } } } } class TaskWithResult implements Callable<String> { privateint id; public TaskWithResult(int id) { this.id = id; } /** * 任务的具体过程,一旦任务传给ExecutorService的submit方法,则该方法自动在一个线程上执行。 * * @return * @throws Exception */ public String call() throws Exception { System.out.println("call()方法被自动调用,干活!!! " + Thread.currentThread().getName()); //一个模拟耗时的操作 for (int i = 999999; i > 0; i--) ; return"call()方法被自动调用,任务的结果是:" + id + " " + Thread.currentThread().getName(); } } 运行结果: call()方法被自动调用,干活!!! pool-1-thread-1 call()方法被自动调用,干活!!! pool-1-thread-3 call()方法被自动调用,干活!!! pool-1-thread-4 call()方法被自动调用,干活!!! pool-1-thread-6 call()方法被自动调用,干活!!! pool-1-thread-2 call()方法被自动调用,干活!!! pool-1-thread-5 call()方法被自动调用,任务的结果是:0 pool-1-thread-1 call()方法被自动调用,任务的结果是:1 pool-1-thread-2 call()方法被自动调用,干活!!! pool-1-thread-2 call()方法被自动调用,干活!!! pool-1-thread-6 call()方法被自动调用,干活!!! pool-1-thread-4 call()方法被自动调用,任务的结果是:2 pool-1-thread-3 call()方法被自动调用,干活!!! pool-1-thread-3 call()方法被自动调用,任务的结果是:3 pool-1-thread-4 call()方法被自动调用,任务的结果是:4 pool-1-thread-5 call()方法被自动调用,任务的结果是:5 pool-1-thread-6 call()方法被自动调用,任务的结果是:6 pool-1-thread-2 call()方法被自动调用,任务的结果是:7 pool-1-thread-6 call()方法被自动调用,任务的结果是:8 pool-1-thread-4 call()方法被自动调用,任务的结果是:9 pool-1-thread-3 Process finished with exit code 0
因为之前一直是用的execute方法,最近有个情况需要用到submit方法,所以研究了下。
三个区别:
1、接收的参数不一样
2、submit有返回值,而execute没有
Method submit extends base method Executor.execute by creating and returning a Future that can be used to cancel execution and/or wait for completion.
用到返回值的例子,比如说我有很多个做validation的task,我希望所有的task执行完,然后每个task告诉我它的执行结果,是成功还是失败,如果是失败,原因是什么。然后我就可以把所有失败的原因综合起来发给调用者。
个人觉得cancel execution这个用处不大,很少有需要去取消执行的。
而最大的用处应该是第二点。
3、submit方便Exception处理
There is a difference when looking at exception handling. If your tasks throws an exception and if it was submitted with execute
this exception will go to the uncaught exception handler (when you don't have provided one explicitly, the default one will just print the stack trace to System.err
). If you submitted the task with submit
any thrown exception, checked or not, is then part of the task's return status. For a task that was submitted with submit
and that terminates with an exception, the Future.get
will rethrow this exception, wrapped in an ExecutionException
.
意思就是如果你在你的task里会抛出checked或者unchecked exception,而你又希望外面的调用者能够感知这些exception并做出及时的处理,那么就需要用到submit,通过捕获Future.get抛出的异常。
比如说,我有很多更新各种数据的task,我希望如果其中一个task失败,其它的task就不需要执行了。那我就需要catch Future.get抛出的异常,然后终止其它task的执行,代码如下:
51cto上有一篇非常好的文章“Java5并发学习”(http://lavasoft.blog.51cto.com/62575/115112),下面的代码是基于它之上修改的。
import java.util.ArrayList; import java.util.List; import java.util.Random; 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 ExecutorServiceTest { public static void main(String[] args) { ExecutorService executorService = Executors.newCachedThreadPool(); List<Future<String>> resultList = new ArrayList<Future<String>>(); // 创建10个任务并执行 for (int i = 0; i < 10; i++) { // 使用ExecutorService执行Callable类型的任务,并将结果保存在future变量中 Future<String> future = executorService.submit(new TaskWithResult(i)); // 将任务执行结果存储到List中 resultList.add(future); } executorService.shutdown(); // 遍历任务的结果 for (Future<String> fs : resultList) { try { System.out.println(fs.get()); // 打印各个线程(任务)执行的结果 } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { executorService.shutdownNow(); e.printStackTrace(); return; } } } } class TaskWithResult implements Callable<String> { private int id; public TaskWithResult(int id) { this.id = id; } /** * 任务的具体过程,一旦任务传给ExecutorService的submit方法,则该方法自动在一个线程上执行。 * * @return * @throws Exception */ public String call() throws Exception { System.out.println("call()方法被自动调用,干活!!! " + Thread.currentThread().getName()); if (new Random().nextBoolean()) throw new TaskException("Meet error in task." + Thread.currentThread().getName()); // 一个模拟耗时的操作 for (int i = 999999999; i > 0; i--) ; return "call()方法被自动调用,任务的结果是:" + id + " " + Thread.currentThread().getName(); } } class TaskException extends Exception { public TaskException(String message) { super(message); } }
执行的结果类似于:
- call()方法被自动调用,干活!!! pool-1-thread-1
- call()方法被自动调用,干活!!! pool-1-thread-2
- call()方法被自动调用,干活!!! pool-1-thread-3
- call()方法被自动调用,干活!!! pool-1-thread-5
- call()方法被自动调用,干活!!! pool-1-thread-7
- call()方法被自动调用,干活!!! pool-1-thread-4
- call()方法被自动调用,干活!!! pool-1-thread-6
- call()方法被自动调用,干活!!! pool-1-thread-7
- call()方法被自动调用,干活!!! pool-1-thread-5
- call()方法被自动调用,干活!!! pool-1-thread-8
- call()方法被自动调用,任务的结果是:0 pool-1-thread-1
- call()方法被自动调用,任务的结果是:1 pool-1-thread-2
- java.util.concurrent.ExecutionException: com.cicc.pts.TaskException: Meet error in task.pool-1-thread-3
- at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:222)
- at java.util.concurrent.FutureTask.get(FutureTask.java:83)
- at com.cicc.pts.ExecutorServiceTest.main(ExecutorServiceTest.java:29)
- Caused by: com.cicc.pts.TaskException: Meet error in task.pool-1-thread-3
- at com.cicc.pts.TaskWithResult.call(ExecutorServiceTest.java:57)
- at com.cicc.pts.TaskWithResult.call(ExecutorServiceTest.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)
相关推荐
操作系统实验二进程同步与互斥
Python库是一组预先编写的代码模块,旨在帮助开发者实现特定的编程任务,无需从零开始编写代码。这些库可以包括各种功能,如数学运算、文件操作、数据分析和网络编程等。Python社区提供了大量的第三方库,如NumPy、Pandas和Requests,极大地丰富了Python的应用领域,从数据科学到Web开发。Python库的丰富性是Python成为最受欢迎的编程语言之一的关键原因之一。这些库不仅为初学者提供了快速入门的途径,而且为经验丰富的开发者提供了强大的工具,以高效率、高质量地完成复杂任务。例如,Matplotlib和Seaborn库在数据可视化领域内非常受欢迎,它们提供了广泛的工具和技术,可以创建高度定制化的图表和图形,帮助数据科学家和分析师在数据探索和结果展示中更有效地传达信息。
gnn-citationS
redis命令实践
Python库是一组预先编写的代码模块,旨在帮助开发者实现特定的编程任务,无需从零开始编写代码。这些库可以包括各种功能,如数学运算、文件操作、数据分析和网络编程等。Python社区提供了大量的第三方库,如NumPy、Pandas和Requests,极大地丰富了Python的应用领域,从数据科学到Web开发。Python库的丰富性是Python成为最受欢迎的编程语言之一的关键原因之一。这些库不仅为初学者提供了快速入门的途径,而且为经验丰富的开发者提供了强大的工具,以高效率、高质量地完成复杂任务。例如,Matplotlib和Seaborn库在数据可视化领域内非常受欢迎,它们提供了广泛的工具和技术,可以创建高度定制化的图表和图形,帮助数据科学家和分析师在数据探索和结果展示中更有效地传达信息。
Web前端开发技术题库
node_exporter-0.17.0.linux-amd64.tar
Python库是一组预先编写的代码模块,旨在帮助开发者实现特定的编程任务,无需从零开始编写代码。这些库可以包括各种功能,如数学运算、文件操作、数据分析和网络编程等。Python社区提供了大量的第三方库,如NumPy、Pandas和Requests,极大地丰富了Python的应用领域,从数据科学到Web开发。Python库的丰富性是Python成为最受欢迎的编程语言之一的关键原因之一。这些库不仅为初学者提供了快速入门的途径,而且为经验丰富的开发者提供了强大的工具,以高效率、高质量地完成复杂任务。例如,Matplotlib和Seaborn库在数据可视化领域内非常受欢迎,它们提供了广泛的工具和技术,可以创建高度定制化的图表和图形,帮助数据科学家和分析师在数据探索和结果展示中更有效地传达信息。
根据日志中的sql及入参自动拼接成完整的可执行sql,简单方便,无需安装,直接使用
股价数据
基于springboot+微信小程序的商城系统 开发环境: springboot+Idea+jdk1.8+ 数据库: mysql 是否使用maven: 使用 购物系统设计的设计主要是对系统所要实现的功能进行详细考虑,确定所要实现的功能后进行界面的设计,在这中间还要考虑如何可以更好的将功能及页面进行很好的结合,方便用户可以很容易明了的找到自己所需要的信息,还有系统平台后期的可操作性,通过对信息内容的详细了解进行技术的开发。
Python库是一组预先编写的代码模块,旨在帮助开发者实现特定的编程任务,无需从零开始编写代码。这些库可以包括各种功能,如数学运算、文件操作、数据分析和网络编程等。Python社区提供了大量的第三方库,如NumPy、Pandas和Requests,极大地丰富了Python的应用领域,从数据科学到Web开发。Python库的丰富性是Python成为最受欢迎的编程语言之一的关键原因之一。这些库不仅为初学者提供了快速入门的途径,而且为经验丰富的开发者提供了强大的工具,以高效率、高质量地完成复杂任务。例如,Matplotlib和Seaborn库在数据可视化领域内非常受欢迎,它们提供了广泛的工具和技术,可以创建高度定制化的图表和图形,帮助数据科学家和分析师在数据探索和结果展示中更有效地传达信息。
斯特林发动机冷却器
Python库是一组预先编写的代码模块,旨在帮助开发者实现特定的编程任务,无需从零开始编写代码。这些库可以包括各种功能,如数学运算、文件操作、数据分析和网络编程等。Python社区提供了大量的第三方库,如NumPy、Pandas和Requests,极大地丰富了Python的应用领域,从数据科学到Web开发。Python库的丰富性是Python成为最受欢迎的编程语言之一的关键原因之一。这些库不仅为初学者提供了快速入门的途径,而且为经验丰富的开发者提供了强大的工具,以高效率、高质量地完成复杂任务。例如,Matplotlib和Seaborn库在数据可视化领域内非常受欢迎,它们提供了广泛的工具和技术,可以创建高度定制化的图表和图形,帮助数据科学家和分析师在数据探索和结果展示中更有效地传达信息。
动态旅游网站-基于SSM动态旅游网上设计与实现
ASP.NET计算机科学与工程系网站毕业设计论文【ASP】
使用 Python 和 Tkinter 的基于 GUI 的图书馆管理系统源码+文档说明专为大学期间课程设计和期末大作业开发的高分设计项目,可作为高分课程设计和期末大作业的参考,含有代码注释小白也可看的懂,有能力的小伙伴也可以在此基础上进行二开,项目代码完整下载即可运行。 首先打开config.txt文件,将登录的用户密码改成你的电脑上的mysql用户名和密码。并且确保你的电脑上按照pdf实验报告中的描述建立了library数据库和三个table。 程序的入口为Gui.py,用vscode打开这个文件,右键,然后选择在终端运行python文件。如果提示说找不到bg.jpg,请尝试更换工作目录(vscode的默认工作目录通常为c:\user,而anaconda自带的spyder默认工作目录则是原文件所在文件夹。如果解决不了,可以换用spyder)。vscode更换工作目录的方法为,请在终端用cd命令,将目录修改到source文件夹。然后程序即可正常运行。如果出现了意料之外的bug,请查看终端的输出。我会用python的logging模块将异常输出到控制台。专为大学期间课程设计和期末
ASP+ACCESS动态网站设计与制作(源代码+论文+答辩PPT)【ASP】
基于ASP网络办公OA系统设计(论文+源代码+开题报告+答辩PPT)【ASP】
哈尔滨工程大学考研复试大纲