完整的jBPM4 PVM介紹發(fā)表在《程序員》第8期，這里截取部分的意思是 PVM的過程調(diào)度是非常靈活的，PVM提供了一套和token類似的execution過程調(diào)度機(jī)制，通過對execution的完全操控，節(jié)點(diǎn)運(yùn)行期行為有了無限的可能 。

?

?

PVM的流程定義模型

首先要說明的是，上圖里的類全是接口。位于最上層的是ObservableElement，其提供給流程元素以附加Event（事件）的能力。在ObservableElementImpl里，它持有一個events的集合屬性。對于流程元素來說，典型的事件有：流程啟動/結(jié)束，節(jié)點(diǎn)啟動/結(jié)束和轉(zhuǎn)移線執(zhí)行（take）。

      protected Map<String, EventImpl> events;
    

?

Event又做了些什么呢？EventImpl透過EventListenerReference實(shí)例的集合持有EventListener實(shí)例。這樣在引擎執(zhí)行過程調(diào)度時，就非常容易地通過流程元素本身獲取事件監(jiān)聽器并在相應(yīng)的時候執(zhí)行它們。

      protected List<EventListenerReference> listenerReferences;
    

?

和傳統(tǒng)的觀察者模式一致，EventListener接口有且只有一個方法：

      void notify(EventListenerExecution execution) throws Exception;
    

?

緊接著ObservableElement的是CompositeElement，其擴(kuò)展了ObservableElement接口。先看看它的方法：

        List<? extends Activity> getActivities();

  boolean hasActivity(String activityName);

  Activity getActivity(String activityName);
    

?

很明顯，它持有了Activity的集合，對于ProcessDefinition來說，這是一件很自然地事情：流程定義包含多個節(jié)點(diǎn)定義。重要的是Activity自身華麗的變身：節(jié)點(diǎn)定義實(shí)現(xiàn)了嵌套，出現(xiàn)了結(jié)構(gòu)塊。看圖說話：

這一設(shè)計在jBPM3里是沒有的，但是在jBPM4里則必須出現(xiàn)，因?yàn)榻Y(jié)構(gòu)塊是BPEL和BPMN里的重要概念。既然號稱PVM，則必須向BPEL和BPMN致敬。稍后我們可以看到，結(jié)構(gòu)塊的引入給引擎過程調(diào)度增加了很大的復(fù)雜度。在jPDL里，與之對應(yīng)的實(shí)現(xiàn)是group。這是jBPM4流程定義模型的最重要改變。

ProcessDefinition和Activity分別繼承自CompositeElement，Activity和Transition建立起雙向關(guān)聯(lián)，這三者也是工作流模型里的標(biāo)準(zhǔn)建模。

PVM的過程調(diào)度
jBPM4采用execution來記錄當(dāng)前流程執(zhí)行的位置，并通過移動execution來推動流程的流轉(zhuǎn)。

        /** transient cached current activity pointer.  persistence is managed in {@link #activityName} */
  private ActivityImpl activity;

  /** transition is not to be made persistable by default */
  protected TransitionImpl transition;
    

?

execution通過activity和transition屬性來記錄位置。

execution是可以嵌套的，即會存在一種父子關(guān)系構(gòu)成樹狀結(jié)構(gòu)，在任何時間，只有葉子execution處于活動狀態(tài)。最上層的execution稱為根execution，jBPM4里，根execution即為流程實(shí)例（在jBPM3里，記錄流程執(zhí)行位置的token和流程實(shí)例processInstance是獨(dú)立分開的）。

在兩種情況下，execution會產(chǎn)生子execution。一種情況是流程定義里存在并發(fā)路徑，此時execution會根據(jù)并發(fā)的路徑個數(shù)產(chǎn)生相應(yīng)的子execution，子execution執(zhí)行完畢并匯聚后則會觸發(fā)它們的父execution繼續(xù)流轉(zhuǎn)。另外一種情況是節(jié)點(diǎn)定義存在自己的變量定義和時間服務(wù)定義，則執(zhí)行該節(jié)點(diǎn)時會為該節(jié)點(diǎn)產(chǎn)生一個獨(dú)立的子execution，產(chǎn)生該execution的目的在于使得該節(jié)點(diǎn)擁有獨(dú)立的作用域，這個子execution也被稱為scope execution。節(jié)點(diǎn)執(zhí)行完畢后，與之關(guān)聯(lián)的scope execution將會被移除，同時，父execution被重新激活流轉(zhuǎn)。

1、 execution的移動
execution的移動操作被封裝在atomicOperation里。execution通過執(zhí)行atomicOperation來推動其的轉(zhuǎn)移。目前移動execution的atomicOperation有7種，如下圖所示：

ExecutionActivity執(zhí)行節(jié)點(diǎn)定義的運(yùn)行期行為。節(jié)點(diǎn)的運(yùn)行期行為委派給ActivityBehaviour實(shí)現(xiàn)，當(dāng)需要對節(jié)點(diǎn)行為進(jìn)行擴(kuò)展時，需要實(shí)現(xiàn)ActivityBehaviour接口。jBPM4存在兩個對節(jié)點(diǎn)行為進(jìn)行擴(kuò)展的接口，分別是ActivityBehaviour和ExternalActivityBehaviour，ActivityBehaviour的execute方法在節(jié)點(diǎn)被執(zhí)行時調(diào)用；ExternalActivityBehaviour繼承自ActivityBehaviour，多出一個signal方法，在節(jié)點(diǎn)處于等待狀態(tài)被觸發(fā)流轉(zhuǎn)時調(diào)用。

      ActivityBehaviour activityBehaviour = activity.getBehaviour();

activityBehaviour.execute(execution);
    

?

Signal執(zhí)行節(jié)點(diǎn)定義的運(yùn)行期signal方法。

      ExternalActivityBehaviour externalActivityBehaviour =     (ExternalActivityBehaviour) activity.getBehaviour();

externalActivityBehaviour.signal(execution,signalName, parameters);
    

?

一個典型的signal方法會調(diào)用execution的take方法，從而將execution移動至給定的轉(zhuǎn)移線上。jPDL里StateActivity類的signal方法：

      execution.take(transition);
    

?

看看execution的take方法，設(shè)置execution位置并執(zhí)行TransitionEndActivity：

      //設(shè)置當(dāng)前execution的位置
setTransition((TransitionImpl) transition);
    //觸發(fā)事件，執(zhí)行TRANSITION_END_ACTIVITY原子操作
fire(Event.END,getActivity(),AtomicOperation.
TRANSITION_END_ACTIVITY);
    

?

TransitionEndActivity銷毀移出節(jié)點(diǎn)的scope execution，接著執(zhí)行TransitionTake：

      //如果activity存在scope execution的話，則銷毀，返回父execution
if (activity.isLocalScope()) {
      propagatingExecution = execution.destroyScope(activity);
     }
//父execution執(zhí)行TRANSITION_TAKE原子操作
propagatingExecution.performAtomicOperation(AtomicOperation.
   TRANSITION_TAKE);
    

?

TransitionTake觸發(fā)轉(zhuǎn)移線的take事件，并執(zhí)行TransitionStartActivity：

      execution.fire(Event.TAKE,transition,AtomicOperation.
     TRANSITION_START_ACTIVITY);
    

?

TransitionStartActivity設(shè)置execution位置為目標(biāo)節(jié)點(diǎn)，創(chuàng)建scope execution并執(zhí)行ExecutionActivity：

      //設(shè)置當(dāng)前execution的位置
execution.setActivity(activity);

ExecutionImpl propagatingExecution = execution;
//如果activity存在scope的話，則創(chuàng)建scope execution
    if (activity.isLocalScope()) {
        propagatingExecution = execution.createScope(activity);
}

propagatingExecution.setTransition(null);
//scope execution執(zhí)行EXECUTE_ACTIVITY原子操作
propagatingExecution.performAtomicOperation(AtomicOperation.
    EXECUTE_ACTIVITY);
    

?

上述5種原子操作構(gòu)成了一個完整的execution節(jié)點(diǎn)間移動過程，分別是：執(zhí)行節(jié)點(diǎn)、觸發(fā)流轉(zhuǎn)、結(jié)束源節(jié)點(diǎn)、執(zhí)行轉(zhuǎn)移線和開始目標(biāo)節(jié)點(diǎn)。如果節(jié)點(diǎn)是自動節(jié)點(diǎn)（沒有等待狀態(tài)），則觸發(fā)流轉(zhuǎn)（signal）這一步操作不會執(zhí)行。

存在結(jié)構(gòu)塊的情況下，TransitionEndActivity會依次觸發(fā)父節(jié)點(diǎn)的結(jié)束事件，前提是下一個目標(biāo)節(jié)點(diǎn)未被父節(jié)點(diǎn)所包含，如果包含，則屬于結(jié)構(gòu)塊內(nèi)的節(jié)點(diǎn)移動；TransitionStartActivity會依次觸發(fā)父節(jié)點(diǎn)的開始事件，前提同樣是上一個源節(jié)點(diǎn)未被該父節(jié)點(diǎn)所包含，不屬于結(jié)構(gòu)塊內(nèi)的節(jié)點(diǎn)移動。

MoveToParentActivity使用在節(jié)點(diǎn)執(zhí)行或signal時沒有指定傳播方式，同時又找不到移出的轉(zhuǎn)移線時，會去執(zhí)行父節(jié)點(diǎn)的signal操作。MoveToChildActivity使用在節(jié)點(diǎn)含有子節(jié)點(diǎn)時，將execution轉(zhuǎn)移至子節(jié)點(diǎn)執(zhí)行。這兩種原子操作共同構(gòu)成了進(jìn)入和結(jié)束結(jié)構(gòu)塊時execution的移動行為。

?