【修改BUG】修正偶发性死锁的问题

.gitignore

@@ -8,3 +8,5 @@ modules.xml
 Project_Default.xml
 vcs.xml
 workspace.xml
+
+target
\ No newline at end of file

byit-myth-core/myth-admin-core/src/main/java/com/byit/conf/MythJobScheduler.java

@@ -32,7 +32,8 @@ public class MythJobScheduler implements InitializingBean, DisposableBean {
      */
     @Override
     public void destroy() throws Exception {
-
+        this.jobScheduleHelper.doStop();
+        this.logScanHelper.doStop();
     }
 
     /**
@@ -42,8 +43,8 @@ public class MythJobScheduler implements InitializingBean, DisposableBean {
     @Override
     public void afterPropertiesSet() throws Exception {
         //启用扫描线程
-        jobScheduleHelper.start();
-        logScanHelper.start();
+        this.jobScheduleHelper.start();
+        this.logScanHelper.start();
 
     }
 }

byit-myth-core/myth-admin-core/src/main/java/com/byit/thread/JobScheduleHelper.java

@@ -320,6 +320,43 @@ public class JobScheduleHelper{
         scheduleThread.setDaemon(true);
         scheduleThread.start();
     }
+    public void doStop(){
+        this.jobInfoThreadToStop = true;
+        try {
+            TimeUnit.SECONDS.sleep(1);
+        } catch (InterruptedException e) {
+            e.printStackTrace( );
+        }
+        if (jobInfoThread.getState() != Thread.State.TERMINATED) {
+            jobInfoThread.interrupt();
+
+            try {
+                jobInfoThread.join();
+            } catch (InterruptedException e) {
+                e.printStackTrace( );
+            }
+        }
+        log.warn("---------------【任务节点节点扫描线程被注销】-----------------------");
+
+        this.scheduleThreadToStop = true;
+        try {
+            TimeUnit.SECONDS.sleep(1);
+        } catch (InterruptedException e) {
+            e.printStackTrace( );
+        }
+        if (scheduleThread.getState() != Thread.State.TERMINATED) {
+            scheduleThread.interrupt();
+            try {
+                scheduleThread.join();
+            } catch (InterruptedException e) {
+                e.printStackTrace( );
+            }
+        }
+        log.warn("---------------【排期表扫描线程被注销】-----------------------");
+
+
+    }
+
 
     @Autowired
     public void setDataSource(DataSource dataSource) {

byit-myth-core/myth-admin-core/src/main/java/com/byit/thread/LogScanHelper.java

@@ -110,7 +110,43 @@ public class LogScanHelper {
                     e.printStackTrace();
                 }finally {
                     //释放资源
-                    freedResource(conn,preparedStatement,connAutoCommit,virtualNodeScanIsStop);
+                    if(conn != null){
+                        try {
+                            conn.commit();
+                        } catch (SQLException e) {
+                            if(!virtualNodeScanIsStop){
+                                log.error("--------------------【提交行锁出错】---------------------");
+                            }
+                        }
+                    }
+
+                    try {
+                        if(conn != null){
+                            conn.setAutoCommit(connAutoCommit);
+                        }
+                    } catch (SQLException e) {
+                        if(!virtualNodeScanIsStop){
+                            log.error("--------------------【恢复自动提交出错】---------------------");
+                        }
+                    }
+
+                    if(preparedStatement != null){
+                        try {
+                            preparedStatement.close();
+                        } catch (SQLException e) {
+                            if(!notAlarmedNodeScanIsStop){
+                                log.error("--------------------【关闭执行器出错】---------------------");
+                            }
+                        }
+                    }
+
+                    try {
+                        conn.close();
+                    } catch (SQLException e) {
+                        if(!virtualNodeScanIsStop){
+                            log.error("--------------------【关闭链接出错】---------------------");
+                        }
+                    }
                 }
             }
 
@@ -136,7 +172,6 @@ public class LogScanHelper {
                     conn.setAutoCommit(false);
                     preparedStatement = conn.prepareStatement("SELECT * FROM JOB_LOCK WHERE LOCK_NAME = 'log_node_callback_lock' FOR UPDATE ");
                     preparedStatement.execute();
-                    System.out.println("--------------火球锁成功------------------" );
                     //查询的是失败的或者是已经结束的节点（完成的）
                     List<JobTaskRunLog> jobTaskRunLogEndOrFailureNode = jobTaskRunLogService.findJobTaskRunLogEndOrFailureNode( );
                     if(CollectionUtil.isNotEmpty(jobTaskRunLogEndOrFailureNode)){
@@ -184,37 +219,22 @@ public class LogScanHelper {
                 }catch (Exception e){
                     e.printStackTrace();
                 }finally {
-                    freedResource(conn,preparedStatement,connAutoCommit,notAlarmedNodeScanIsStop);
-                }
-            }
-        });
-        notAlarmedNodeScanThread.setName("myth-job#【LogScanHelper】#notAlarmedNodeScanThread");
-        notAlarmedNodeScanThread.setDaemon(true);
-        notAlarmedNodeScanThread.start();
-    }
-
-    /**
-     * 释放资源
-     * @param conn 数据库链接
-     * @param preparedStatement 执行器
-     * @param connAutoCommit 原来的提交状态
-     */
-    private void freedResource(Connection conn,PreparedStatement preparedStatement,boolean connAutoCommit,boolean isStop){
                     if(conn != null){
                         try {
                             conn.commit();
                         } catch (SQLException e) {
-                if(!isStop){
+                            if(!notAlarmedNodeScanIsStop){
                                 log.error("--------------------【提交行锁出错】---------------------");
                             }
                         }
                     }
 
                     try {
-            assert conn != null;
+                        if(conn != null){
                             conn.setAutoCommit(connAutoCommit);
+                        }
                     } catch (SQLException e) {
-            if(!isStop){
+                        if(!notAlarmedNodeScanIsStop){
                             log.error("--------------------【恢复自动提交出错】---------------------");
                         }
                     }
@@ -223,7 +243,7 @@ public class LogScanHelper {
                         try {
                             preparedStatement.close();
                         } catch (SQLException e) {
-                if(!isStop){
+                            if(!notAlarmedNodeScanIsStop){
                                 log.error("--------------------【关闭执行器出错】---------------------");
                             }
                         }
@@ -232,12 +252,18 @@ public class LogScanHelper {
                     try {
                         conn.close();
                     } catch (SQLException e) {
-            if(!isStop){
+                        if(!notAlarmedNodeScanIsStop){
                             log.error("--------------------【关闭链接出错】---------------------");
                         }
                     }
-
                 }
+            }
+        });
+        notAlarmedNodeScanThread.setName("myth-job#【LogScanHelper】#notAlarmedNodeScanThread");
+        notAlarmedNodeScanThread.setDaemon(true);
+        notAlarmedNodeScanThread.start();
+    }
+
 
     public void doStop(){
         this.virtualNodeScanIsStop = true;
@@ -255,6 +281,7 @@ public class LogScanHelper {
                 e.printStackTrace( );
             }
         }
+        log.warn("---------------【虚节点扫描线程被注销】-----------------------");
 
         this.notAlarmedNodeScanIsStop = true;
         try {
@@ -270,6 +297,8 @@ public class LogScanHelper {
                 e.printStackTrace( );
             }
         }
+        log.warn("---------------【日志扫描线程被注销】-----------------------");
+
 
     }