ds-master
2022-04-20 11:17:25 6 举报master
作者其他创作
大纲/内容
generateNewProcessInstance()
processService.findOneCommand()
switch (commandType)
return processInstance
mutex.release()
createRecoveryWaitingThreadCommand()
masterExecService.getActiveCount()
false
return null
constructProcessInstance()
true
saveProcessInstance()
processInstance.setGlobalParams()
processService.handleCommand()
scheduleProcess()
mutex.acquire()
checkThreadNum()
checkCmdParam（）
get processInstanceId
processInstanceId==0
checkResource
Main()
开始
setWaitingThreadProcess()
masterExecService.execute()
cmdParam == null
delCommandById()
MasterSchedulerService.start()
0 条评论
下一页
