程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> JAVA編程 >> 關於JAVA >> JBPM源碼解讀之:Fork

JBPM源碼解讀之:Fork

編輯:關於JAVA

Fork節點在整個JBPM流程運轉過程中配合Join使用提供使多於一個的節點如:TaskNode、State等並行運行的作用,很可惜我們不能利用Fork提供的現有機制實現需求中經常遇到的並發子流程的效果,當然雖然JBPM並不支持並發子流程的機制,並不代表我們不能變通的實現,我將在另一篇文章中詳細說明我的並發子流程的實現方式。

Fork類的注釋中說:if this fork behaviour is not sufficIEnt for your needs, consider writing your own custom TokenHandler.看來連JBPM開發小組也意識到Fork可能不能滿足某些特殊的需求。注釋中還說Fork節點有三種配置方式,我很奇怪為什麼代碼中只能找到兩種:

1、without configuration : in that case the fork will launch one new sub-token over each of the leaving tranisions of the fork node.

2、a script : can be used to calculate a collection of transition names at runtime. if a script is configured, the script must have exactly one variable with 'write' Access. that variable should be assigned a Java.util.Collection in the script expression.

Fork類繼承自Node並實現了Parsable接口。Fork類相對簡單,他的私有成員變量只有一個:

1/**

2 * a script that calculates the transitionNames at runtime.

3 */

4 Script script = null;

Fork中的Script可以在運行時對Fork節點選擇Transition,所以在實際應用中可以使用Fork+Script的方式進行多路路由選擇。但是有一點要特別注意:JBBM User Guide文檔中說:the script in a fork is not persisted. script in fork might be removed in later versions of jPDL,原本以為這句話的前半句是說Script不會被持久化進數據庫,實驗了才知道其實Script還是被存進了數據庫,這半句的意思應該是說"fork中的script不被堅持",JBPM開發小組要在新版本中放棄Script,我相信他們一定會提供更好的解決方案,讓我們拭目以待。 Fork重寫了Node類的read(Element forkElement, JpdlXMLReader jpdlReader)方法,其主要作用是解析JPDL中Fork節點Script的配置,並初始化自己的成員變量script.下面是execute(ExecutionContext executionContext)方法中的相關處理。

1Token token = executionContext.getToken();

2 // 聲明離開轉向的集合

3 Collection transitionNames = null;

4 //聲明子Token容器

5 List forkedTokens = new ArrayList();

6

7 // 如果沒有Script,默認按照其父類Node的getLeavingTransitionsMap取得所有離開轉向

8 if (script == null) {

9 transitionNames = getLeavingTransitionsMap().keySet();

10 } else {

11 //如果有Script,按照規范該Script應該返回一個Collection類型的數據,作為Fork的離開轉向集合

12 Map outputMap = null;

13 try {

14 //執行Script,得到返回的Collection數據

15 outputMap = script.eval(token);

16 } catch (Exception e) {

17 this.raiseException(e, executionContext);

18 }

19 if (outputMap.size() == 1) {

20 Object result = outputMap.values().iterator().next();

21 if (result instanceof Collection) {

22 transitionNames = (Collection) result;

23 }

24 }

25 if (transitionNames == null) {

26 throw new JbpmException("script for fork '" + name + "' should produce one collection (in one writable variable): " + transitionNames);

27 }

28 }

下面讓我們來看一下,Fork產生的子Token的命名方式:

1 /**

2 * 功能描述:為子Token取名字

3 * @param parent 父Token

4 * @param transitionName 離開轉向的名字

5 */

6 protected String getTokenName(Token parent, String transitionName) {

7 String tokenName = null;

8 //如果transitionName不為空

9 if (transitionName != null) {

10 //如果父Tokehn中不存在以transitionName命名的子Token

11 if (!parent.hasChild(transitionName)) {

12 //以transitionName的名字為子Token命名

13 tokenName = transitionName;

14 } else {

15 //如果已經存在則以transitionName+2的方式命名

16 int i = 2;

17 tokenName = transitionName + Integer.toString(i);

18 //如果加2之後依然存在,開始循環,直到父Token中不存在相同名稱的子Token

19 while (parent.hasChild(tokenName)) {

20 i++;

21 tokenName = transitionName + Integer.toString(i);

22 }

23 }

24 } else {

25 //如果transitionName為空,則判但父Token中是否有子Token,如果有則以parent.getChildren().size() + 1法命名,

26 //如果沒有直接命名為1

27 int size = (parent.getChildren() != null ? parent.getChildren().size() + 1 : 1);

28 tokenName = Integer.toString(size);

29 }

30 return tokenName;

31 }

名字定好之後,Fork為每個離開轉向分別創建了一個子Token,加入一開始創建的forkedTokens中。最後開始循環列表,執行Node的leave方法,並觸發Node-leave事件。

iter = forkedTokens.iterator();

while (iter.hasNext()) {

ForkedToken forkedToken = (ForkedToken) iter.next();

Token childToken = forkedToken.token;

String leavingTransitionName = forkedToken.leavingTransitionName;

ExecutionContext childExecutionContext = new ExecutionContext(childToken);

if (leavingTransitionName != null) {

leave(childExecutionContext, leavingTransitionName);

} else {

leave(childExecutionContext);

}

}

看了這段代碼我們應該明白:Fork的Node-leave事件是會執行多遍的,具體要看產生的子Token的個數。至於ForkedToken類,其實是Fork的一個內被類,只起到一個普通Bean的作用。

到這裡,Fork類的大體內容我們已經解讀完畢,但是還有一點要注意的地方:

add some way of blocking the current token here and disable that blocking when the join reactivates this token Then an exception can be thrown by in case someone trIEs to signal a token that is waiting in a fork.Suspend and resume can NOT be used for this since that will also suspend any related timers, tasks and messages……So a separate kind of blocking should be created for this.

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved