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()
