并行网关(ParallelGateWay)

一、流程图

img

​ 图一 并行网关网购流程图

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

二、部署和启动流程

/**部署流程定义+启动流程实例*/  
@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

img

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

​ 2.act_ru_task表

img

​ 在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.买家

img

​ 2.商家

img

四、完成任务

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

​ 执行结果如下:

​ 1.完成【付款】任务,第一个流程实例自动流转到下个任务:收款

img

​ 2.完成【发货】任务,第二个流程实例自动流转到下一个任务:收货

img

​ 之后,再分别完成收款和收货两个任务,流程才能够结束。

​ 总结:

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

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

​ 汇聚(join):所有到达并行网关,在此等待的进入分支,直到所有进入顺序流的分支都到达以后,流程就会通

过汇聚网关。

Logo

权威|前沿|技术|干货|国内首个API全生命周期开发者社区

更多推荐