| | |
| | | {
|
| | | // 创建脚本连接池
|
| | | GenericObjectPoolConfig<SMTJsonFlowScriptJet> config = new GenericObjectPoolConfig<>();
|
| | | config.setMaxTotal(32);
|
| | | config.setMinIdle(32);
|
| | | config.setMaxTotal(102400);
|
| | | config.setMinIdle(0);
|
| | | _scriptJetPool = new GenericObjectPool<>(new SMTJsonFlowScriptPoolFactory(), config);
|
| | |
|
| | |
|
| | |
| | | {
|
| | | // 执行下一个节点
|
| | | 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;
|