博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
线程执行者(四)执行者执行返回结果的任务
阅读量:6206 次
发布时间:2019-06-21

本文共 3624 字,大约阅读时间需要 12 分钟。

执行者执行返回结果的任务

Executor framework的一个优点是你可以并发执行返回结果的任务。Java并发API使用以下两种接口来实现:

  • Callable:此接口有一个call()方法。在这个方法中,你必须实现任务的(处理)逻辑。Callable接口是一个参数化的接口。意味着你必须表明call()方法返回的数据类型。
  • Future:此接口有一些方法来保证Callable对象结果的获取和管理它的状态。

在这个指南中,你将学习如何实现返回结果的任务,并在执行者中运行它们。

准备工作…

这个指南的例子使用Eclipse IDE实现。如果你使用Eclipse或其他IDE,如NetBeans,打开它并创建一个新的Java项目。

如何做…

按以下步骤来实现的这个例子:

1.创建FactorialCalculator类,指定它实现Callable接口,并参数化为Integer类型。

public class FactorialCalculator implements Callable
{

2.声明一个私有的,类型为Integer,名为number的属性,用来存储任务将要计算出的数。

private Integer number;

3.实现FactorialCalculator构造器,初始化这个属性。

public FactorialCalculator(Integer number){this.number=number;}

4.实现call()方法。这个方法将返回FactorialCalculator的number属性的阶乘。

@Overridepublic Integer call() throws Exception {

5.首先,创建和初始化在这个方法中使用的局部变量。

int result = 1;

6.如果数是1或0,则返回1。否则,计算这个数的阶乘。出于教学目的,在两次乘之间,令这个任务睡眠20毫秒。

if ((num==0)||(num==1)) {result=1;} else {for (int i=2; i<=number; i++) {result*=i;TimeUnit.MILLISECONDS.sleep(20);}}

7.操作结果的信息写入控制台。

System.out.printf("%s: %d\n",Thread.currentThread().getName(),result);

8.返回操作结果。

return result;

9.实现这个示例的主类,创建Main类,实现main()方法。

public class Main {public static void main(String[] args) {

10.使用Executors类的newFixedThreadPool()方法创建ThreadPoolExecutor来运行任务。传入参数2。

ThreadPoolExecutor executor=(ThreadPoolExecutor)Executors.newFixedThreadPool(2);

11.创建Future<Integer>对象的数列。

List
> resultList=new ArrayList<>();

12.创建Random类产生的随机数。

Random random=new Random();

13.生成0到10之间的10个随机数。

for (int i=0; i<10; i++){Integer number= random.nextInt(10);

14.创建一个FactorialCaculator对象,传入随机数作为参数。

FactorialCalculator calculator=new FactorialCalculator(number);

15.调用执行者的submit()方法来提交FactorialCalculator任务给执行者。这个方法返回Future<Integer>对象来管理任务,并且最终获取它的结果。

Future
result=executor.submit(calculator);

16.添加Future对象到之前创建的数列。

resultList.add(result);}

17.创建一个do循环来监控执行者的状态。

do {

18.首先,写入信息到控制台,表明使用执行者的getCompletedTaskNumber()方法获得的已完成的任务数。

System.out.printf("Main: Number of Completed Tasks:%d\n",executor.getCompletedTaskCount());

19.然后,对于数列中的10个Future对象,使用isDone()方法,将信息写入(到控制台)表明它们所管理的任务是否已经完成

for (int i=0; i
result=resultList.get(i);System.out.printf("Main: Task %d: %s\n",i,result.isDone());}

20.令这个线程睡眠50毫秒

try {TimeUnit.MILLISECONDS.sleep(50);} catch (InterruptedException e) {e.printStackTrace();}

21.如果执行者中的已完成任务数小于10,重复这个循环。

} while (executor.getCompletedTaskCount()

22.将获得的每个任务的结果写入控制台。对于每个Future对象,通过它的任务使用get()方法获取返回的Integer对象。

System.out.printf("Main: Results\n");for (int i=0; i
result=resultList.get(i);Integer number=null;try {number=result.get();} catch (InterruptedException e) {e.printStackTrace();} catch (ExecutionException e) {e.printStackTrace();}

23.然后,在控制台打印这个数。

System.out.printf("Main: Task %d: %d\n",i,number);}

24.最后,调用执行者的shutdown()方法来结束这个执行者。

executor.shutdown();

它是如何工作的…

在这个指南中,你已经学习了如何使用Callable接口来启动返回结果的并发任务。你已经使用FactorialCalculator类实现了Callable接口,并参数化为Integer类型作为结果类型。因此,Integer就作为call()方法的返回类型。

Main类是这个示例的另一个关键点。它使用submit()方法提交一个Callable对象给执行者执行。这个方法接收Callable对象参数,并且返回一个Future对象,你可以以这两个目标来使用它:

  • 你可以控制任务的状态:你可以取消任务,检查任务是否已经完成。基于这个目的,你已经使用isDone()方法来检查任务是否已经完成。
  • 你 可以获取call()方法返回的结果。基于这个目的,你已经使用了get()方法。这个方法会等待,直到Callable对象完成call()方法的执 行,并且返回它的结果。如果线程在get()方法上等待结果时被中断,它将抛出InterruptedException异常。如果call()方法抛出 异常,这个方法会抛出ExecutionException异常。

不止这些…

当你调用Future对象的get()方法,并且这个对象控制的任务未完成,这个方法会阻塞直到任务完成。Future接口提供其他版本的get()方法:

  • get(long timeout, TimeUnit unit):这个版本的get方法,如果任务的结果不可用,等待它在指定的时间内。如果时间超时,并且结果不可用,这个方法返回null值。 TimeUnit类是个枚举类,有如下常量:DAYS,HOURS,MICROSECONDS, MILLISECONDS, MINUTES,,NANOSECONDS 和SECONDS。

参见

  • 在第4章,线程执行者中的创建线程执行者指南
  • 在第4章,线程执行者中的运行多个任务并处理第一个结果指南
  • 在第4章,线程执行者中的运行多个任务并处理所有结果指南

转载地址:http://rhhca.baihongyu.com/

你可能感兴趣的文章
gitlab 2.7版本升级到2.8
查看>>
linux用户空间和内核exit的语义--linux没有线程
查看>>
乱花渐欲迷人眼-杜绝设计的视噪
查看>>
获取Extjs文本域中的内容
查看>>
RHEL 5基础篇—常见系统启动类故障
查看>>
对‘初学者应该选择哪种编程语言’的回答——计算机达人成长之路(38)
查看>>
Redis-3.2主从复制与集群搭建 推荐
查看>>
随便说说:在ASP.NET应用程序中上传文件
查看>>
【jQuery Demo】图片由下至上逐渐显示
查看>>
在.NET中使用SMTP发送邮件
查看>>
Unity Camera的两种模式
查看>>
3.5. Ticket
查看>>
越狱第一至五季/全集迅雷下载
查看>>
从Mysql slave system lock延迟说开去
查看>>
归并排序
查看>>
RecyclerView的下拉刷新和加载更多 动画
查看>>
ABAP常见面试问题
查看>>
程序猿是如何解决SQLServer占CPU100%的
查看>>
web.xml
查看>>
HBase-1.2.4LruBlockCache实现分析(一)
查看>>