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

jbpm与工作流模式 同步汇聚(Synchronizing Merge)

    博客分类:
  • java
阅读更多
同步汇聚(Synchronizing Merge)


Description : A point in the workow process where multiple paths converge into one single
thread. If more than one path is taken, synchronization of the active threads needs to take place.
If only one path is taken, the alternative branches should reconverge without synchronization.
It is an assumption of this pattern that a branch that has already been activated, cannot be
activated again while the merge is still waiting for other branches to complete.
Synonyms Synchronizing join.


描述 :    流程中某点多条路径聚合成一个线程,若多于一条路径触发,则活动线程需同步;若仅
有一条路径触发,则可选分支应再收敛,无需同步.

同义词:    Synchronizing join.

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.*;  
  25.   
  26. import org.jbpm.graph.def.*;  
  27. import org.jbpm.graph.exe.*;  
  28.   
  29. public class Wfp07SynchronizingMergeTest extends TestCase {  
  30.   
  31.   private static ProcessDefinition synchronizingMergeProcessDefinition = createSynchronizingMergeProcessDefinition();  
  32.   
  33.   public static ProcessDefinition createSynchronizingMergeProcessDefinition() {  
  34.     ProcessDefinition pd = Wfp06MultiChoiceTest.createMultiChoiceProcessDefinition();  
  35.     return pd;  
  36.   }  
  37.   
  38.   public void testSynchronizingMergeScenario1() {  
  39.     ProcessDefinition pd = synchronizingMergeProcessDefinition;  
  40.   
  41.     Token root = Wfp06MultiChoiceTest.executeScenario(pd,1);  
  42.     Token tokenB = root.getChild("to b"); // the default token names are extracted from the leaving transitions   
  43.   
  44.     tokenB.signal();  
  45.     assertSame( pd.getNode("end"), root.getNode() );  
  46.     assertSame( pd.getNode("syncmerge"), tokenB.getNode() );  
  47.   }  
  48.   
  49.   public void testSynchronizingMergeScenario2() {  
  50.     ProcessDefinition pd = synchronizingMergeProcessDefinition;  
  51.   
  52.     Token root = Wfp06MultiChoiceTest.executeScenario(pd,2);  
  53.     Token tokenC = root.getChild("to c"); // the default token names are extracted from the leaving transitions  
  54.   
  55.     tokenC.signal();  
  56.     assertSame( pd.getNode("end"), root.getNode() );  
  57.     assertSame( pd.getNode("syncmerge"), tokenC.getNode() );  
  58.   }  
  59.   
  60.   public void testSynchronizingMergeScenario3() {  
  61.     ProcessDefinition pd = synchronizingMergeProcessDefinition;  
  62.   
  63.     Token root = Wfp06MultiChoiceTest.executeScenario(pd,3);  
  64.     Token tokenB = root.getChild("to b"); // the default token names are extracted from the leaving transitions   
  65.     Token tokenC = root.getChild("to c"); // the default token names are extracted from the leaving transitions  
  66.   
  67.     tokenB.signal();  
  68.     assertSame( pd.getNode("multichoice"), root.getNode() );  
  69.     assertSame( pd.getNode("syncmerge"), tokenB.getNode() );  
  70.     assertSame( pd.getNode("c"), tokenC.getNode() );  
  71.   
  72.     tokenC.signal();  
  73.     assertSame( pd.getNode("end"), root.getNode() );  
  74.     assertSame( pd.getNode("syncmerge"), tokenB.getNode() );  
  75.     assertSame( pd.getNode("syncmerge"), tokenC.getNode() );  
  76.   }  
  77.   
  78.   public void testSynchronizingMergeScenario4() {  
  79.     ProcessDefinition pd = synchronizingMergeProcessDefinition;  
  80.   
  81.     Token root = Wfp06MultiChoiceTest.executeScenario(pd,3);  
  82.     Token tokenB = root.getChild("to b"); // the default token names are extracted from the leaving transitions   
  83.     Token tokenC = root.getChild("to c"); // the default token names are extracted from the leaving transitions  
  84.   
  85.     tokenC.signal();  
  86.     assertSame( pd.getNode("multichoice"), root.getNode() );  
  87.     assertSame( pd.getNode("b"), tokenB.getNode() );  
  88.     assertSame( pd.getNode("syncmerge"), tokenC.getNode() );  
  89.   
  90.     tokenB.signal();  
  91.     assertSame( pd.getNode("end"), root.getNode() );  
  92.     assertSame( pd.getNode("syncmerge"), tokenB.getNode() );  
  93.     assertSame( pd.getNode("syncmerge"), tokenC.getNode() );  
  94.   }  
  95. }  


流程定义文件:

xml 代码
 
  1. <process-definition name="process">  
  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.         <transition name='to b' to='b'>  
  10.             <condition>#{scenario == 1} or #{scenario >= 3}</condition>  
  11.         </transition>  
  12.         <transition name='to c' to='c'>  
  13.             <condition>#{scenario == 2} or #{scenario >= 3}</condition>  
  14.         </transition>  
  15.     </fork>  
  16.     <state name='b'>  
  17.         <transition to='syncmerge' />  
  18.     </state>  
  19.     <state name='c'>  
  20.         <transition to='syncmerge' />  
  21.     </state>  
  22.     <join name='syncmerge'>  
  23.         <transition to='end' />  
  24.     </join>  
  25. </process-definition>  


testSynchronizingMergeScenario1()
   
当scenario == 1
节点流程如下:

    start --> a --> multichoice --> b --> syncmerge --> end

testSynchronizingMergeScenario2()
   
当scenario == 2
节点流程如下:

    start --> a --> multichoice --> c --> syncmerge --> end

testSynchronizingMergeScenario3()
   
当scenario == 3
节点流程如下:

    start --> a --> multichoice --> b --> syncmerge(先) --> end
                multichoice --> c --> syncmerge(后)

testSynchronizingMergeScenario4()
   
当scenario == 3
节点流程如下:

    start --> a --> multichoice --> b --> syncmerge(后) --> end
                      multichoice --> c --> syncmerge(先)
分享到:
评论

相关推荐

    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应用服务器上。

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

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

    JBPM4工作流介绍.ppt

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

    jbpm工作流引擎总结文档

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

    jbpm工作流整合

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

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

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

    jbpm Java工作流 教程

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

    JBPM4工作流介绍.pptx

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

    jBPM工作流详解

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

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

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

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

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

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

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

    jBPM4工作流示例jbpmDemo

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

    jbpm4.3 工作流实例 java

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

    jbpm工作流 基础视频

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

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

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

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

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

    JBPM工作流全套学习资料

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

Global site tag (gtag.js) - Google Analytics