`
chenjin
  • 浏览: 163618 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

jbpm 与工作流模式 多路聚合(Multiple Merge)

    博客分类:
  • java
阅读更多
多路聚合(Multiple Merge)

Description :    A point in a workow process where two or more branches reconverge without
synchronization. If more than one branch gets activated, possibly concurrently, the activity
following the merge is started for every activation of every incoming branch.

描述:    多路合并是指在流程中某点,两条或更多分支无同步再收敛。若多于一个分支被激活,可能同时被激活,任务后的合并对于每条流入的激活分支都响应一次。

java 代码
 
  1. /* 
  2.  * JBoss, Home of Professional Open Source 
  3.  * Copyright 2005, JBoss Inc., and individual contributors as indicated 
  4.  * by the @authors tag. See the copyright.txt in the distribution for a 
  5.  * full listing of individual contributors. 
  6.  * 
  7.  * This is free software; you can redistribute it and/or modify it 
  8.  * under the terms of the GNU Lesser General Public License as 
  9.  * published by the Free Software Foundation; either version 2.1 of 
  10.  * the License, or (at your option) any later version. 
  11.  * 
  12.  * This software is distributed in the hope that it will be useful, 
  13.  * but WITHOUT ANY WARRANTY; without even the implied warranty of 
  14.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 
  15.  * Lesser General Public License for more details. 
  16.  * 
  17.  * You should have received a copy of the GNU Lesser General Public 
  18.  * License along with this software; if not, write to the Free 
  19.  * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 
  20.  * 02110-1301 USA, or see the FSF site: http://www.fsf.org. 
  21.  */  
  22. package org.jbpm.jpdl.patterns;  
  23.   
  24. import junit.framework.TestCase;  
  25.   
  26. import org.jbpm.graph.def.ProcessDefinition;  
  27. import org.jbpm.graph.exe.Token;  
  28. import org.jbpm.graph.node.Merge;  
  29.   
  30. /** 
  31.  * http://is.tm.tue.nl/research/patterns/download/swf/pat_8.swf 
  32.  */  
  33. public class Wfp08MultiMergeTest extends TestCase {  
  34.   
  35.   private static ProcessDefinition multiMergeProcessDefinition = createMultiMergeProcessDefinition();  
  36.   
  37.   public static ProcessDefinition createMultiMergeProcessDefinition() {  
  38.     ProcessDefinition processDefinition = ProcessDefinition.parseXmlString(  
  39.       "<process-definition>" +  
  40.       "  <start-state name='start'>" +  
  41.       "    <transition to='a' />" +  
  42.       "  </start-state>" +  
  43.       "  <state name='a'>" +  
  44.       "    <transition to='multichoice' />" +  
  45.       "  </state>" +  
  46.       "  <fork name='multichoice'>" +  
  47.       "    <script>" +  
  48.       "      <variable name='transitionNames' access='write' />" +  
  49.       "      <expression>" +  
  50.       "        transitionNames = new ArrayList();" +  
  51.       "        if ( scenario == 1 ) {" +  
  52.       "          transitionNames.add( \"to b\" );" +  
  53.       "        } else if ( scenario == 2 ) {" +  
  54.       "          transitionNames.add( \"to c\" );" +  
  55.       "        } else if ( scenario >= 3 ) {" +  
  56.       "          transitionNames.add( \"to b\" );" +  
  57.       "          transitionNames.add( \"to c\" );" +  
  58.       "        }" +  
  59.       "      </expression>" +  
  60.       "    </script>" +  
  61.       "    <transition name='to b' to='b' />" +  
  62.       "    <transition name='to c' to='c' />" +  
  63.       "  </fork>" +  
  64.       "  <state name='b'>" +  
  65.       "    <transition to='multimerge' />" +  
  66.       "  </state>" +  
  67.       "  <state name='c'>" +  
  68.       "    <transition to='multimerge' />" +  
  69.       "  </state>" +  
  70.       "  <merge name='multimerge'>" +  
  71.       "    <transition to='d' />" +  
  72.       "  </merge>" +  
  73.       "  <state name='d' />" +  
  74.       "</process-definition>"  
  75.     );  
  76.             
  77.     return processDefinition;  
  78.   }  
  79.   
  80.   public void testMultiMergeScenario1() {  
  81.     ProcessDefinition pd = multiMergeProcessDefinition;  
  82.     Token root = Wfp06MultiChoiceTest.executeScenario(pd,1);  
  83.     Token tokenB = root.getChild("to b");   
  84.     tokenB.signal();  
  85.     assertSame( pd.getNode("d"), tokenB.getNode() );  
  86.   }  
  87.     
  88.   public void testMultiMergeScenario2() {  
  89.     ProcessDefinition pd = multiMergeProcessDefinition;  
  90.     Token root = Wfp06MultiChoiceTest.executeScenario(pd,2);  
  91.     Token tokenC = root.getChild("to c");   
  92.     tokenC.signal();  
  93.     assertSame( pd.getNode("d"), tokenC.getNode() );  
  94.   }  
  95.     
  96.   private static ProcessDefinition synchronizingMultiMergeProcessDefinition = createSynchronizingMultiMergeProcessDefinition();  
  97.   
  98.   public static ProcessDefinition createSynchronizingMultiMergeProcessDefinition() {  
  99.     ProcessDefinition pd = createMultiMergeProcessDefinition();  
  100.   
  101.     // get the multimerge handler  
  102.     Merge merge = (Merge) pd.getNode("multimerge");  
  103.     merge.setSynchronized( true );  
  104.       
  105.     return pd;  
  106.   }  
  107.   
  108.   public void testMultiMergeScenario3() {  
  109.     ProcessDefinition pd = synchronizingMultiMergeProcessDefinition;  
  110.     Token root = Wfp06MultiChoiceTest.executeScenario(pd,3);  
  111.     Token tokenB = root.getChild("to b");   
  112.     Token tokenC = root.getChild("to c");  
  113.       
  114.     tokenB.signal();  
  115.     assertSame( pd.getNode("multimerge"), tokenB.getNode() );  
  116.     assertSame( pd.getNode("c"), tokenC.getNode() );  
  117.       
  118.     tokenC.signal();  
  119.     assertSame( pd.getNode("d"), tokenB.getNode() );  
  120.     assertSame( pd.getNode("d"), tokenC.getNode() );  
  121.   }  
  122.     
  123.   public void testMultiMergeScenario4() {  
  124.     ProcessDefinition pd = synchronizingMultiMergeProcessDefinition;  
  125.     Token root = Wfp06MultiChoiceTest.executeScenario(pd,4);  
  126.     Token tokenB = root.getChild("to b");   
  127.     Token tokenC = root.getChild("to c");  
  128.       
  129.     tokenC.signal();  
  130.     assertSame( pd.getNode("b"), tokenB.getNode() );  
  131.     assertSame( pd.getNode("multimerge"), tokenC.getNode() );  
  132.       
  133.     tokenB.signal();  
  134.     assertSame( pd.getNode("d"), tokenB.getNode() );  
  135.     assertSame( pd.getNode("d"), tokenC.getNode() );  
  136.   }  
  137.   
  138.   public void testMultiMergeScenario5() {  
  139.     ProcessDefinition pd = multiMergeProcessDefinition;  
  140.     Token root = Wfp06MultiChoiceTest.executeScenario(pd,5);  
  141.     Token tokenB = root.getChild("to b");   
  142.     Token tokenC = root.getChild("to c");  
  143.       
  144.     tokenB.signal();  
  145.     assertSame( pd.getNode("d"), tokenB.getNode() );  
  146.     assertSame( pd.getNode("c"), tokenC.getNode() );  
  147.       
  148.     tokenC.signal();  
  149.     assertSame( pd.getNode("d"), tokenB.getNode() );  
  150.     assertSame( pd.getNode("d"), tokenC.getNode() );  
  151.   }  
  152.   
  153.   public void testMultiMergeScenario6() {  
  154.     ProcessDefinition pd = multiMergeProcessDefinition;  
  155.     Token root = Wfp06MultiChoiceTest.executeScenario(pd,6);  
  156.     Token tokenB = root.getChild("to b");   
  157.     Token tokenC = root.getChild("to c");  
  158.       
  159.     tokenC.signal();  
  160.     assertSame( pd.getNode("b"), tokenB.getNode() );  
  161.     assertSame( pd.getNode("d"), tokenC.getNode() );  
  162.       
  163.     tokenB.signal();  
  164.     assertSame( pd.getNode("d"), tokenB.getNode() );  
  165.     assertSame( pd.getNode("d"), tokenC.getNode() );  
  166.   }  
  167. }  


流程定义文件:


xml 代码
 
  1. <process-definition>  
  2.       <start-state name='start'>  
  3.         <transition to='a' />  
  4.       </start-state>  
  5.       <state name='a'>  
  6.         <transition to='multichoice' />  
  7.       </state>  
  8.       <fork name='multichoice'>  
  9.         <script>  
  10.           <variable name='transitionNames' access='write' />  
  11.           <expression>  
  12.             transitionNames = new ArrayList();  
  13.             if ( scenario == 1 ) {  
  14.               transitionNames.add( \"to b\" );  
  15.             } else if ( scenario == 2 ) {  
  16.               transitionNames.add( \"to c\" );  
  17.             } else if ( scenario >= 3 ) {  
  18.               transitionNames.add( \"to b\" );  
  19.               transitionNames.add( \"to c\" );  
  20.             }  
  21.           </expression>  
  22.         </script>  
  23.         <transition name='to b' to='b' />  
  24.         <transition name='to c' to='c' />  
  25.       </fork>  
  26.       <state name='b'>  
  27.         <transition to='multimerge' />  
  28.       </state>  
  29.       <state name='c'>  
  30.         <transition to='multimerge' />  
  31.       </state>  
  32.       <merge name='multimerge'>  
  33.         <transition to='d' />  
  34.       </merge>  
  35.       <state name='d' />  
  36.  </process-definition>  


testMultiMergeScenario1()

节点流程执行顺序:

    start -> a --> multichoice --> b --> multimerge --> d

testMultiMergeScenario2()

节点流程执行顺序:

    start -> a --> multichoice --> c  --> multimerge--> d

testMultiMergeScenario3()
注意该方法,在multimerge 会同步等待
节点流程执行顺序:

    start -> a --> multichoice --> b  --> multimerge--> d
                 multichoice --> c  --> multimerge--> d

testMultiMergeScenario4()
注意该方法,在multimerge 会同步等待
节点流程执行顺序:

    start -> a --> multichoice --> b  --> multimerge--> d
                 multichoice --> c  --> multimerge--> d

testMultiMergeScenario5()

节点流程执行顺序:

    start -> a --> multichoice --> b  --> multimerge--> d
                 multichoice --> c  --> multimerge--> d

testMultiMergeScenario6()

节点流程执行顺序:

    start -> a --> multichoice --> b  --> multimerge--> d
                 multichoice --> c  --> multimerge--> d

注意该类中同步设置.
 Merge merge = (Merge) pd.getNode("multimerge");
    merge.setSynchronized( true );

分享到:
评论
2 楼 tonysnss 2007-05-17  
<merge name='multimerge'>  
        <transition to='d' />  
      </merge>
这个结点为什么在eclipse plugin的jbpm设计器上画不出来
1 楼 lovevirus 2006-12-18  
fork也可以实现你这个功能的阿

相关推荐

    jBPM4工作流应用开发指南.pdf

    jBPM4作为该系列的一个版本,提供了一套完整的流程管理和执行框架,允许开发者构建灵活的工作流应用,以实现业务流程自动化。本指南由胡奇编写,旨在为开发者提供一个全面的参考,帮助他们快速学习和掌握使用jBPM4...

    JBPM5工作流引擎 S2SH+JBPM4.4开发工作流的一个完整的请假流程例子

    JBPM5工作流引擎 S2SH+JBPM4.4开发工作流的一个完整的请假流程例子。带有文档教程和所有源码+JAR包。在网上找了半天jbpm6\jbpm7的资料,都很少。所以 环境:Myeclipse2015 JDK1.7 mysql 5.0 Struts2+Spring3.1 1...

    JBPM3.2工作流开发指南

    JBPM3.2工作流开发指南 JBPM是一个扩展性很强的工作流系统,百分百用JAVA语言开发,持久层采用Hibernate实现,理论上说,只要Hibernate支持的数据库JBPM都支持。同时它还能被部署在任何一款JAVA应用服务器上。

    jbpm工作流引擎总结文档

    jbpm工作流引擎基于J2EE的轻量级,纯java,开源的工作流管理系统。

    jbpm工作流整合

    jbpm工作流整合是一个关键的主题,它涉及到企业级业务流程管理(BPM)系统的实施与集成。jbpm是一个开源的工作流管理系统,它提供了一套全面的工具和框架,用于设计、执行、监控和优化业务流程。这个压缩包可能包含...

    jbpm Java工作流 教程

    JBPM设计之初就考虑到了与Java环境的无缝集成,其API提供了丰富的功能,便于开发者在Java应用程序中嵌入工作流逻辑。例如: 1. **流程实例的启动**:通过调用JBPM API,可以在Java代码中启动一个流程实例。 2. **...

    jBPM工作流详解

    此外,jBPM通过API和事件机制允许自定义扩展,如添加新的工作流服务或者与外部系统交互。 **4. 决策管理与规则引擎** jBPM内嵌了Drools规则引擎,允许在流程中嵌入复杂的业务决策。Drools支持基于DRD(Decision ...

    jBPM4工作流应用开发指南完整版带书签

    由于给出的内容是由图片格式转换而来,我们无法直接获取这部分内容的具体文字...开发者可通过这份指南获得在不同业务场景中部署和管理jBPM4工作流的深入理解与技能,进而在企业环境中实现高效和灵活的业务流程自动化。

    JBPM4工作流介绍.ppt

    本篇文章将对JBPM4工作流进行详细的介绍,涵盖工作流的概念、工作流引擎、工作流管理系统等方面的知识点。 一、工作流的概念 工作流是指在一个工作群组中,为了达成某一个共同目的而需要多人协力以串行或平行工作...

    基于JBPM工作流的OA办公系统

    在基于JBPM的OA办公系统中,工作流引擎负责解析流程定义,控制流程实例的执行,并与实际业务逻辑相结合,确保流程按照预设规则运行。 ### 2. JBPM的主要特点 - **可视化建模**:JBPM提供了一款名为BPMN(Business ...

    JBPM4工作流介绍.pptx

    JBPM4是一款强大的工作流管理系统,专为JavaEE开发人员设计,旨在解决复杂流程管理和变更需求。本课程适合对JavaEE开发有经验的技术人员以及流程分析师。JBPM4提供了广泛的应用场景,涵盖了关键业务流程,如订单处理...

    jBPM4工作流应用开发指南.rar

    **jBPM4工作流应用开发指南** jBPM4是一款强大的开源工作流管理系统,它为业务流程管理和执行提供了一套完整的解决方案。本指南将深入探讨jBPM4的特性和使用方法,帮助开发者实现高效的工作流应用开发。 **1. jBPM...

    jbpm工作流 基础视频

    jbpm工作流是一款开源的工作流程管理系统,主要用于设计、执行和管理业务流程。它结合了Java技术和BPM(Business Process Management)理念,为开发者提供了一套强大的工具,使得企业能够更有效地自动化和优化业务...

    jBPM4工作流应用开发指南最新版_01.pdf

    jBPM4工作流应用开发指南最新版_01 JBPM4详细指南,非常实用,我就是通过这个文档学习起来的,相当受益

    jBPM4工作流应用开发指南(高清,带书签)

    jBPM4工作流应用开发指南,很详细很全面,高清带书签的,适合新手入门

    jbpm4.3 工作流实例 java

    【jbpm4.3 工作流实例与Java结合详解】 在信息技术领域,工作流管理系统(Workflow Management System,简称WfMS)是用于自动化业务流程的软件系统。jbpm(Business Process Management)是一款开源的工作流引擎,...

    JBPM工作流全套学习资料

    【JBPM工作流全套学习资料】是一份详尽的学习资源,涵盖了JBPM工作流系统的基础到高级知识。JBPM(Java Business Process Management)是开源的企业级工作流管理系统,它允许开发者设计、部署和执行业务流程。这个...

    jBPM4工作流示例jbpmDemo

    **jbPM4工作流示例jbpmDemo**是一款基于jBPM4的工作流管理系统实例,旨在帮助用户深入了解和掌握jBPM4工作流引擎的使用方法。jBPM4是一款强大的开源工作流管理系统,它提供了流程建模、执行以及监控等功能,广泛应用...

    jbpm开发指南 jbpm 工作流 自定义

    jbpm开发指南 jbpm开发指南 jbpm 工作流 自定义

    jBPM4.4工作流开发指南(改进版)

    jBPM4.4工作流开发指南(改进版) 开发环境搭建

Global site tag (gtag.js) - Google Analytics