|
@@ -408,6 +408,12 @@ public class TaskWorkNode {
|
|
|
if(bool){
|
|
|
logger.info("条件判断成功,关闭线程池");
|
|
|
pool.shutdown();
|
|
|
+ }else{
|
|
|
+ try {
|
|
|
+ checkCon(taskNode, task, dataMap);
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
}
|
|
|
}else{
|
|
|
throw new RuntimeException(ex);
|