线程异常增加监听，主线程感知。

Author: mingj

src/main/java/com/jeiao/ThreadMain.java

@@ -20,8 +20,9 @@
 public class ThreadMain {
 
     private static Logger logger = LogManager.getLogger();
+    public static volatile int threadStatus = 0;
 
-    public static void main(String[] args) throws InterruptedException {
+    public static void main(String[] args) throws Exception {
 
 
         for (int i = 0; i < 300; i++) {
@@ -48,6 +49,10 @@ public static void main(String[] args) throws InterruptedException {
         countDownLatch.await();
         executorService.shutdown();
 
+        if (threadStatus > 0) {
+            throw new Exception("线程异常，程序异常退出！");
+        }
+
         logger.info("最后处理完成后的map数量："+MemoryCache.orderBeanMap.size());
 
     }

src/main/java/com/jeiao/thread/OrderBeanThread.java

@@ -1,5 +1,6 @@
 package com.jeiao.thread;
 
+import com.jeiao.ThreadMain;
 import com.jeiao.bean.OrderBean;
 import com.jeiao.common.MemoryCache;
 import com.jeiao.queue.OrderBeanQueue;
@@ -8,6 +9,7 @@
 
 
 import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.Executors;
 
 
 /**
@@ -30,31 +32,44 @@ public OrderBeanThread(String threadName, CountDownLatch countDownLatch) {
     }
 
     public void run() {
+        try {
+            while (!OrderBeanQueue.isEmpty()) {
+                OrderBean orderBean = OrderBeanQueue.getOrder();
 
-        while (!OrderBeanQueue.isEmpty()) {
-            OrderBean orderBean = OrderBeanQueue.getOrder();
+                if (orderBean == null) {
+                    continue;
+                }
 
-            if (orderBean == null) {
-                continue;
-            }
 
-            try {
-                Thread.sleep(1000);
-            } catch (InterruptedException e) {
-                e.printStackTrace();
-            }
+                //测试
+                //int i = 1 / 0;
+
+                try {
+                    Thread.sleep(1000);
+                } catch (InterruptedException e) {
+                    ThreadMain.threadStatus++;
+                    e.printStackTrace();
+                    throw new Exception(e);
+                }
 
-            logger.info(threadName);
-            logger.info(countDownLatch.getCount());
 
-            String orderId = orderBean.getOrderId();
 
-            //do something
+                logger.info(threadName);
+                logger.info(countDownLatch.getCount());
 
-            MemoryCache.orderBeanMap.put(orderId, orderBean);
+                String orderId = orderBean.getOrderId();
 
+                //do something
+
+                MemoryCache.orderBeanMap.put(orderId, orderBean);
+            }
+        } catch (Exception e) {
+            ThreadMain.threadStatus++;
+            throw new RuntimeException("线程处理异常，线程退出");
+
+        }finally {
+            countDownLatch.countDown();
+            logger.info(countDownLatch.getCount());
         }
-        countDownLatch.countDown();
-        logger.info(countDownLatch.getCount());
     }
 }