文档章节

Java并发编程高级篇(十):分离任务的执行和结果的处理

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

在之前的例子中,我们使用执行器框架都是在主类中提交任务,等待任务执行完毕后再去处理任务执行的结果。接下来我们打算将任务的提交和结果的处理都放置到线程中去执行。在每个任务内部提交自己到执行器,然后通过一个统一的结果处理线程来处理所有任务执行的结果。

为了解决这个问题,执行器框架为我们提供了一个CompletionService类,任务执行线程和结果处理线程能够共享这个类,结果处理线程便可以在这里渠道已经执行完毕的任务的结果。CompletionService类的内部也是通过一个ExecutorService来提交任务的。

首先,创建任务线程,实现Callable接口。模拟报表生成过程。

/**
 * 模拟生成报告
 *
 * Created by hadoop on 2016/11/3.
 */
public class ReportGenerator implements Callable<String> {
    private String sender;
    private String title;

    public ReportGenerator(String sender, String title) {
        this.sender = sender;
        this.title = title;
    }

    @Override
    public String call() throws Exception {
        long duration = (long)(Math.random() * 10);

        System.out.printf("ReportGenerator: Generator report %s_%s duration %d seconds.\n", sender, title, duration);

        TimeUnit.SECONDS.sleep(duration);

        return sender + "_" + title;
    }
}

然后我们创建任务提交线程,这个线程的构造方法接受两个参数,分别是报表名称和CompletionService对象。将报表生成任务提交到CompletionService去执行。

import java.util.concurrent.CompletionService;

/**
 * 模拟请求获取报告
 *
 * Created by hadoop on 2016/11/3.
 */
public class ReportRequest implements Runnable {
    private String name;
    private CompletionService<String> service;

    public ReportRequest(String name, CompletionService<String> service) {
        this.name = name;
        this.service = service;
    }

    @Override
    public void run() {
        ReportGenerator generator = new ReportGenerator(name, "Report");
        service.submit(generator);
    }
}

下面我们创建任务结果处理类,来打印生成的报表。这个类同样会拿到CompletionService的引用,然后循环调用CompletionService.poll()方法来从任务结果队列中获取执行的结果,这个方法接受一个时间参数,如果当前结果队列为空,那么则等待这个时间,超时返回null。不带参数的poll()方法,如果对别为空则直接返回null。

/**
 * 处理报表结果
 *
 * Created by hadoop on 2016/11/3.
 */
public class ReportProcessor implements Runnable {
    private boolean end;
    private CompletionService<String> service;

    public ReportProcessor(boolean end, CompletionService<String> service) {
        this.end = end;
        this.service = service;
    }

    @Override
    public void run() {
        while (!end) {
            try {
                Future<String> future = service.poll(20, TimeUnit.SECONDS);

                if (future != null) {
                    System.out.printf("ReportReceiver: received %s\n", future.get());
                }

            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (ExecutionException e) {
                e.printStackTrace();
            }
        }
    }

    public void setEnd(boolean end) {
        this.end = end;
    }
}

最后我们创建主方法类。在这里我们创建ExecutorServer并把它赋值给ExecutorCompletionService。之后创建两个报表请求任务和一个报表处理任务,同时持有ExecutorCompletionService的引用。

import java.util.concurrent.CompletionService;
import java.util.concurrent.ExecutorCompletionService;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

/**
 * 在执行器中分离任务执行和结果处理
 *
 * 我们如何处理在一个对象里发送任务给执行器,在另一个对象里处理任务执行结果。
 * 对于这种情况Java API提供了CompletionService类
 *
 * CompletionService使用Executor对象类执行任务。
 *   优势在于:可以共享CompletionService。
 *   缺点在于:CompletionService获取的Future对象只能是已经执行完毕的任务,他没有办法控制任务状态,只能处理任务结果。
 *
 * 我们创建了一个ExecutorService,然后使用这个ExecutorService来初始化一个ExecutorCompletionService<String>(executor)。
 *
 * 首先创建了两个ReportRequest任务,然后在任务内部使用service.submit(generator)方法调用报表生成任务。
 *
 * 然后再ReportProcessor中不断调用service.poll(20, TimeUnit.SECONDS);方法获取已经执行完的结果,如果当前没有结果那么等待20秒。
 *
 * CompletionService还提供了两个人方法:
 *   poll():如果没有任何Future直接返回null。
 *   take():如若任务队列中没有Future那么阻塞知道有可用的Future。
 *
 * Created by hadoop on 2016/11/3.
 */
public class Main {
    public static void main(String[] args) {
        ExecutorService executor = Executors.newCachedThreadPool();

        CompletionService<String> service = new ExecutorCompletionService<String>(executor);

        ReportRequest request1 = new ReportRequest("Face", service);
        ReportRequest request2 = new ReportRequest("Online", service);

        ReportProcessor processor = new ReportProcessor(false, service);

        Thread thread1 = new Thread(request1);
        Thread thread2 = new Thread(request2);
        Thread thread3 = new Thread(processor);

        thread1.start();
        thread2.start();
        thread3.start();

        try {
            thread1.join();
            thread2.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        executor.shutdown();

        try {
            executor.awaitTermination(1, TimeUnit.SECONDS);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        try {
            TimeUnit.SECONDS.sleep(10);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        processor.setEnd(true);
    }
}

控制台中,我们可以看到两个任务的提交信息和结果处理信息。

ReportGenerator: Generator report Online_Report duration 4 seconds.
ReportGenerator: Generator report Face_Report duration 1 seconds.
ReportReceiver: received Face_Report
ReportReceiver: received Online_Report

© 著作权归作者所有

阿拉德大陆的魔法师
粉丝 27
博文 91
码字总数 83019
作品 0
西城
程序员
私信 提问
读书笔记之《Java并发编程的艺术》-线程池和Executor的子孙们

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

Hi徐敏
2015/11/11
733
1
Java线程面试题 Top 50

不管你是新程序员还是老手,你一定在面试中遇到过有关线程的问题。Java语言一个重要的特点就是内置了对并发的支持,让Java大受企业和程序员的欢迎。大多数待遇丰厚的Java开发职位都要求开发者...

loda0128
2015/05/29
964
1
读书笔记之《Java并发编程的艺术》-并发编程容器和框架(重要)

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

Hi徐敏
2015/11/11
685
1
安卓中高级开发工程师面试之——面试永远逃不掉的Java线程面试题

不管你是Java工程师还是安卓开发工程师,只要你是计算机开发工程师,你一定在面试中遇到过有关线程的问题。Java语言一个重要的特点就是内置了对并发的支持,让Java大受企业和程序员的欢迎。大...

小饼干的梦
2018/10/12
0
0
Java 编程之美:并发编程基础晋级篇

本文来自作者 加多 在 GitChat 上分享 「Java 并发编程之美:并发编程基础晋级篇」 编辑 | Mc Jin 借用 Java 并发编程实践中的话,编写正确的程序并不容易,而编写正常的并发程序就更难了! ...

gitchat
2018/04/18
0
0

没有更多内容

加载失败,请刷新页面

加载更多

手写RPC框架指北另送贴心注释代码一套

Angular8正式发布了,Java13再过几个月也要发布了,技术迭代这么快,框架的复杂度越来越大,但是原理是基本不变的。所以沉下心看清代码本质很重要,这次给大家带来的是手写RPC框架。 完整代码...

全菜工程师小辉
11分钟前
2
0
【Java】开发收货

简介 谨以此篇,记载开发过程中的一些tips。 编译器 【Shift + F6】可实现变量的联动修改。

Areya
28分钟前
5
0
DOM官方定义

DOM Document Object Model 文档对象模型 DOM的官方定义:W3C的DOM,可以使程序或者脚本(JS或AS\JScript),动态的访问或者操作文档的内容、结构、样式。 DOM只是一个标准,操作网页的标准。...

前端老手
33分钟前
6
0
IT兄弟连 HTML5教程 HTML5的学习线路图 第一阶段学习网页制作

学习HTML5技术可并不是简单学会几个新增的标签而已,HTML5现在可以说是前端所有技术的代名词。需要学习的语言和工具不仅多,对于刚接触他们的新人会感觉很乱。另外,前端开发也会细分很多个开...

老码农的一亩三分地
35分钟前
6
0
可见性有序性,Happens-before来搞定

写在前面 上一篇文章并发 Bug 之源有三,请睁大眼睛看清它们 谈到了可见性/原子性/有序性三个问题,这些问题通常违背我们的直觉和思考模式,也就导致了很多并发 Bug 为了解决 CPU,内存,IO ...

tan日拱一兵
50分钟前
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部