文档章节

Java并发编程高级篇(九):在线程之行结束后再做些什么

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

如果我们想要在线程执行结束后做一些事情,比如生成报表,发送通知邮件或者释放一些系统资源,FutureTask类给于我们最好的支持。

想要实现这种控制方式,我们不能直接把Callable<?>对象直接提交到线程执行器中运行,而是要借助FutureTask类,把需要执行的线程类发送给FutureTask对象,然后把FutureTask类发送给执行器去执行。

首先创建线程类,实现Callable接口(不能使用Runnable)。休眠一个随机时间来模拟线程执行过程。

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

/**
 * 创建一个雷ExecutableTask实现Callable<String>接口。
 *
 * 延迟一定是坚守执行
 *
 * Created by hadoop on 2016/11/3.
 */
public class ExecutableTask implements Callable<String> {
    private String name;

    public ExecutableTask(String name) {
        this.name = name;
    }

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

        System.out.printf("Task: %s will delay %d \n", name, duration);

        TimeUnit.SECONDS.sleep(duration);

        return "Hello, I am " + name;
    }

    public String getName() {
        return name;
    }
}

接下来我们继承FutureTask类实现自己的ResultTask类,并重写done方法。在done方法中即可定义任务执行完毕的处理逻辑,在这里我们打印线程的一些状态。

import java.util.concurrent.Callable;
import java.util.concurrent.FutureTask;

/**
 * 创建类ResultTask继承FutureTask<String>类
 *
 * 重写done()方法:打印任务isCancelled()状态还是完成状态。
 *
 * Created by hadoop on 2016/11/3.
 */
public class ResultTask extends FutureTask<String> {
    private String name;

    public ResultTask(Callable<String> callable) {
        super(callable);
        this.name = ((ExecutableTask)callable).getName();
    }

    @Override
    protected void done() {
        if (isCancelled()) {
            System.out.printf("%s: Has been canceled.\n", name);
        } else {
            System.out.printf("%s: Has been finished.\n", name);
        }
    }
}

在主线程类中,我们创建5个线程任务,因为FutureTask实现了Runnable接口,所以可以直接提交到执行器去运行。主线程休眠5s,然后以此取消5个线程。最后打印已经执行完成的任务的信息。

import java.util.concurrent.ExecutionException;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * Created by hadoop on 2016/11/3.
 *
 * 在任务结束的时候FutureTask类就会调用done()方法。
 *
 * 创建一个实现Callable接口的ExecutableTask类
 * 创建一个阶乘FutureTask类的ResultTask类
 *
 * 然后我们就可以在done方法啊中做出一些资源释放之类的工作了
 *
 */
public class Main {
    public static void main(String[] args) throws InterruptedException, ExecutionException {
        ThreadPoolExecutor executor = (ThreadPoolExecutor)Executors.newCachedThreadPool();

        ResultTask[] tasks = new ResultTask[5];

        for (int i = 0; i < 5; i++) {
            ExecutableTask task = new ExecutableTask("Task" + String.valueOf(i));
            tasks[i] = new ResultTask(task);
            executor.submit(tasks[i]);
        }

        TimeUnit.SECONDS.sleep(5);

        for (int i = 0; i < 5; i++) {
            tasks[i].cancel(true);
        }

        for (int i = 0; i < 5; i++) {
            if (!tasks[i].isCancelled()) {
                System.out.println(tasks[i].get());
            }
        }

        executor.shutdown();
    }
}

控制台中你可以看到,每个线程的休眠时间,以及线程结束时的状态。还有执行完成线程的信息。

Task: Task0 will delay 3 
Task: Task4 will delay 1 
Task: Task3 will delay 5 
Task: Task2 will delay 8 
Task: Task1 will delay 0 
Task1: Has been finished.
Task4: Has been finished.
Task0: Has been finished.
Task2: Has been canceled.
Task3: Has been canceled.
Hello, I am Task0
Hello, I am Task1
Hello, I am Task4

© 著作权归作者所有

阿拉德大陆的魔法师
粉丝 27
博文 91
码字总数 83019
作品 0
西城
程序员
私信 提问
Java面试:投行的15个多线程和并发面试题

本文由ImportNew -一杯哈希不加盐 翻译自dzone。欢迎加入翻译小组。转载请见文末要求。 多线程和并发问题已成为各种 Java 面试中必不可少的一部分。如果你准备参加投行的 Java 开发岗位面试,...

ImportNew
2018/08/23
0
0
Java线程面试题 Top 50

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

loda0128
2015/05/29
964
1
Java 编程之美:并发编程基础晋级篇

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

gitchat
2018/04/18
0
0
JAVA多线程和并发基础面试问答

多线程和并发问题是Java技术面试中面试官比较喜欢问的问题之一。在这里,从面试的角度列出了大部分重要的问题,但是你仍然应该牢固的掌握Java多线程基础知识来对应日后碰到的问题。(校对注:...

LCZ777
2014/05/26
189
0
JAVA多线程和并发基础面试问答

Java多线程面试问题 1. 进程和线程之间有什么不同? 一个进程是一个独立(self contained)的运行环境,它可以被看作一个程序或者一个应用。而线程是在进程中执行的一个任务。Java运行环境是一...

hanzhankang
2014/01/20
141
0

没有更多内容

加载失败,请刷新页面

加载更多

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

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

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

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

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

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

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

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

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

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

tan日拱一兵
57分钟前
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部