| | |
| | | {
|
| | | // 创建脚本连接池
|
| | | GenericObjectPoolConfig<SMTJsonFlowScriptJet> config = new GenericObjectPoolConfig<>();
|
| | | config.setMaxTotal(32);
|
| | | config.setMinIdle(32);
|
| | | config.setMaxTotal(102400);
|
| | | config.setMinIdle(0);
|
| | | _scriptJetPool = new GenericObjectPool<>(new SMTJsonFlowScriptPoolFactory(), config);
|
| | |
|
| | |
|
| | |
| | | // 创建并初始化节点
|
| | | for(Json jsonNode : jsonWorkflow.getJson("nodes").asJsonList())
|
| | | {
|
| | | SMTJsonFlowNode wfNode = null;
|
| | | SMTJsonFlowNode wfNode;
|
| | | String nodeType = jsonNode.getJson("type").asString();
|
| | | if("start".equals(nodeType))
|
| | | {
|
| | |
| | | {
|
| | | // 执行下一个节点
|
| | | SMTJsonFlowNodeExec flowNodeExec = execArg._stackNodeExec.pollFirst();
|
| | | execArg._tranReq.sendChunkedBlock("begin", "执行工作流节点:" + flowNodeExec._flowNode.getTitle() + "(" + flowNodeExec._flowNode.getId() + ")");
|
| | | execArg._tranReq.sendChunkedBlock("begin", "执行节点:" + flowNodeExec._flowNode.getTitle() + "(" + flowNodeExec._flowNode.getId() + ")");
|
| | | SMTJavaAIError error = flowNodeExec.executeFlowNode(execArg);
|
| | | if(error != null)
|
| | | return error;
|