定制并发类(五)在一个Executor对象中使用我们的ThreadFactory
2016-06-01 09:25
363 查看
声明:本文是《 Java 7 Concurrency Cookbook 》的第七章,作者: Javier Fernández González 译者:许巧辉
在一个Executor对象中使用我们的ThreadFactory
在前面的指南中,实现ThreadFactory接口生成自定义线程,我们引进了工厂模式和提供如何实现一个实现ThreadFactory接口的线程的工厂例子。
执行者框架(Executor framework)是一种机制,它允许你将线程的创建与执行分离。它是基于Executor、ExecutorService接口和实现这两个接口的ThreadPoolExecutor类。它有一个内部的线程池和提供一些方法,这些方法允许你提交两种任务给线程池执行。这两种任务是:
实现Runnable接口的类,用来实现没有返回结果的任务
实现Callable接口的类,用来实现有返回结果的任务
在执行者框架(Executor framework)的内部,它提供一个ThreadFactory接口来创建线程,这是用来产生新的线程。在这个指南中,你将学习如何实现你自己的线程类,用一个工厂来创建这个类的线程,及如何在执行者中使用这个工厂,所以这个执行者将执行你的线程。
准备工作…
阅读之前的指南,实现ThreadFactory接口生成自定义线程,并实现它的例子。
这个指南的例子使用Eclipse IDE实现。如果你使用Eclipse或其他IDE,如NetBeans,打开它并创建一个新的Java项目。
如何做…
按以下步骤来实现的这个例子:
1.将实现ThreadFactory接口生成自定义线程的指南中实现的MyThread、MyThreadFactory和MyTask类复制到这个项目中,所以你将在这个例子中继续使用它们。
2.实现这个例子的主类,通过创建Main类,并实现mian()方法。
3.创建一个新的MyThreadFactory对象,名为threadFactory。
4.使用Executors类的newCachedThreadPool()方法,创建一个新的Executor对象。传入前面创建的工厂对象作为参数。这个新的Executor对象将使用这个工厂创建必需的线程,所以它将执行MyThread线程。
5.创建一个新的Task对象,并使用submit()方法将它提交给执行者。
6.使用shutdown()方法关闭这个执行者。
7.使用awaitTermination()方法,等待执行者的结束。
8.写入一条信息表明程序的结束。
它是如何工作的…
在前面指南(实现ThreadFactory接口生成自定义线程)中的它是如何工作的部分中,你可以阅读到关于MyThread、MyThreadFactory和MyTask工作的详细解释。
在这个例子的main()方法中,你已使用Executors类的newCachedThreadPool()方法创建一个Executor对象。你已传入之前创建的工厂对象作为参数,所以已创建的Executor对象将使用这个工厂来创建它所需的线程,并且它将执行MyThread类的线程。
执行这个程序,你将看到关于线程的开始日期和它的执行时间的信息。以下截图显示了这个例子产生的输出:
原文地址:http://ifeve.com/customizing-concurrency-classes-5/
在一个Executor对象中使用我们的ThreadFactory
在前面的指南中,实现ThreadFactory接口生成自定义线程,我们引进了工厂模式和提供如何实现一个实现ThreadFactory接口的线程的工厂例子。
执行者框架(Executor framework)是一种机制,它允许你将线程的创建与执行分离。它是基于Executor、ExecutorService接口和实现这两个接口的ThreadPoolExecutor类。它有一个内部的线程池和提供一些方法,这些方法允许你提交两种任务给线程池执行。这两种任务是:
实现Runnable接口的类,用来实现没有返回结果的任务
实现Callable接口的类,用来实现有返回结果的任务
在执行者框架(Executor framework)的内部,它提供一个ThreadFactory接口来创建线程,这是用来产生新的线程。在这个指南中,你将学习如何实现你自己的线程类,用一个工厂来创建这个类的线程,及如何在执行者中使用这个工厂,所以这个执行者将执行你的线程。
准备工作…
阅读之前的指南,实现ThreadFactory接口生成自定义线程,并实现它的例子。
这个指南的例子使用Eclipse IDE实现。如果你使用Eclipse或其他IDE,如NetBeans,打开它并创建一个新的Java项目。
如何做…
按以下步骤来实现的这个例子:
1.将实现ThreadFactory接口生成自定义线程的指南中实现的MyThread、MyThreadFactory和MyTask类复制到这个项目中,所以你将在这个例子中继续使用它们。
2.实现这个例子的主类,通过创建Main类,并实现mian()方法。
1 | public class Main { |
2 | public static void main(String[] args) throws Exception { |
1 | MyThreadFactory threadFactory= new MyThreadFactory( "MyThreadFactory" ); |
1 | ExecutorService executor=Executors.newCachedThreadPool(threadFactory); |
1 | MyTask task= new MyTask(); |
2 | executor.submit(task); |
1 | executor.shutdown(); |
1 | executor.awaitTermination( 1 , TimeUnit.DAYS); |
1 | System.out.printf( "Main: End of the program.\n" ); |
在前面指南(实现ThreadFactory接口生成自定义线程)中的它是如何工作的部分中,你可以阅读到关于MyThread、MyThreadFactory和MyTask工作的详细解释。
在这个例子的main()方法中,你已使用Executors类的newCachedThreadPool()方法创建一个Executor对象。你已传入之前创建的工厂对象作为参数,所以已创建的Executor对象将使用这个工厂来创建它所需的线程,并且它将执行MyThread类的线程。
执行这个程序,你将看到关于线程的开始日期和它的执行时间的信息。以下截图显示了这个例子产生的输出:
原文地址:http://ifeve.com/customizing-concurrency-classes-5/
相关文章推荐
- 探究在C++程序并发时保护共享数据的问题
- 在ASP.NET 2.0中操作数据之四十八:对SqlDataSource控件使用开放式并发
- 在ASP.NET 2.0中操作数据之二十一:实现开放式并发
- Nodejs实战心得之eventproxy模块控制并发
- 并发环境下mysql插入检查方案
- PHP编程中尝试程序并发的几种方式总结
- 浅析PHP中Session可能会引起并发问题
- php session的锁和并发
- Oracle 数据库针对表主键列并发导致行级锁简单演示
- MySQL中SELECT+UPDATE处理并发更新问题解决方案分享
- Java并发编程中的生产者与消费者模型简述
- Java中同步与并发用法分析
- Java多线程编程中的两种常用并发容器讲解
- Java实现的并发任务处理实例
- Java线程并发中常见的锁机制详细介绍
- Go语言并发模型的2种编程方案
- Go语言并发技术详解
- JAVA多线程与并发学习总结分析
- JAVA多线程和并发基础面试问答(翻译)
- 在Java内存模型中测试并发程序代码