1、背景:
Java 多线程异常不向主线程抛,自己处理,外部捕获不了异常。所以要实现主线程对子线程异常的捕获。
2、工具:
实现Runnable接口的LayerInitTask类,ThreadException类,线程安全的Vector
3、思路:
向LayerInitTask中传入Vector,记录异常情况,外部遍历,判断,抛出异常。
4、代码:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
|
package step5.exception; import java.util.Vector; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; import com.autonavi.pds.core.incre.impl.LayerInitTask; public class ThreadException { public static void main(String[] args) { try { Vector<String> errRet = new Vector(); ExecutorService pool = Executors.newFixedThreadPool( 6 ); for ( int i = 0 ; i < 6 ; ++i) { pool.execute( new LayerInitTask(i, errRet)); } pool.shutdown(); pool.awaitTermination( 1 , TimeUnit.DAYS); if (errRet.size() > 0 ) { System.out.println( "根据返回值捕获:exception" ); throw new RuntimeException( "入库失败!" ); } } catch (Exception e) { System.out.println( "根据抛出异常捕获:exception" ); throw new RuntimeException( "入库失败!" ); } System.out.println( "-----入库成功,发成功完成工作邮件--------" ); } } |
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
package step5.exception; import java.util.Vector; public class LayerInitTask implements Runnable { private int threadNum; private Vector<String> errRet; public LayerInitTask( int num, Vector<String> errRet) { this .threadNum = num; this .errRet = errRet; } @Override public void run() { try { if ( this .threadNum == 3 ) { throw new RuntimeException( this .threadNum + ":数据格式有误." ); } System.out.println( this .threadNum + ":刷表成功" ); } catch (Exception e) { this .errRet.add( "线程:" + this .threadNum + "运行异常!" ); throw new RuntimeException( this .threadNum + ":刷表失败" ); } } } |
5、结果:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
Exception in thread "pool-1-thread-4" java.lang.RuntimeException: 3 :刷表失败 at step5.exception.LayerInitTask.run(LayerInitTask.java: 23 ) at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) at java.lang.Thread.run(Unknown Source) Exception in thread "main" java.lang.RuntimeException: 入库失败! at step5.exception.ThreadException.main(ThreadException.java: 27 ) 2 :刷表成功 1 :刷表成功 5 :刷表成功 0 :刷表成功 4 :刷表成功 根据返回值捕获:exception 根据抛出异常捕获:exception |
如有疑问请留言或者到本站社区交流讨论,感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!
原文链接:http://blog.csdn.net/q_l_s/article/details/70159749