多线程异常处理机制

￡神魔★判官ぃ 2023-01-06 01:37 201阅读 0赞

### 多线程异常处理机制 ###

*  thread异常处理
 *  FutureTask异常处理
 *  ThreadPoolExcutor线程池的异常处理：
 *   *  使用execute提交线程的情况
     *  使用submit提交线程的情况

# thread异常处理 #

@org.junit.Test
        public void test(){
            try{
                Thread t = new Thread(() -> {
                    System.out.println("test thread");
                    System.out.println(1/0);
                });
                t.start();
            } catch (Exception e){
                System.out.println("catch exception");
            }
        }

可以看到没有打印出catch exception，说明没有捕获到异常，在多线程的时候，我们在线程外面是捕获不到异常的  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE3MDExNDIz_size_16_color_FFFFFF_t_70]

@org.junit.Test
        public void test(){
            Thread t = new Thread(() -> {
                try{
                    System.out.println("test thread");
                    System.out.println(1/0);
                } catch (Exception e){
                System.out.println("catch exception");
                }
            });
            t.start();
        }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE3MDExNDIz_size_16_color_FFFFFF_t_70 1]  
可以看到，在线程里面可以捕获到异常。

# FutureTask异常处理 #

class ExceptionCallable implements Callable<String> {
        @Override
        public String call() throws Exception {
            System.out.println("run");
            throw new RuntimeException("exception throw");
        }
    }

@org.junit.Test
        public void futureTaskTest(){
            FutureTask<String> task = new FutureTask<>(new ExceptionCallable());
            Thread thread = new Thread(task);
            thread.setUncaughtExceptionHandler((t, e) ->
                    System.out.println("catch exception"+ t.getName()+ e));
            thread.start();
            
        }

![在这里插入图片描述][20210114111233530.png]  
可以看到并没有捕获到异常，需要在future的get()来捕获异常才可以。

try{
                task.get();
            } catch (Exception e){
                System.out.println("catch exception"+e.getMessage());
            }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE3MDExNDIz_size_16_color_FFFFFF_t_70 2]

# ThreadPoolExcutor线程池的异常处理： #

## 使用execute提交线程的情况 ##

这种情况如果我们没有在线程内捕获异常那么JVM会调用  
Thread的UncaughtExceptionHandler的uncaughtException方法来处理异常，这是我们可以自己写逻辑覆盖其方法

public class MyHandler implements Thread.UncaughtExceptionHandler{
        @Override
        public void uncaughtException(Thread t, Throwable e) {
            System.out.println("threadId = {}, threadName = {}, ex = {}"
                    +t.getId()+ t.getName()+ e.getMessage());
        }
    }

测试代码：

public static void main(String[] args){
            ExecutorService es = new ThreadPoolExecutor(1, 1,
                    0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>(), new ThreadFactoryBuilder().setUncaughtExceptionHandler(new MyHandler()).build());
            es.execute(() -> {
                System.out.println(1/0);
            });
            System.out.println("x");
            es.shutdown();
    
        }

运行结果如下，说明最终执行到了我们自定义的异常捕获方法。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE3MDExNDIz_size_16_color_FFFFFF_t_70 3]

## 使用submit提交线程的情况 ##

submit会返回一个Future对象，我们要catct，Future的get()来捕获异常

ExecutorService es = new ThreadPoolExecutor(1, 1,
                    0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>(), new ThreadFactoryBuilder().setUncaughtExceptionHandler(new MyHandler()).build());
            Future ft = es.submit(() -> {
                System.out.println(1/0);
                //System.out.println("x1");
            });
    
            try{
                ft.get();
            } catch (Exception e){
                System.out.println("catch exception = {},"+e.getMessage());
            }

![在这里插入图片描述][20210114110548223.png]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE3MDExNDIz_size_16_color_FFFFFF_t_70]: /images/20221119/e39c3982be6b4e7ba8942620326ace66.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE3MDExNDIz_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20210114103458713.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE3MDExNDIz,size_16,color_FFFFFF,t_70
[20210114111233530.png]: https://img-blog.csdnimg.cn/20210114111233530.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE3MDExNDIz_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20210114112801990.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE3MDExNDIz,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE3MDExNDIz_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20210113181310661.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE3MDExNDIz,size_16,color_FFFFFF,t_70
[20210114110548223.png]: https://img-blog.csdnimg.cn/20210114110548223.png