1.对处理GPS的线程池做了超时处理，以及出现超时后通知处理

王通
1 parent de274183
Showing 3 changed files with 77 additions and 11 deletions
src/main/java/com/bsth/data/ThreadMonotor.java
src/main/java/com/bsth/data/gpsdata_v2/DataHandleProcess.java
src/main/resources/logback.xml
@@ -2,6 +2,9 @@ package com.bsth.data;
 import com.bsth.data.gpsdata_v2.DataHandleProcess;
 import com.bsth.data.gpsdata_v2.thread.GpsDataLoaderThread;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Component;
 /**
@@ -9,11 +12,15 @@ import org.springframework.stereotype.Component;
  */
 @Component
 public class ThreadMonotor extends Thread{
+	
+	Logger logger = LoggerFactory.getLogger(this.getClass());
     @Override
     public void run() {
         //切换到备用的网关实时GPS对照数据
-        if(DataHandleProcess.isBlock())
-            GpsDataLoaderThread.setFlag(-1);
+        if(DataHandleProcess.isBlock()) {
+        	GpsDataLoaderThread.setFlag(-1);
+        	logger.error("切换到备用GPS数据源");
+        }
     }
 }
 \ No newline at end of file
@@ -4,6 +4,8 @@ import com.alibaba.fastjson.JSON;
 import com.bsth.data.gpsdata_v2.cache.GpsCacheData;
 import com.bsth.data.gpsdata_v2.entity.GpsEntity;
 import com.bsth.data.gpsdata_v2.handlers.*;
+import com.bsth.email.SendEmailController;
+import com.bsth.email.entity.EmailBean;
 import com.google.common.collect.ArrayListMultimap;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
@@ -15,6 +17,8 @@ import java.util.*;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
+import java.util.concurrent.ThreadFactory;
+import java.util.concurrent.TimeUnit;
 /**
  * 实时信号数据处理
@@ -37,13 +41,27 @@ public class DataHandleProcess {
     ReverseRouteProcess reverseRouteProcess;
     @Autowired
     GpsRealData gpsRealData;
+    // 发送邮件
+ 	@Autowired
+ 	private SendEmailController sendEmailController;
     static Logger logger = LoggerFactory.getLogger(DataHandleProcess.class);
     final static int POOL_SIZE = 20;
-    static ExecutorService threadPool = Executors.newFixedThreadPool(POOL_SIZE + 1);
+    static ExecutorService threadPool = Executors.newFixedThreadPool(POOL_SIZE + 1, new ThreadFactory() {
+
+		@Override
+		public Thread newThread(Runnable r) {
+			// TODO Auto-generated method stub
+			Thread t = new Thread(r);
+			t.setName("GPSProcessor");
+			
+			return t;
+		}
+    	
+    });
     public static CountDownLatch count;
     static long lastTime;
@@ -51,7 +69,22 @@ public class DataHandleProcess {
     public static boolean isBlock() {
         return System.currentTimeMillis() - lastTime > 1000 * 30;
     }
-
+    
+    private void shutdownAndAwaitTermination(ExecutorService pool) {
+    	pool.shutdown();
+    	try {
+    		if (!pool.awaitTermination(500, TimeUnit.MILLISECONDS)) {
+    			pool.shutdownNow();
+    		}
+    		if (!pool.awaitTermination(500, TimeUnit.MILLISECONDS)) {
+    			logger.error("线程池无法正常终止");
+    		}
+    	} catch (InterruptedException e) {
+    		pool.shutdown();
+    		Thread.currentThread().interrupt();
+    	}
+    }
+    
     public void handle(List<GpsEntity> list) {
         try {
             if (list.size() == 0)
@@ -85,7 +118,32 @@ public class DataHandleProcess {
             //等待子线程结束
-            count.await();
+            boolean isNormal = count.await(5, TimeUnit.SECONDS);
+            if (!isNormal) {
+            	try {
+            		shutdownAndAwaitTermination(threadPool);
+            		threadPool = Executors.newFixedThreadPool(POOL_SIZE + 1, new ThreadFactory() {
+
+            			@Override
+            			public Thread newThread(Runnable r) {
+            				// TODO Auto-generated method stub
+            				Thread t = new Thread(r);
+            				t.setName("GPSProcessor");
+            				
+            				return t;
+            			}
+            	    	
+            	    });
+    				//发送邮件
+    				EmailBean mail = new EmailBean();
+    				mail.setSubject("线调GPS处理<br/>");
+    				mail.setContent("GPS处理超时，检查线程栈文件信息<br/>");
+    				sendEmailController.sendMail("113252620@qq.com", mail);
+    				logger.info("DataHandlerProcess:邮件发送成功!");
+    			} catch (Exception e){
+    				logger.error("DataHandlerProcess:邮件发送失败!",e);
+    			}
+            }
             //加入实时gps对照
             for (GpsEntity gps : list)
@@ -115,6 +173,7 @@ public class DataHandleProcess {
                 Collections.sort(list, comp);
                 GpsEntity gps;
                 for(int i = 0,len = list.size(); i< len ;i ++){
+                	if (Thread.currentThread().isInterrupted()) break;
                     gps = list.get(i);
                     try {
@@ -72,7 +72,7 @@
 		</rollingPolicy>
 		<layout class="ch.qos.logback.classic.PatternLayout">
-			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%file:%line] %-5level -%msg%n
+			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] [%file:%line] %-5level -%msg%n
 			</pattern>
 		</layout>
 	</appender>
@@ -102,7 +102,7 @@
 		</rollingPolicy>
 		<layout class="ch.qos.logback.classic.PatternLayout">
-			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%file:%line] %-5level -%msg%n
+			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] [%file:%line] %-5level -%msg%n
 			</pattern>
 		</layout>
 	</appender>
@@ -124,7 +124,7 @@
 		</rollingPolicy>
 		<layout class="ch.qos.logback.classic.PatternLayout">
-			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%file:%line] %-5level -%msg%n
+			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] [%file:%line] %-5level -%msg%n
 			</pattern>
 		</layout>
 	</appender>
@@ -141,7 +141,7 @@
 		</rollingPolicy>
 		<layout class="ch.qos.logback.classic.PatternLayout">
-			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%file:%line] %-5level -%msg%n
+			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] [%file:%line] %-5level -%msg%n
 			</pattern>
 		</layout>
 	</appender>
@@ -213,7 +213,7 @@
 		</rollingPolicy>
 		<layout class="ch.qos.logback.classic.PatternLayout">
-			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%file:%line] %-5level -%msg%n
+			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] [%file:%line] %-5level -%msg%n
 			</pattern>
 		</layout>
 	</appender>
@@ -235,7 +235,7 @@
 		</rollingPolicy>
 		<layout class="ch.qos.logback.classic.PatternLayout">
-			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%file:%line] %-5level -%msg%n
+			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] [%file:%line] %-5level -%msg%n
 			</pattern>
 		</layout>
 	</appender>