提交 523357f5 编写于 作者: W wind 提交者: lenboo

[DS-6737][MasterServer] fix event handle twice (#6738)

Co-authored-by: Ncaishunfeng <534328519@qq.com>
上级 98465b12
......@@ -104,10 +104,7 @@ public class WorkflowExecuteThread implements Runnable {
* runing TaskNode
*/
private final Map<Integer, ITaskProcessor> activeTaskProcessorMaps = new ConcurrentHashMap<>();
/**
* task exec service
*/
private final ExecutorService taskExecService;
/**
* process instance
*/
......@@ -216,9 +213,6 @@ public class WorkflowExecuteThread implements Runnable {
this.processInstance = processInstance;
this.masterConfig = masterConfig;
int masterTaskExecNum = masterConfig.getMasterExecTaskNum();
this.taskExecService = ThreadUtils.newDaemonFixedThreadExecutor("Master-Task-Exec-Thread",
masterTaskExecNum);
this.nettyExecutorManager = nettyExecutorManager;
this.processAlertManager = processAlertManager;
this.taskTimeoutCheckList = taskTimeoutCheckList;
......@@ -227,8 +221,11 @@ public class WorkflowExecuteThread implements Runnable {
@Override
public void run() {
try {
startProcess();
handleEvents();
if (!this.isStart()) {
startProcess();
} else {
handleEvents();
}
} catch (Exception e) {
logger.error("handler error:", e);
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册