Activiti进阶（八）——并行网关（ParallelGateWay）

蔚落 2022-04-05 05:49 253阅读 0赞

上一篇博客我们讲到了排他网管，这篇博文简单介绍一下他的兄弟，并行网关。

##      一、流程图 ##

![20151222180623461][]

图一   并行网关网购流程图

在这里，我们模拟网上购物流程，四个用户任务，分别是付款、发货、收款、收货，其中付款和收货的办理人是买家，发货和收款的办理人是卖家。

##      二、部署和启动流程 ##

/**部署流程定义+启动流程实例*/
        @Test
        public void deployementAndStartProcess(){
            InputStream inputStreamBpmn = this.getClass().getResourceAsStream("parallelGateWay.bpmn");
            InputStream inputStreampng = this.getClass().getResourceAsStream("parallelGateWay.png");
            //部署流程定义
            Deployment deployment = processEngine.getRepositoryService()//
                                .createDeployment()//创建部署对象
                                .addInputStream("parallelGateWay.bpmn", inputStreamBpmn)//部署加载资源文件
                                .addInputStream("parallelGateWay.png", inputStreampng)//
                                .name("并行网关演示")
                                .deploy();
            System.out.println("部署ID："+deployment.getId());
            //启动流程实例
            ProcessInstance pi = processEngine.getRuntimeService()//
                                .startProcessInstanceByKey("parallelGateWay");//使用流程定义的key的最新版本启动流程
            System.out.println("流程实例ID："+pi.getId());
            System.out.println("流程定义的ID："+pi.getProcessDefinitionId());
        }

对应数据库表：  
     1.act\_ru\_execution

![20151222182412169][]

我们可以看到，部署和启动流程后，在act\_ru\_execution表中对应三条记录，1个流程实例，2个执行对象。

2.act\_ru\_task表     ![20151222214051564][]

在act\_ru\_task表中，有两条正在执行的任务，分别是付款和发货。

##      三、查询个人任务 ##

/**查询我的个人任务*/
        @Test
        public void findPersonalTaskList(){
            //任务办理人
            String assignee = "买家";//或商家
            List<Task> list = processEngine.getTaskService()//
                            .createTaskQuery()//
                            .taskAssignee(assignee)//个人任务的查询
                            .list();
            if(list!=null && list.size()>0){
                for(Task task:list){
                    System.out.println("任务ID："+task.getId());
                    System.out.println("任务的办理人："+task.getAssignee());
                    System.out.println("任务名称："+task.getName());
                    System.out.println("任务的创建时间："+task.getCreateTime());
                    System.out.println("流程实例ID："+task.getProcessInstanceId());
                    System.out.println("#######################################");
                }
            }
        }

我们通过设置的办理人的名字，买家和商家，可以查询到他们对应的当前任务的信息：  
     1.买家

![20151222215356387][]

2.商家

![20151222215852128][]

##      四、完成任务 ##

/**完成任务*/
        @Test
        public void completeTask(){
            //任务ID
            String taskId = "2611";
            processEngine.getTaskService()//
                            .complete(taskId);
            System.out.println("完成任务："+taskId);
        }

执行结果如下：  
     1.完成【付款】任务，第一个流程实例自动流转到下个任务：收款

![20151222220605433][]

2.完成【发货】任务，第二个流程实例自动流转到下一个任务：收货     ![20151222221215988][]  
     之后，再分别完成收款和收货两个任务，流程才能够结束。

总结：

一个流程中流程实例只有1个，执行对象有多个；并行网关的功能是基于进入和外出的顺序流的：

分支(fork)：并行后的所有外出顺序流，为每个顺序流都创建一个并发分支。

汇聚(join)：所有到达并行网关，在此等待的进入分支，直到所有进入顺序流的分支都到达以后，流程就会通  
过汇聚网关。  
\---------------------   
作者：周江霄   
来源：CSDN   
原文：https://blog.csdn.net/zjx86320/article/details/50381523   
版权声明：本文为博主原创文章，转载请附上博文链接！

[20151222180623461]: /images/20220405/d34f515ea43b42e09d28afb10eaea6eb.png
[20151222182412169]: /images/20220405/f61eaee0bec746b0878ca8775ceb88ab.png
[20151222214051564]: /images/20220405/9852ddd3f81748c189634d6007ec3b79.png
[20151222215356387]: /images/20220405/0a9b75ee13fd42f3bee769310bd55932.png
[20151222215852128]: /images/20220405/e4e6eb25ef4d4d1d9a9dd45c10e7d4f6.png
[20151222220605433]: /images/20220405/06bbf3cf64bc491291dd9db97ece6b58.png
[20151222221215988]: /images/20220405/67f6572183d2498aad85cdee725d3e1c.png