文档章节

Java并发编程高级篇(三):执行器中执行任务并返回结果

阿拉德大陆的魔法师
 阿拉德大陆的魔法师
发布于 2017/03/02 09:33
字数 1092
阅读 86
收藏 0

执行器框架的优质之一是可以并发地执行任务,并将任务执行结果返回。要想实现这个功能,需要JDK中的两个接口。

  • Callable:这个接口带有一个call()方法,你可以在这个方法里面实现任务执行逻辑,同时这个接口带有一个泛型参数,你可以通过这个泛型参数来指定返回结果的类型。
  • Future:这个接口生命了一些方法来获取由Callable对象产生的结果,并管理他们的状态。

创建一个类FactorialCalculator实现Callable接口,用于计算阶乘。泛型参数使用Integer来规定返回值为整型。

import java.util.concurrent.Callable;
import java.util.concurrent.TimeUnit;

/**
 * 创建一个名为FactorialCalculator类并实现Callable<Integer>接口
 *
 * 用来计算number的阶乘
 *
 * Created by hadoop on 2016/11/2.
 */
public class FactorialCalculator implements Callable<Integer> {
    private Integer number;

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

    @Override
    public Integer call() throws Exception {
        int result = 1;

        if (number > 2) {
            for (int i = 2; i <= number; i++) {
                result *= i;
            }
        }

        TimeUnit.MILLISECONDS.sleep(200);

        return result;
    }
}

然后实现Main方法,循环10次,每次产生一个随机整数,然后调用FactorialCalculator来求这个整数的阶乘。注意这里使用submit()方法来提交callable任务,因为这个方法会返回一个Future对象,而不是前面两节那样使用的是execute方法来执行Runnable。

使用Futuee对象不但可以用来获取线程任务的返回值,还可以用于获取线程执行状态。

  • isDone():用于检查任务是否执行完成。
  • get():用于获取Callable的call()方法执行的返回结果,get()方法将一直等待call()方法执行完成。如果等待过程中线程中断了,那么将抛出InterrupedException异常,如果call()方法执行异常,那么get()方法将接着抛出ExecutionException。
  • get(long timeout, TimeUnit unit):等待一段时间,如果任务没有执行完毕,那么返回null。
import java.util.ArrayList;
import java.util.List;
import java.util.Random;
import java.util.concurrent.*;

/**
 * 在执行器中执行任务并返回结果
 *
 * 执行器框架的优势之一在于可以并行执行任务,并且返回结果。Java并发API通过以下两个接口来s实现这个功能。
 * 1. Callable接口:这个借口生命了call()方法,你可以在这个方法中实现具体的处理逻辑。
 *    Callable接口带有泛型参数,这意味着call()方法可以返回该数据类型的对象。
 * 2. Future接口:这个接口用来接收Callable接口产生的结果,并管理他们的状态。
 *
 * 在本节我们学习了使用Callable接口来启动并发任务并返回结果。
 * 我么编写了FactorialCalculator类,它实现了带有泛型参数Integer的Callable接口。
 * 因此这个Integer类型将作为在调用call()方法的返回值类型。
 *
 * 另一个关键点在于Main类,在这个类中我们使用了submit()方法,发送一个Callable对象到执行器中。
 * 这个submit()方法接收Callable对象作为参数,然后返回Future对象。
 * Future对象可以用于以下两个目的。
 * 1. 控制任务的状态:可以取消或者检查任务是否完成。在这里我们使用了isDone方法来判断任务是否完成。
 * 2. 通过get()方法,接收call()方法返回的结果。这个方法一直等到call()方法执行完成并返回结果。
 *    如果get()方法在等待结果时线程中断了,将抛出一个InterruptedException。
 *    如果call()方法抛出异常,那么get方法抛出ExecutionException。
 *
 * Future对象还听了另一个future.get(1000, TimeUnit.NANOSECONDS)方法来接受返回值。
 * 如果等待(1000, TimeUnit.NANOSECONDS)时间,call()方法还没有执行结束,那么将直接返回null值。
 *
 * Created by hadoop on 2016/11/2.
 */
public class Main {
    public static void main(String[] args) throws ExecutionException, InterruptedException, TimeoutException {
        ThreadPoolExecutor executor = (ThreadPoolExecutor)Executors.newFixedThreadPool(2);

        List<Future<Integer>> futures = new ArrayList<Future<Integer>>();

        Random random = new Random();

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

            FactorialCalculator calculator = new FactorialCalculator(number);

            Future<Integer> future = executor.submit(calculator);

            futures.add(future);
        }

        do {
            //System.out.printf("Main: Number of the completed Tasks: %d\n", executor.getCompletedTaskCount());

            for (int i = 0; i < futures.size(); i++) {
                Future<Integer> future = futures.get(i);
                //System.out.printf("Main: Tasks %d: %s\n", i, future.isDone());
            }

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

        } while (executor.getCompletedTaskCount() < futures.size());

        for (int i = 0; i < futures.size(); i++) {
            Future<Integer> future = futures.get(i);
            System.out.printf("Main: Tasks %d: %d\n", i, future.get());
            //System.out.printf("Main: Tasks %d: %d\n", i, future.get(1000, TimeUnit.NANOSECONDS));
        }

        executor.shutdown();
    }
}

© 著作权归作者所有

阿拉德大陆的魔法师
粉丝 27
博文 91
码字总数 83019
作品 0
西城
程序员
私信 提问
读书笔记之《Java并发编程的艺术》-并发编程容器和框架(重要)

读书笔记部分内容来源书出版书,版权归本书作者,如有错误,请指正。 欢迎star、fork,读书笔记系列会同步更新 git https://github.com/xuminwlt/j360-jdk module j360-jdk-thread/me.j360....

Hi徐敏
2015/11/11
695
1
读书笔记之《Java并发编程的艺术》-线程池和Executor的子孙们

读书笔记部分内容来源书出版书,版权归本书作者,如有错误,请指正。 欢迎star、fork,读书笔记系列会同步更新 git https://github.com/xuminwlt/j360-jdk module j360-jdk-thread/me.j360....

Hi徐敏
2015/11/11
737
1
Java 并发:Executors 和线程池

本文译自:Java Concurrency – Part 7 : Executors and thread pools 让我们开始来从入门了解一下 Java 的并发编程。 本文主要介绍如何开始创建线程以及管理线程池,在 Java 语言中,一个最...

红薯
2010/09/15
34.2K
18
读书笔记之《Java并发编程的艺术》-并发编程基础

读书笔记部分内容来源书出版书,版权归本书作者,如有错误,请指正。 欢迎star、fork,读书笔记系列会同步更新 git https://github.com/xuminwlt/j360-jdk module j360-jdk-thread/me.j360....

Hi徐敏
2015/11/11
4K
8
Java多线程学习(八)线程池与Executor 框架

Java面试通关手册(Java学习指南,欢迎Star,会一直完善下去,欢迎建议和指导):https://github.com/Snailclimb/JavaGuide 历史优质文章推荐: Java并发编程指南专栏 分布式系统的经典基础理...

snailclimb
2018/05/31
0
0

没有更多内容

加载失败,请刷新页面

加载更多

SSH安全加强两步走

从 OpenSSH 6.2 开始已经支持 SSH 多因素认证,本文就来讲讲如何在 OpenSSH 下启用该特性。 OpenSSH 6.2 以后的版本多了一个配置项 AuthenticationMethods。该配置项可以让 OpenSSH 同时指定...

xiangyunyan
24分钟前
3
0
C或C++不是C/C++

http://www.voidcn.com/article/p-mucdruqa-ws.html

shzwork
今天
6
0
OSChina 周六乱弹 —— 如何将梳子卖给和尚

Osc乱弹歌单(2019)请戳(这里) 【今日歌曲】 @for_ :划水五分钟,专注两小时。分享Various Artists的单曲《贝多芬第8号钢琴奏鸣曲悲伤的第三乐章》: 《贝多芬第8号钢琴奏鸣曲悲伤的第三乐...

小小编辑
今天
176
8
ES5

什么是ES5:比普通js运行要求更加严格的模式 为什么:js语言本身有很多广受诟病的缺陷 如何:在当前作用域的顶部添加:"use strict" 要求: 1、禁止给未声明的变量赋值 2、静默失败升级为错误...

wytao1995
今天
7
0
c++ 内联函数调用快的原因

见图片分析

天王盖地虎626
今天
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部