Commit e7fe9d5a7263cdd8daf0f2979d6f6b2cc736cbd2
1 parent
1a9184ae
每个方法改为线程模式
Showing
1 changed file
with
41 additions
and
10 deletions
src/main/java/com/bsth/data/zndd/ZnddTwoThread.java
| @@ -62,24 +62,53 @@ public class ZnddTwoThread extends Thread{ | @@ -62,24 +62,53 @@ public class ZnddTwoThread extends Thread{ | ||
| 62 | if (zs.getOpenStatus() != null && zs.getOpenStatus().equals("0")) { | 62 | if (zs.getOpenStatus() != null && zs.getOpenStatus().equals("0")) { |
| 63 | //预案5个 | 63 | //预案5个 |
| 64 | if (zs.getType().equals("fcjg")) { | 64 | if (zs.getType().equals("fcjg")) { |
| 65 | - automaticSch.dfTz(0); | ||
| 66 | - logger.info("发车间隔执行完毕"); | 65 | + new Thread() { |
| 66 | + @Override | ||
| 67 | + public void run() { | ||
| 68 | + automaticSch.dfTz(0); | ||
| 69 | + logger.info("发车间隔执行完毕"); | ||
| 70 | + } | ||
| 71 | + }.start();//启动线程 | ||
| 67 | } | 72 | } |
| 68 | if (zs.getType().equals("wd")) { | 73 | if (zs.getType().equals("wd")) { |
| 69 | - automaticSch.wd(); | ||
| 70 | - logger.info("误点执行完毕"); | 74 | + new Thread() { |
| 75 | + @Override | ||
| 76 | + public void run() { | ||
| 77 | + automaticSch.wd(); | ||
| 78 | + logger.info("误点执行完毕"); | ||
| 79 | + } | ||
| 80 | + }.start();//启动线程 | ||
| 71 | } | 81 | } |
| 72 | if (zs.getType().equals("djg")) { | 82 | if (zs.getType().equals("djg")) { |
| 73 | - automaticSch.dfTz(1); | ||
| 74 | - logger.info("行车大间隔执行完毕"); | 83 | + new Thread() { |
| 84 | + @Override | ||
| 85 | + public void run() { | ||
| 86 | + automaticSch.dfTz(1); | ||
| 87 | + logger.info("行车大间隔执行完毕"); | ||
| 88 | + } | ||
| 89 | + }.start();//启动线程 | ||
| 90 | + | ||
| 75 | } | 91 | } |
| 76 | if (zs.getType().equals("mz")) { | 92 | if (zs.getType().equals("mz")) { |
| 77 | - automaticSch.mz(); | ||
| 78 | - logger.info("满载执行完毕"); | 93 | + new Thread() { |
| 94 | + @Override | ||
| 95 | + public void run() { | ||
| 96 | + automaticSch.mz(); | ||
| 97 | + logger.info("满载执行完毕"); | ||
| 98 | + } | ||
| 99 | + }.start();//启动线程 | ||
| 100 | + | ||
| 79 | } | 101 | } |
| 80 | if (zs.getType().equals("desctwo")) { | 102 | if (zs.getType().equals("desctwo")) { |
| 81 | - automaticSch.TowdescSch(); | ||
| 82 | - logger.info("末二班车"); | 103 | + new Thread() { |
| 104 | + @Override | ||
| 105 | + public void run() { | ||
| 106 | + automaticSch.TowdescSch(); | ||
| 107 | + logger.info("末二班车"); | ||
| 108 | + } | ||
| 109 | + }.start();//启动线程 | ||
| 110 | + | ||
| 111 | + | ||
| 83 | } | 112 | } |
| 84 | } | 113 | } |
| 85 | } | 114 | } |
| @@ -89,6 +118,8 @@ public class ZnddTwoThread extends Thread{ | @@ -89,6 +118,8 @@ public class ZnddTwoThread extends Thread{ | ||
| 89 | logger.info("智能调度线程——————", e); | 118 | logger.info("智能调度线程——————", e); |
| 90 | } | 119 | } |
| 91 | } | 120 | } |
| 121 | + | ||
| 122 | + | ||
| 92 | //满载 | 123 | //满载 |
| 93 | /* public void MZ(){ | 124 | /* public void MZ(){ |
| 94 | try { | 125 | try { |