Floating source code comment (38) parallel job processor

Flowable Source code address ：https://github.com/flowable/flowable-engine

Flowable-6.7.2 Source code comment address ：https://github.com/solojin/flowable-6.7.2-annotated

Package path ：org.flowable.engine.impl.jobexecutor

ParallelMultiInstanceWithNoWaitStatesAsyncLeaveJobHandler Parallel multi instance asynchronous leave job processor without waiting state

/** *  Parallel multi instance asynchronous leave job processor without waiting state  * * @author Joram Barrez */
public class ParallelMultiInstanceWithNoWaitStatesAsyncLeaveJobHandler implements JobHandler {
    

    public static final String TYPE = "parallel-multi-instance-no-waits-async-leave";

    @Override
    public String getType() {
    
        return TYPE;
    }

    @Override
    public void execute(JobEntity job, String configuration, VariableScope variableScope, CommandContext commandContext) {
    
        ProcessEngineConfigurationImpl processEngineConfiguration = CommandContextUtil.getProcessEngineConfiguration(commandContext);
        ExecutionEntityManager executionEntityManager = processEngineConfiguration.getExecutionEntityManager();

        ExecutionEntity execution = executionEntityManager.findById(job.getExecutionId());
        if (execution != null) {
    
            FlowElement currentFlowElement = execution.getCurrentFlowElement();
            if (currentFlowElement instanceof Activity) {
    
                Object behavior = ((Activity) currentFlowElement).getBehavior();
                if (behavior instanceof ParallelMultiInstanceBehavior) {
    
                    ParallelMultiInstanceBehavior parallelMultiInstanceBehavior = (ParallelMultiInstanceBehavior) behavior;

                    DelegateExecution multiInstanceRootExecution = ExecutionGraphUtil.getMultiInstanceRootExecution(execution);
                    if (multiInstanceRootExecution != null) {
    

                        //  Optimize the activity count here ： If there is still activity execution in the database , There is no need to do anything ：
                        //  No need to get any variables , If completed 、 Activities of the nr etc. .
                        //  This work can be simply rearranged , And when things are not finished , It will try the same logic again .
                        long activeChildExecutionCount = executionEntityManager.countActiveExecutionsByParentId(multiInstanceRootExecution.getId());
                        if (activeChildExecutionCount > 0) {
    

                            List<String> boundaryEventActivityIds = ExecutionGraphUtil.getBoundaryEventActivityIds(multiInstanceRootExecution);
                            if (boundaryEventActivityIds.isEmpty()) {
    
                                reCreateJob(processEngineConfiguration, execution);

                            } else {
    
                                //  If all remaining executions are boundary event executions , You can keep multiple instances .
                                List<ExecutionEntity> boundaryEventChildExecutions = executionEntityManager
                                    .findExecutionsByParentExecutionAndActivityIds(multiInstanceRootExecution.getId(), boundaryEventActivityIds);
                                if (activeChildExecutionCount <= boundaryEventChildExecutions.size()) {
    
                                    leaveMultiInstance(processEngineConfiguration, execution, parallelMultiInstanceBehavior);

                                } else {
    
                                    reCreateJob(processEngineConfiguration, execution);

                                }

                            }

                        } else {
    
                            leaveMultiInstance(processEngineConfiguration, execution, parallelMultiInstanceBehavior);

                        }
                    }
                }
            }
        }
    }

    protected void reCreateJob(ProcessEngineConfigurationImpl processEngineConfiguration, ExecutionEntity execution) {
    
        //  This is not a common way to create jobs , Because we especially don't want asynchronous actuators to trigger .
        //  This operation should extract , To avoid continuous circulation .
        JobService jobService = processEngineConfiguration.getJobServiceConfiguration().getJobService();
        JobEntity newJob = JobUtil.createJob(execution, TYPE, processEngineConfiguration);
        jobService.createAsyncJobNoTriggerAsyncExecutor(newJob, true);
        jobService.insertJob(newJob);
    }

    protected void leaveMultiInstance(ProcessEngineConfigurationImpl processEngineConfiguration, ExecutionEntity execution,
        ParallelMultiInstanceBehavior parallelMultiInstanceBehavior) {
    
        // ParallelMultiInstanceBehavior The implementation of considers sub execution .
        //  So choose random sub execution instead of passing multiple instance root execution 
        boolean multiInstanceCompleted = parallelMultiInstanceBehavior.leaveAsync(execution);
        if (!multiInstanceCompleted) {
    
            reCreateJob(processEngineConfiguration, execution);
        }
    }


}

ParallelMultiInstanceActivityCompletionJobHandler Parallel multi instance activity completion job processor

/** *  Parallel multi instance activity completion job processor  * * @author Filip Hrisafov */
public class ParallelMultiInstanceActivityCompletionJobHandler  implements JobHandler {
    

    public static final String TYPE = "parallel-multi-instance-complete";

    @Override
    public String getType() {
    
        return TYPE;
    }

    @Override
    public void execute(JobEntity job, String configuration, VariableScope variableScope, CommandContext commandContext) {
    
        ProcessEngineConfigurationImpl processEngineConfiguration = CommandContextUtil.getProcessEngineConfiguration(commandContext);

        ExecutionEntity completingExecution = processEngineConfiguration.getExecutionEntityManager().findById(job.getExecutionId());
        if (completingExecution != null) {
    
            // It is possible that the execution completed (through another thread). In that case we ignore it.
            FlowElement currentFlowElement = completingExecution.getCurrentFlowElement();
            if (currentFlowElement instanceof Activity) {
    
                Object behavior = ((Activity) currentFlowElement).getBehavior();
                if (behavior instanceof ParallelMultiInstanceBehavior) {
    
                    ParallelMultiInstanceBehavior parallelMultiInstanceBehavior = (ParallelMultiInstanceBehavior) behavior;
                    parallelMultiInstanceBehavior.leaveAsync(completingExecution);
                }
            }
        }
    }
}