文档章节

并发编程实战 1.10. 线程组处理异常 - 重写uncaughtException()

火犀牛
 火犀牛
发布于 2016/05/11 17:56
字数 535
阅读 12
收藏 0

线程组通过重写uncaughtException(Thread t, Throwable e)方法处理线程组异常。

范例: 查询文件(sleep),其中一个抛出异常,threadGroup处理异常后,全部进程都interrupt

自定义的线程组:

package com.rr.concurrent.chapter1.recipe11.test;

/**
 * Created by isaac_gu on 2016/5/11.
 */
public class MyThreadGroup extends ThreadGroup {
    public MyThreadGroup(String name) {
        super(name);
    }

    @Override
    public void uncaughtException(Thread t, Throwable e) {
        System.out.println("******************************** Exception Handler ******************************");

        System.out.printf("1. %s 线程出现了异常!\n", t.getName());
        System.out.printf("2. Exception: %s: %s\n", e.getClass().getName(), e.getMessage());
        System.out.printf("3. Stack Trace: \n");
        e.printStackTrace(System.out);
        System.out.printf("4. Thread status: %s\n", t.getState());
        System.out.println("******************************** Exception Handler END ******************************");

        //打断所有活动的线程
        interrupt();
    }
}

查找线程:

package com.rr.concurrent.chapter1.recipe11.test;

import java.util.Random;
import java.util.concurrent.TimeUnit;

/**
 * Created by isaac_gu on 2016/5/11.
 */
public class SearchTask implements Runnable {
    @Override
    public void run() {
        System.out.printf("%s 线程开始查找!\n", Thread.currentThread().getName());
        //2秒后开始查找
        suspend(2);
        while (true) {
            //当除以0 的时候报异常
            int c = 1000 / new Random().nextInt(100);
            if (Thread.currentThread().isInterrupted()) {
                System.out.printf("%s 被打断!\n", Thread.currentThread().getName());
                return;
            }

            //每100微秒查询一次
            try {
                TimeUnit.MILLISECONDS.sleep(100);
            } catch (InterruptedException e) {
                System.out.printf("%s 被打断!\n", Thread.currentThread().getName());
                return;
            }
        }
    }

    private void suspend(int s) {
        try {
            TimeUnit.SECONDS.sleep(s);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

测试:

package com.rr.concurrent.chapter1.recipe11.test;


/**
 * Created by isaac_gu on 2016/5/11.
 * 范例: 查询文件,其中一个抛出异常,threadGroup处理异常后,全部进程都interrupt
 */
public class Test {
    public static void main(String[] args) {
        MyThreadGroup myThreadGroup = new MyThreadGroup("myThreadGroup");
        SearchTask searchTask = new SearchTask();

        for (int i = 0, len = 10; i < len; i++) {
            new Thread(myThreadGroup, searchTask).start();
        }

        System.out.println("主线程结束!");
    }
}

运行结果:

Thread-0 线程开始查找!
Thread-5 线程开始查找!
Thread-9 线程开始查找!
Thread-1 线程开始查找!
Thread-7 线程开始查找!
Thread-3 线程开始查找!
Thread-8 线程开始查找!
Thread-4 线程开始查找!
Thread-6 线程开始查找!
Thread-2 线程开始查找!
******************************** Exception Handler ******************************
1. Thread-0 线程出现了异常!
2. Exception: java.lang.ArithmeticException: / by zero
3. Stack Trace: 
java.lang.ArithmeticException: / by zero
	at com.rr.concurrent.chapter1.recipe11.test.SearchTask.run(SearchTask.java:17)
	at java.lang.Thread.run(Thread.java:745)
4. Thread status: RUNNABLE
******************************** Exception Handler END ******************************
Thread-6 被打断!
Thread-9 被打断!
Thread-1 被打断!
Thread-3 被打断!
Thread-5 被打断!
Thread-2 被打断!
Thread-4 被打断!
Thread-7 被打断!
Thread-8 被打断!

 

© 著作权归作者所有

共有 人打赏支持
火犀牛
粉丝 0
博文 27
码字总数 12180
作品 0
海淀
程序员
Java并发编程初级篇(九):线程组

Java API提供了一个线程组类ThreadGroup,这个类提供了一些方法可以让我们方便地对加入这个线程组的多个线程进行操作。 想使用线程组首先需要实例化一个线程组对象,并把创建的线程加入到这个...

阿拉德大陆的魔法师
2016/11/23
41
0
关于未捕获异常(Uncaught Exception)的处理

我们经常使用try..catch进行异常处理,但是对于Uncaught Exception是没办法捕获的。对于这类异常如何处理呢? 回顾一下thread的run方法,有个特别之处,它不会抛出任何检查型异常,但异常会导...

Bruceshi
2013/04/10
0
2
优雅的处理Android崩溃(一)

写在前面: Android崩溃是我们开发中不可避免的异常处理,通常崩溃都会触发系统的强制关闭对话框,用户点击后系统会强制关闭当前进程,用户体验及其不好。本文就简单介绍下怎么优雅的处理全局...

咖喱配胡椒
2017/08/14
0
0
Java并发编程初级篇(七):捕获线程中的运行时异常

Java API中为我们提供了一个用于捕获线程内部运行时异常的接口。实现这个接口并给线程指定异常捕获器就可以达到目的。 因为线程类的run()方法并不能抛出异常,所以如果不为线程指定UncaughtE...

阿拉德大陆的魔法师
2016/11/23
25
0
《Java多线程编程核心技术》读书笔记

《Java多线程编程核心技术》读书笔记。 第一章 Java多线程技能 使用Java多线程两种方式。 继承Thread类与实现Runnable接口。 线程的开始、中止、暂停、恢复、停止。 、、、、 线程的、、优先...

刀狂剑痴
2016/05/02
390
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

es6

在实际开发中,我们有时需要知道对象的所有属性,原生js给我们提供了一个很好的方法:Object.keys(),该方法返回一个数组 传入对象,返回属性名 var obj = {'a':'123','b':'345'};console.l...

不负好时光
21分钟前
0
0
叮!您收到一份超值Java基础入门资料!

摘要:Java语言有什么特点?如何最大效率的学习?深浅拷贝到底有何区别?阿里巴巴高级开发工程师为大家带来Java系统解读,带你掌握Java技术要领,突破重点难点,入门面向对象编程,以详细示例...

全部原谅
22分钟前
0
0
web.xml容器加载顺序

容器对于web.xml的加载过程是context-param >> listener >> fileter >> servlet

Aeroever
25分钟前
1
0
Docker容器日志查看与清理

1. 问题 docker容器日志导致主机磁盘空间满了。docker logs -f container_name噼里啪啦一大堆,很占用空间,不用的日志可以清理掉了。 2. 解决方法 2.1 找出Docker容器日志 在linux上,容器日...

muzi1994
26分钟前
0
0
J2Cache 和普通缓存框架有何不同,它解决了什么问题?

不少人看到 J2Cache 第一眼时,会认为这就是一个普普通通的缓存框架,和例如 Ehcache、Caffeine 、Spring Cache 之类的项目没什么区别,无非是造了一个新的轮子而已。事实上完全不是一回事!...

红薯
28分钟前
484
14

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部