jbpm的支配应用2

jbpm的调度应用2

上篇介绍了通过跳过节点可以终止timer，其实也可以直接在流程定义里设置timer的终止，就是使用cancel-timer元素。

xml 代码

1. <?xml?version="1.0"?encoding="UTF-8"?>??
2. <process-definition?xmlns=""?name="yytest">??
3. ???<start-state?name="start">??
4. ??????<transition?name=""?to="a"></transition>??
5. ???</start-state>??
6. ???<state?name='a'>??
7. ?????<timer?name='reminder'? ??
8. ?????????????duedate='0?seconds'? ??
9. ?????????????repeat='3?seconds'>??
10. ????????<script>System.out.println(new?Date()+"----node?enter:send?mail?to?operator.");</script>??
11. ?????</timer>??
12. ?????<timer?name='reminderend'? ??
13. ?????????????duedate='12?seconds'??
14. ?????????????transition='toend'??
15. ?????????????>??
16. ????????<script>System.out.println(new?Date()+"----canceled?timer");</script>??
17. ????????<cancel-timer?name='reminder'/>??
18. ?????</timer>??
19. ?????<transition?name="toend"?to="end"></transition>??
20. ????</state>??
21. ???<end-state?name="end"></end-state>???? ??
22. </process-definition>??

reminderend 这个定时器，在12秒后调用cancel-timer终止定时器reminder，同时按照指定的transition结束流程。

java 代码

1. package?com.jeffentest; ??
2. ??
3. import?org.jbpm.*; ??
4. import?org.jbpm.graph.def.ProcessDefinition; ??
5. import?org.jbpm.graph.exe.*; ??
6. import?org.jbpm.scheduler.impl.Scheduler; ??
7. ??
8. ??
9. public?class?Jeffentest?{ ??
10. ????static?JbpmConfiguration?jbpmConfiguration?=?JbpmConfiguration.getInstance(); ??
11. ????static?ProcessDefinition?processDefinition?=?null; ??
12. ????static?ProcessInstance?processInstance?=?null; ??
13. ????static?Scheduler?scheduler?=?null; ??
14. ??
15. ????public?static?void?initSchedular()?{//设置Schedular的属性 ??
16. ????????scheduler?=?new?Scheduler(); ??
17. ????????int?interval?=?5000; ??
18. ????????scheduler.setInterval(interval); ??
19. ????????int?historyMaxSize?=?0; ??
20. ????????scheduler.setHistoryMaxSize(historyMaxSize); ??
21. ????????scheduler.start(); ??
22. ????} ??
23. ?????? ??
24. ????public?static?void?destroy()?{//这个例子没用到 ??
25. ????????scheduler.stop(); ??
26. ????} ??
27. ????static?class?MySchedularThread?extends?Thread{//实际业务处理线程 ??
28. ????????public?void?run(){ ??
29. ????????????JbpmContext?jbpmContext?=?jbpmConfiguration.createJbpmContext(); ??
30. ????????????try?{ ??
31. ????????????????long?processInstanceId?=1; ??
32. ???????????????????processInstance?=?jbpmContext.loadProcessInstance(processInstanceId); ??
33. ???????????????????Token?token?=?processInstance.getRootToken(); ??
34. ???????????????????System.out.println(token.getNode()); ??
35. ???????????????????//一定要运行到有timer生成，触发<timer?name='reminder'> ??
36. ???????????????????token.signal(); ??
37. ???????????????????System.out.println(token.getNode()); ??
38. ???????????????????jbpmContext.save(processInstance); ??
39. ???????????????????//jbpm_timer表里数据被清空、同时可以看jbpm_processinstance.end_,该流程实例也结束了 ??
40. ????????????}catch(Exception?e){ ??
41. ????????????????e.printStackTrace(); ??
42. ????????????}finally?{ ??
43. ??????????????????jbpmContext.close(); ??
44. ????????????} ??
45. ????????} ??
46. ????} ??
47. ???????? ??
48. ????public?static?void?main(String[]?args)?{ ??
49. ????????initSchedular?(); ??
50. ????????MySchedularThread?mst=new?MySchedularThread(); ??
51. ????????mst.start(); ??
52. ????} ??
53. } ??

?

运行结果：

StartState(start)
State(a)
Fri Dec 08 10:22:26 CST 2006----node enter:send mail to operator.
Fri Dec 08 10:22:31 CST 2006----node enter:send mail to operator.
Fri Dec 08 10:22:33 CST 2006----node enter:send mail to operator.
Fri Dec 08 10:22:33 CST 2006----canceled timer

说明一下，我的这两个例子都是基于state的，如果采用node则不会给timer运行的机会。

timer还有几个特殊属性是针对task节点的，见下篇吧。

1 楼 tomkoo 2006-12-13   现在项目中还没有要用到Timer的地方，不过看了这个系列的文章以后，也对Timer有了一个了解，哈哈！

查看更多 下一篇