本文介绍: ACT_HI_TASKINST:上传vlog节点已经审批完成ACT_RU_TASK:进入子流程,路由网关为并行网关,所以同时出现3个任务。ACT_RU_TASK:流程来到上传成功节点。ACT_RU_EXECUTION:数据变成了一条,活动来到上传成功。
一:内嵌子流程
repositoryService.createDeployment().name("内嵌子流程").addClasspathResource("bpmn/embed_sub_process.bpmn").deploy();
identityService.setAuthenticatedUserId("huihui");
ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("EmbedSubProcess");
Task task = taskService.createTaskQuery() .processInstanceId(processInstance.getId()).singleResult();
taskService.complete(task.getId());
ACT_HI_TASKINST:上传vlog节点已经审批完成
ACT_RU_TASK:进入子流程,路由网关为并行网关,所以同时出现3个任务。
ACT_RU_EXECUTION
- 父流程和子流程的流程实例id是同一个。
- SEQUENCE_COUNTER_ 序列计数器最小的记录对应的ID_和流程实例ID一样。
- 父流程实例的ROOT_PROC_INST_ID_有值,PARENT_ID_为null。
List<Task> list = taskService.createTaskQuery().processInstanceId("097a8235-b080-11ee-982f-92e97825df95").list();
for (Task task : list) {
taskService.complete(task.getId());
}
ACT_RU_TASK:流程来到上传成功节点。
ACT_RU_EXECUTION:数据变成了一条,活动来到上传成功。
二:多实例内嵌子流程
子流程也支持多实例(并发/顺序)执行。
当任务为外部任务时可以设置任务的优先级,默认为50,假如“批量上传vlog”上传10个,如果没有设置优先级即都为50,当第一次循环进入“排队检查”,后面可能执行后面的校验节点,而第二轮循环如果第二轮的“排队检查”没有执行,那么第二轮的后面检查节点也得不到执行的机会,所以我们循环10轮,尽可能先将10轮中的“排队检查”优先执行完,这样会生成10*3的检查节点,这样节点就可以并发去执行,这样就减少了不必要的等待时间。
多实例,节点执行有先后,尽可能提高前面节点的优先级,保证前面节点优先执行。
repositoryService.createDeployment().name("多实例内嵌子流程").addClasspathResource("bpmn/embed_sub_process_multi.bpmn").deploy();
identityService.setAuthenticatedUserId("huihui");
ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("EmbedSubProcessMulti");
Task task = taskService.createTaskQuery() .processInstanceId(processInstance.getId()).singleResult();
VariableMap variables = Variables.createVariables().putValue("fileList", Arrays.asList("a.mp4", "b.rmvb"));
taskService.complete(task.getId(), variables);
camunda:
bpm:
client:
base-url: http://localhost:8080/engine-rest
# 一次拉取10个任务,提高并发效率
max-tasks: 10
三:调用流程 Call Activity
<dependency>
<groupId>org.codehaus.groovy</groupId>
<artifactId>groovy-all</artifactId>
<version>3.0.9</version>
<type>pom</type>
</dependency>
<dependency>
<groupId>org.codehaus.groovy.modules.http-builder</groupId>
<artifactId>http-builder</artifactId>
<version>0.7.1</version>
</dependency>
repositoryService.createDeployment().name("调用流程").addClasspathResource("bpmn/main_process.bpmn").deploy();
identityService.setAuthenticatedUserId("huihui");
ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("MainProcess");
Task task = taskService.createTaskQuery().processInstanceId(processInstance.getId()).singleResult();
VariableMap variables = Variables.createVariables().putValue("sourcePath", "xxx.rmvb");
taskService.complete(task.getId(), variables);
ACT_RU_TASK:进入调用的流程。
ACT_RU_EXECUTION:
- 调用流程和内嵌子流程完全不一样,调用流程会生成2个不同的流程实例。
- 两个流程的ROOT_PROC_INST_ID_值一样。
- 父子流程通过 SUPER_EXEC_ 字段进行关联。
List<Task> list = taskService.createTaskQuery().processInstanceId("719d2260-b08b-11ee-8cfc-92e97825df95").list();
for (Task task : list) {
taskService.complete(task.getId());
}
ACT_RU_VARIABLE:Out Mappings中的sourceResult变量赋值成功了。
原文地址:https://blog.csdn.net/vbirdbest/article/details/135538772
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.7code.cn/show_56730.html
如若内容造成侵权/违法违规/事实不符,请联系代码007邮箱:suwngjj01@126.com进行投诉反馈,一经查实,立即删除!
声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。