Package org.flowable.engine.impl.bpmn.behavior

Class ParallelMultiInstanceBehavior

java.lang.Object

org.flowable.engine.impl.bpmn.behavior.FlowNodeActivityBehavior

org.flowable.engine.impl.bpmn.behavior.MultiInstanceActivityBehavior

org.flowable.engine.impl.bpmn.behavior.ParallelMultiInstanceBehavior

All Implemented Interfaces:

Serializable, ActivityBehavior, InterruptibleActivityBehaviour, SubProcessActivityBehavior, TriggerableActivityBehavior

public class ParallelMultiInstanceBehavior
extends MultiInstanceActivityBehavior

Author:

Joram Barrez, Tijs Rademakers, Filip Hrisafov

See Also:

• Serialized Form

Field Summary

Fields inherited from class org.flowable.engine.impl.bpmn.behavior.MultiInstanceActivityBehavior

activity, aggregations, collectionElementIndexVariable, collectionElementVariable, collectionExpression, collectionHandler, collectionString, collectionVariable, completionCondition, DELETE_REASON_END, innerActivityBehavior, LOGGER, loopCardinalityExpression, NUMBER_OF_ACTIVE_INSTANCES, NUMBER_OF_COMPLETED_INSTANCES, NUMBER_OF_INSTANCES

Fields inherited from class org.flowable.engine.impl.bpmn.behavior.FlowNodeActivityBehavior

bpmnActivityBehavior

Constructor Summary

Constructors

Constructor	Description
ParallelMultiInstanceBehavior(Activity activity, AbstractBpmnActivityBehavior originalActivityBehavior)

Method Summary

Modifier and Type	Method	Description
protected int	createInstances(DelegateExecution multiInstanceRootExecution)	Handles the parallel case of spawning the instances.
protected ExecutionEntity	inactivateExecution(DelegateExecution execution, ProcessEngineConfigurationImpl processEngineConfiguration)
protected void	inactivateExecutionAndParentExecutions(DelegateExecution execution, ProcessEngineConfigurationImpl processEngineConfiguration)
protected void	internalInterrupted(DelegateExecution execution)
protected void	internalLeave(DelegateExecution execution, boolean zeroNrOfInstances)
boolean	isAsyncWithoutWaitStates(ProcessEngineConfigurationImpl processEngineConfiguration)
void	leave(DelegateExecution execution)	Called when the wrapped ActivityBehavior calls the AbstractBpmnActivityBehavior.leave(DelegateExecution) method.
protected void	leave(ExecutionEntity execution, int nrOfInstances, int nrOfCompletedInstances, boolean isCompletionConditionSatisfied)
boolean	leaveAsync(ExecutionEntity execution)
protected void	lockFirstParentScope(DelegateExecution execution)
protected void	verifyCallActivity(ExecutionEntity executionToUse, Activity activity)
protected Activity	verifyCompensation(DelegateExecution execution, ExecutionEntity executionToUse, Activity activity)

Methods inherited from class org.flowable.engine.impl.bpmn.behavior.MultiInstanceActivityBehavior

aggregateVariablesForChildExecution, aggregateVariablesOfAllInstances, buildCompletedEvent, buildUnresolvedCollectionExceptionMessage, callActivityEndListeners, cleanupMiRoot, completed, completing, completionConditionSatisfied, createFlowableCollectionHandler, execute, executeCompensationBoundaryEvents, executeOriginalBehavior, findBoundaryEventsForFlowNode, getActiveValue, getAggregations, getCollectionElementIndexVariable, getCollectionElementVariable, getCollectionExpression, getCollectionString, getCollectionVariable, getCompletionCondition, getHandler, getInnerActivityBehavior, getInstanceExecution, getLocalLoopVariable, getLoopCardinalityExpression, getLoopVariable, getLoopVariableInstance, getMultiInstanceRootExecution, getProcessDefinition, hasVariableAggregationDefinitions, interrupted, isExtraScopeNeeded, iterableToCollection, lastExecutionEnded, logLoopDetails, resolveAndValidateCollection, resolveCollection, resolveLoopCardinality, resolveNrOfInstances, sendCompletedEvent, sendCompletedWithConditionEvent, setAggregations, setCollectionElementIndexVariable, setCollectionElementVariable, setCollectionExpression, setCollectionString, setCollectionVariable, setCompletionCondition, setHandler, setInnerActivityBehavior, setLoopCardinalityExpression, setLoopVariable, trigger, usesCollection

Methods inherited from class org.flowable.engine.impl.bpmn.behavior.FlowNodeActivityBehavior

leaveIgnoreConditions, parseActivityType

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ParallelMultiInstanceBehavior

public ParallelMultiInstanceBehavior(Activity activity,
 AbstractBpmnActivityBehavior originalActivityBehavior)

Method Details

createInstances

protected int createInstances(DelegateExecution multiInstanceRootExecution)

Handles the parallel case of spawning the instances. Will create child executions accordingly for every instance needed.

Specified by:

createInstances in class MultiInstanceActivityBehavior

isAsyncWithoutWaitStates

public boolean isAsyncWithoutWaitStates(ProcessEngineConfigurationImpl processEngineConfiguration)

leave

public void leave(DelegateExecution execution)

Called when the wrapped ActivityBehavior calls the AbstractBpmnActivityBehavior.leave(DelegateExecution) method. Handles the completion of one of the parallel instances

Overrides:

leave in class MultiInstanceActivityBehavior

internalLeave

protected void internalLeave(DelegateExecution execution,
 boolean zeroNrOfInstances)

inactivateExecutionAndParentExecutions

protected void inactivateExecutionAndParentExecutions(DelegateExecution execution,
 ProcessEngineConfigurationImpl processEngineConfiguration)

inactivateExecution

protected ExecutionEntity inactivateExecution(DelegateExecution execution,
 ProcessEngineConfigurationImpl processEngineConfiguration)

leaveAsync

public boolean leaveAsync(ExecutionEntity execution)

leave

protected void leave(ExecutionEntity execution,
 int nrOfInstances,
 int nrOfCompletedInstances,
 boolean isCompletionConditionSatisfied)

verifyCompensation

protected Activity verifyCompensation(DelegateExecution execution,
 ExecutionEntity executionToUse,
 Activity activity)

verifyCallActivity

protected void verifyCallActivity(ExecutionEntity executionToUse,
 Activity activity)

lockFirstParentScope

protected void lockFirstParentScope(DelegateExecution execution)

internalInterrupted

protected void internalInterrupted(DelegateExecution execution)

Overrides:

internalInterrupted in class MultiInstanceActivityBehavior