1000字范文，内容丰富有趣，学习的好帮手！
1000字范文XML网站地图
全站
首页 50字 100字 200字 300字 400字 500字 600字 700字 800字 900字 1000字 1200字 1500字
推荐专题：
1000字范文 > Activiti并行网关和串行网关区别

Activiti并行网关和串行网关区别

时间：2023-07-20 00:41:12

相关推荐

Activiti并行网关和串行网关区别

转载出处来自分享牛/qq_30739519)

Activiti多实例任务有并行、串行区分。

并行代表同时进行，如把任务分给5个人来处理，这5个人同时会收到任务，并且可以同时处理，不受各自的影响。

串行代表工作或任务由一个人完成后，再由另一个人去处理，直至全部完成，每个任务依赖于前一个任务完成。

我们在使用activiti工作流引擎的时候，最常用的肯定是任务节点，因为在OA系统、审批系统、办公自动化系统中核心的处理就是流程的运转，在流程运转的时候，可能我们有这样的一个需求，在一个任务节点的时候，我们需要多个人对这个节点进行审批，比如实际中这样一个例子，假如是一个部门的投票，这个部门有5个人，那么当5个人都投票的时候大概分为如下几种：

1.部门所有人都去投票，当所有人都投票完成的时候，这个节点结束，流程运转到下一个节点。(所有的人都需要投票)

2.部门所有人都去投票,只要有任意2/3的人同意，这个节点结束，流程运转到下一个节点。(部分人投票只要满足条件就算完成)。

3.部门中有一个部门经理，只要部门经理投票过了，这个节点结束，流程运转到下一个节点（一票否决权）。

4.部门中根据职位不同，不同的人都不同的权重，当满足条件的时候，这个节点结束，流程运转到下一个节点。比如说所有的人员权重加起来是1，a有0.2的权重，其他的四个人分别是0.1的权重，我们可以配置权重达到0.3就可以走向下一个节点，换言之a的权重是其他人的2倍，那就是a的投票相当于2个人投票。这种需求还是很常见的。

5.部门所有人都去投票，a投票结束到b,b开始投票结束到c,一直如此，串行执行。最终到最后一个人再统计结果，决定流程的运转。

上面的五种情况，我们可以提取出来一些信息，我们的activiti工作流引擎，必须支持如下功能，才能满足上面的需求：

1.任务节点可以配置自定义满足条件。

2.任务节点必须支持串行、并行。

3.任务节点必须支持可以指定候选人或者候选组。

4.任务节点必须支持可以循环的次数。

5.任务节点必须支持可以自定义权重。

6.任务节点必须支持加签、减签。(就是动态的修改任务节点的处理人)

因为实际上的需求可能比上面的几种情况更加的复杂，上面的6个满足条件，工作流支持前4个，后面的2个条件是不支持的，所以我们必须要扩展activiti工作流引擎才能使用5、6等的功能。下面我们将详细的介绍前四种条件的使用，在掌握基本使用之后，我们在后面的章节中将详细的介绍，5、6这两种功能以及可能更加复杂的操作。

1.1.2.串行、并行配置

为了演示如何使用，我们采用由浅入深的使用，结合流程图、流程定义xml、以及代码和数据库的变化来阐释每一个配置的使用以及含义。

流程的详细定义如下图所示：

流程的详细定义xml如下所示：

<?xml version="1.0" encoding="UTF-8"?>

<definitions xmlns="/spec/BPMN/0524/MODEL" xmlns:xsi="/2001/XMLSchema-instance" xmlns:xsd="/2001/XMLSchema" xmlns:activiti="/bpmn" xmlns:bpmndi="/spec/BPMN/0524/DI" xmlns:omgdc="/spec/DD/0524/DC" xmlns:omgdi="/spec/DD/0524/DI" typeLanguage="/2001/XMLSchema" expressionLanguage="/1999/XPath" targetNamespace="daling">

<process id="daling" name="name_daling" isExecutable="true" activiti:candidateStarterUsers="a,b,c,d">

<startEvent id="startevent1" name="Start"></startEvent>

<userTask id="usertask1" name="多实例任务" activiti:candidateUsers="shareniu1,shareniu2,shareniu3,shareniu4">

<multiInstanceLoopCharacteristics isSequential="true">

<loopCardinality>2</loopCardinality>

</multiInstanceLoopCharacteristics>

</userTask>

<sequenceFlow id="flow1" sourceRef="startevent1" targetRef="usertask1"></sequenceFlow>

<endEvent id="endevent1" name="End"></endEvent>

<sequenceFlow id="flow2" sourceRef="usertask1" targetRef="endevent1"></sequenceFlow>

</process>

<bpmndi:BPMNDiagram id="BPMNDiagram_daling">

<bpmndi:BPMNPlane bpmnElement="daling" id="BPMNPlane_daling">

<bpmndi:BPMNShape bpmnElement="startevent1" id="BPMNShape_startevent1">

<omgdc:Bounds height="35.0" width="35.0" x="180.0" y="150.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNShape bpmnElement="usertask1" id="BPMNShape_usertask1">

<omgdc:Bounds height="55.0" width="105.0" x="370.0" y="90.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNShape bpmnElement="endevent1" id="BPMNShape_endevent1">

<omgdc:Bounds height="35.0" width="35.0" x="650.0" y="130.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNEdge bpmnElement="flow1" id="BPMNEdge_flow1">

<omgdi:waypoint x="215.0" y="167.0"></omgdi:waypoint>

<omgdi:waypoint x="422.0" y="145.0"></omgdi:waypoint>

</bpmndi:BPMNEdge>

<bpmndi:BPMNEdge bpmnElement="flow2" id="BPMNEdge_flow2">

<omgdi:waypoint x="475.0" y="117.0"></omgdi:waypoint>

<omgdi:waypoint x="667.0" y="130.0"></omgdi:waypoint>

</bpmndi:BPMNEdge>

</bpmndi:BPMNPlane>

</bpmndi:BPMNDiagram>

</definitions>

xml配置文件的部分含义如下：

1.activiti:candidateUsers="shareniu1,shareniu2,shareniu3,shareniu4"这个节点可以4个人审核。

2.<loopCardinality>2</loopCardinality>循环2次结束。

3.<multiInstanceLoopCharacteristics isSequential="true">串行并行的配置。

1.1.2.1.串行的配置

修改<multiInstanceLoopCharacteristics isSequential="true">中的isSequential为true是串行，isSequential为false是并行。我们测试串行。下面的代码展示启动流程因为是以一个节点所以部署启动后，直接进入多实例任务。

1.1.2.1.1.流程的部署

Deployment deploy = repositoryService2.createDeployment()

.category(category).addClasspathResource("demo1.bpmn").deploy();

1.1.2.1.2.流程的启动

/**

*

*@paramruntimeService

*@paramkey

* act_re_procdef表的Id

*@parambusinessKey

* 业务单号

*@return

*/

publicProcessInstancestartProcessInstanceByKey(

RuntimeServiceruntimeService, Stringkey, StringbusinessKey){

ProcessInstanceprocessInstance=runtimeService

.startProcessInstanceByKey(key,businessKey);

returnprocessInstance;

}

我们按照上面的步骤启动一个流程看一下数据库的变化。

ACT_RU_TASK表的数据有了如下图所示：

ACT_RU_IDENTITYLINK表的数据有了如下图所示：

ACT_RU_IDENTITYLINK权限表中，确实把我们设置的人员信息设置进去了，shareniu1,shareniu2,shareniu3,shareniu4现在就有代办信息了。

ACT_RU_VARIABLE表的数据有了如下图所示：

上面重要的变量需要解释一下，要不然还真不好理解，多任务是怎么运转的。

1.nrOfInstances 实例总数。

2.nrOfCompletedInstances 当前还没有完成的实例nr是number单词缩写 。

3.loopCounter已经循环的次数。

4.nrOfActiveInstances 已经完成的实例个数。

下面我们结束一个任务看一下，流程走到那个节点了。

1.1.2.1.3.完成任务

String taskId="45009";

demo.getTaskService().complete(taskId);

接下来看一下数据库表的变化。

ACT_RU_VARIABLE表的数据有了如下图所示：

上面我们仔细的发现，可以看到

nrOfCompletedInstances、loopCounter、nrOfActiveInstances都加1了，确实多任务就是参考这几个值的变化进行判断的。

因为我们设置了循环2次，所以我们看看ACT_RU_IDENTITYLINK还有一个任务，因为我们是并行处理的。

所以我们在结束新的任务看一下流程是不是真的结束了，如果结束了，那么我们循环次数的配置就是正确的。

1.1.2.1.4.完成任务

String taskId="47502";

demo.getTaskService().complete(taskId);

下面看一下ACT_RU_TASK，里面没有任务信息了，所以侧面证明循环次数的配置就是正确的。

接下来我们测试并行任务。除了isSequential="false",其他的配置是一样的。

1.1.2.2.并行的配置测试

除了isSequential="false",其他的配置跟上面的串行是一样一样的。

重新部署测试，部署后我们启动一个新的流程测试。

ACT_RU_TASK表如下：

一次性的有2个任务需要处理，因为我们循环的是2次，所以直接就是2个。

ok串行、并行就讲解到这里。

1.1.3.串行、并行总结

我们配置的是循环2次，看以看到不管是并行还是串行，两个代办任务结束之后，流程直接跳转到下一个状态，但是

我们并没有配置结束条件，所以上面的例子，也可以看出来，如果不配置默认的通过条件，则默认条件是1，后面的源码章节会给大家说明这一点的。

1.1.4.通过条件的配置

在上面的串行、并行实例中，我们没有设置通过条件，但是程序按照配置的循环的次数，然后跳转到了下一个状态，可以侧面印证，如果不配置通过条件则默认值就是1.

下面的代码详细的介绍通过条件的配置，具体的配置代码如下：

<?xml version="1.0" encoding="UTF-8"?>

<definitions xmlns="/spec/BPMN/0524/MODEL" xmlns:xsi="/2001/XMLSchema-instance" xmlns:xsd="/2001/XMLSchema" xmlns:activiti="/bpmn" xmlns:bpmndi="/spec/BPMN/0524/DI" xmlns:omgdc="/spec/DD/0524/DC" xmlns:omgdi="/spec/DD/0524/DI" typeLanguage="/2001/XMLSchema" expressionLanguage="/1999/XPath" targetNamespace="daling">

<process id="daling" name="name_daling" isExecutable="true" activiti:candidateStarterUsers="a,b,c,d">

<startEvent id="startevent1" name="Start"></startEvent>

<userTask id="usertask1" name="多实例任务" activiti:candidateUsers="shareniu1,shareniu2,shareniu3,shareniu4">

<multiInstanceLoopCharacteristics isSequential="false">

<loopCardinality>4</loopCardinality>

<completionCondition>${nrOfCompletedInstances/nrOfInstances >= 0.25}</completionCondition>

</multiInstanceLoopCharacteristics>

</userTask>

<sequenceFlow id="flow1" sourceRef="startevent1" targetRef="usertask1"></sequenceFlow>

<endEvent id="endevent1" name="End"></endEvent>

<sequenceFlow id="flow2" sourceRef="usertask1" targetRef="endevent1"></sequenceFlow>

</process>

<bpmndi:BPMNDiagram id="BPMNDiagram_daling">

<bpmndi:BPMNPlane bpmnElement="daling" id="BPMNPlane_daling">

<bpmndi:BPMNShape bpmnElement="startevent1" id="BPMNShape_startevent1">

<omgdc:Bounds height="35.0" width="35.0" x="180.0" y="150.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNShape bpmnElement="usertask1" id="BPMNShape_usertask1">

<omgdc:Bounds height="55.0" width="105.0" x="371.0" y="140.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNShape bpmnElement="endevent1" id="BPMNShape_endevent1">

<omgdc:Bounds height="35.0" width="35.0" x="660.0" y="150.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNEdge bpmnElement="flow1" id="BPMNEdge_flow1">

<omgdi:waypoint x="215.0" y="167.0"></omgdi:waypoint>

<omgdi:waypoint x="371.0" y="167.0"></omgdi:waypoint>

</bpmndi:BPMNEdge>

<bpmndi:BPMNEdge bpmnElement="flow2" id="BPMNEdge_flow2">

<omgdi:waypoint x="476.0" y="167.0"></omgdi:waypoint>

<omgdi:waypoint x="660.0" y="167.0"></omgdi:waypoint>

</bpmndi:BPMNEdge>

</bpmndi:BPMNPlane>

</bpmndi:BPMNDiagram>

</definitions>

1.1.4.1.配置描述

<completionCondition>${nrOfCompletedInstances/nrOfInstances >= 0.25}</completionCondition>

nrOfCompletedInstances、nrOfInstances 变量描述上面已经描述了，我们这里设置的条件是大于1/4的人完成任务，任务就结束了。下面我们代码部署流程，启动流程后进行测试：

ACT_RU_TASK表如下：

我们随便结束一个任务，看一下ACT_RU_TASK表变化。

StringtaskId="60038";

demo.getTaskService().complete(taskId);

执行上面的代码，我们很神奇的发现，ACT_RU_TASK表中的其他任务没有了，因为我们配置了4个人，通过条件是1/4,所以任意一个人结束了，流程就结束了。这里我们测试的是并行，串行也是一样的，读者可以自行测试验证。

1.1.5.动态的配置

上面的几种方式，我们定义xml的时候，循环的次数是固定写在xml中的，也就是说我们配置的是循环2次，那么所有的流程实例都是循环2次，这样就不灵活了，程序当然是灵活了比较好，所以在实际开发中，我们可以使用下面的这种方式操作，使程序更加的灵活。

程序的xml配置如下所示：

<?xml version="1.0" encoding="UTF-8"?>

<definitions xmlns="/spec/BPMN/0524/MODEL" xmlns:xsi="/2001/XMLSchema-instance" xmlns:xsd="/2001/XMLSchema" xmlns:activiti="/bpmn" xmlns:bpmndi="/spec/BPMN/0524/DI" xmlns:omgdc="/spec/DD/0524/DC" xmlns:omgdi="/spec/DD/0524/DI" typeLanguage="/2001/XMLSchema" expressionLanguage="/1999/XPath" targetNamespace="daling">

<process id="daling" name="name_daling" isExecutable="true" activiti:candidateStarterUsers="a,b,c,d">

<startEvent id="startevent1" name="Start"></startEvent>

<userTask id="usertask1" name="多实例任务" activiti:assignee="${assignee}">

<multiInstanceLoopCharacteristics isSequential="false" activiti:collection="assigneeList" activiti:elementVariable="assignee">

<completionCondition>${nrOfCompletedInstances/nrOfInstances >= 0.25}</completionCondition>

</multiInstanceLoopCharacteristics>

</userTask>

<endEvent id="endevent1" name="End"></endEvent>

<sequenceFlow id="flow2" sourceRef="usertask1" targetRef="endevent1"></sequenceFlow>

<userTask id="usertask2" name="User Task"></userTask>

<sequenceFlow id="flow3" sourceRef="startevent1" targetRef="usertask2"></sequenceFlow>

<sequenceFlow id="flow4" sourceRef="usertask2" targetRef="usertask1"></sequenceFlow>

</process>

<bpmndi:BPMNDiagram id="BPMNDiagram_daling">

<bpmndi:BPMNPlane bpmnElement="daling" id="BPMNPlane_daling">

<bpmndi:BPMNShape bpmnElement="startevent1" id="BPMNShape_startevent1">

<omgdc:Bounds height="35.0" width="35.0" x="180.0" y="150.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNShape bpmnElement="usertask1" id="BPMNShape_usertask1">

<omgdc:Bounds height="55.0" width="105.0" x="371.0" y="140.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNShape bpmnElement="endevent1" id="BPMNShape_endevent1">

<omgdc:Bounds height="35.0" width="35.0" x="660.0" y="150.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNShape bpmnElement="usertask2" id="BPMNShape_usertask2">

<omgdc:Bounds height="55.0" width="105.0" x="330.0" y="50.0"></omgdc:Bounds>

</bpmndi:BPMNShape>

<bpmndi:BPMNEdge bpmnElement="flow2" id="BPMNEdge_flow2">

<omgdi:waypoint x="476.0" y="167.0"></omgdi:waypoint>

<omgdi:waypoint x="660.0" y="167.0"></omgdi:waypoint>

</bpmndi:BPMNEdge>

<bpmndi:BPMNEdge bpmnElement="flow3" id="BPMNEdge_flow3">

<omgdi:waypoint x="197.0" y="150.0"></omgdi:waypoint>

<omgdi:waypoint x="382.0" y="105.0"></omgdi:waypoint>

</bpmndi:BPMNEdge>

<bpmndi:BPMNEdge bpmnElement="flow4" id="BPMNEdge_flow4">

<omgdi:waypoint x="382.0" y="105.0"></omgdi:waypoint>

<omgdi:waypoint x="423.0" y="140.0"></omgdi:waypoint>

</bpmndi:BPMNEdge>

</bpmndi:BPMNPlane>

</bpmndi:BPMNDiagram>

</definitions>

动态配置如下所示：

<userTask id="usertask1" name="多实例任务" activiti:assignee="${assignee}">

<multiInstanceLoopCharacteristics isSequential="false" activiti:collection="assigneeList" activiti:elementVariable="assignee">

<completionCondition>${nrOfCompletedInstances/nrOfInstances >= 0.25}</completionCondition>

</multiInstanceLoopCharacteristics>

</userTask>

参数说明：

activiti:assignee="${assignee}"

activiti:elementVariable="assignee"多实例任务依赖上面的配置${assignee}

activiti:collection="assigneeList"

三个参数结合决定了，当前节点的处理人来自assigneeList集合，注意这里是集合信息而不是字符串，所以程序的运行时候变量的赋值，如下所示：

String[]v={"shareniu1","shareniu2","shareniu3","shareniu4"};

vars.put("assigneeList", Arrays.asList(v));

StringtaskId="97515";

demo.getTaskService().complete(taskId,vars);

ok了，测试一下，确实程序如预期的所示，大功告成。

1.1.6.总结

参数的使用总结

4.activiti:candidateUsers="shareniu1,shareniu2,shareniu3,shareniu4"这个节点可以4个人审核。

5.<loopCardinality>2</loopCardinality>循环2次结束。

6.<multiInstanceLoopCharacteristics isSequential="true">串行并行的配置。

7.

<completionCondition>${nrOfCompletedInstances/nrOfInstances>= 0.25}</completionCondition>完成条件的配置。

这里我们还可以得出一个结论：

如果使用串行方式操作nrOfActiveInstances 变量始终是1，因为并行的时候才会去+1操作

本内容不代表本网观点和政治立场，如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法，并不表明网站立场。
相关阅读
activiti学习--10 并行网关

activiti学习--10 并行网关

2023-09-07

activiti学习之并行网关

activiti学习之并行网关

2021-12-04

【activiti 入门】activiti6.0之并行网关

【activiti 入门】activiti6.0之并行网关

2018-12-13

Activiti工作并行网关和融合（包容）网关使用经验总结

Activiti工作并行网关和融合（包容）网关使用经验总结

2022-03-23

扩展阅读

木器行家买瓷器 串行串出来的故事

异步串行接口 asynchronous serial interface英语短句 例句大全

GOIP移动电话网关简介

异步串行通信电路 asynchronous serial communications英语短句 例句大全

通过对话框来查看和编辑Excel表格中的数据（可避免看串行）

解决代理网关与IP地址的不一致性问题

最近发布
亲爱的 让我们不再忧伤：1000字作文素材大全

亲爱的 让我们不再忧伤：1000字作文素材大全

2024-07-16

白茉莉的催眠奇幻术：作文素材大全

白茉莉的催眠奇幻术：作文素材大全

2024-07-16

把握机遇1000字英语作文

把握机遇1000字英语作文

2024-07-16

低碳环保：1000字作文素材全收录

低碳环保：1000字作文素材全收录

2024-07-15

追寻记忆的足迹：1000字作文记忆独白

追寻记忆的足迹：1000字作文记忆独白

2024-07-15

拾贝滩涂 1000字赶海作文

拾贝滩涂 1000字赶海作文

2024-07-15

推荐专题
1000字文章 我能行1000字作文 中美贸易战论文1000字 野草读后感1000字 我爱我的祖国演讲稿1000字 成长的滋味作文1000字 我的同桌作文1000字 家乡的变化1000字作文 中华魂征文1000字左右 变形记读后感1000字 实习报告总结1000字 自我反省检讨书1000字 俗世奇人读后感1000字 古文观止读后感1000字 地雷战观后感1000字
猜你喜欢：
自我鉴定范文1000字 沙漠之花观后感1000字 征文怎么写1000字 考后反思1000字 宿舍打架检讨书1000字 逃寝检讨书1000字 我的学习生活1000字 1000字符是多少字 小说范文1000字 爱国的作文1000字 过年的作文1000字 大学生活作文1000字 关于孝的作文1000字 大学生个人年度总结1000字 为自己喝彩作文1000字 关于长征的作文1000字 初中入团申请书1000字 宿舍讲话检讨书1000字 小说1000字 怎么写检讨1000字 勇士观后感1000字 水浒传读书笔记1000字 入党积极分子思想汇报1000字 学校打架检讨书1000字 禁毒征文1000字 黄山导游词1000字 彷徨读后感1000字 美丽乡村建设总结1000字 流浪地球读后感1000字 童年读后感1000字左右
展开

1000字范文 免责声明© 2024 All Rights Reserved.

湘ICP备2024057051号网站地图XML

© 2024 All Rights Reserved.

1000字范文 免责声明