Comments on flowable source code (37) asynchronous 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

AsyncCompleteCallActivityJobHandler Asynchronous completion invokes the active job processor

/** *  Asynchronous completion invokes the active job processor  *  Job processor that asynchronously ends execution {@link JobHandler} Realization . *  The main use case is to handle parallel multi instance invocation activities , The subprocess has an asynchronous step before reaching the end event . *  Asynchronous locking occurs at the level of child process instances , But the end event will execute to complete the parent process instance within the scope  *  Call the completion callback method of the activity , And may cause optimistic locking exceptions . *  By scheduling jobs in the context of the parent process instance , The correct lock will be used . * * @author Joram Barrez */
public class AsyncCompleteCallActivityJobHandler implements JobHandler {
    

    //  type ： Asynchronously complete the call activity 
    public static final String TYPE = "async-complete-call-actiivty";

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

    @Override
    public void execute(JobEntity job, String configuration, VariableScope variableScope, CommandContext commandContext) {
      // the executionId of the job = the parent execution, which will be used for locking
        ExecutionEntity childProcessInstanceExecutionEntity = CommandContextUtil.getExecutionEntityManager(commandContext).findById(configuration); // the child process instance execution
        CommandContextUtil.getAgenda(commandContext).planEndExecutionOperationSynchronous(childProcessInstanceExecutionEntity);
    }

}

AsyncSendEventJobHandler Asynchronously send event job processor

/** *  Asynchronously send event job processor  * * @author Tijs Rademakers */
public class AsyncSendEventJobHandler implements JobHandler {
    

    //  type ： Send events asynchronously 
    public static final String TYPE = "async-send-event";

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

    @Override
    public void execute(JobEntity job, String configuration, VariableScope variableScope, CommandContext commandContext) {
    
        ExecutionEntity executionEntity = (ExecutionEntity) variableScope;
        FlowElement flowElement = executionEntity.getCurrentFlowElement();

        if (!(flowElement instanceof SendEventServiceTask)) {
    
            throw new FlowableException(String.format("Unexpected activity type found for job %s, at activity %s", job.getId(), flowElement.getId()));
        }

        Object behavior = ((SendEventServiceTask) flowElement).getBehavior();
        if (!(behavior instanceof ActivityBehavior)) {
    
            throw new FlowableException(String.format("Unexpected activity behavior found for job %s, at activity %s: %s",
                job.getId(), flowElement.getId(), behavior.getClass()));
        }

        try {
    
            ActivityBehavior activityBehavior = (ActivityBehavior) behavior;
            commandContext.addAttribute(TYPE, true); // Will be read in the SendEventTaskActivityBehavior
            activityBehavior.execute(executionEntity);
        } finally {
    
            commandContext.removeAttribute(TYPE);
        }
    }

}

AsyncContinuationJobHandler Asynchronous continuation job handler

/** *  Asynchronous continuation job handler  * * @author Tijs Rademakers */
public class AsyncContinuationJobHandler implements JobHandler {
    

    //  type ： Asynchronous continuation 
    public static final String TYPE = "async-continuation";

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

    @Override
    public void execute(JobEntity job, String configuration, VariableScope variableScope, CommandContext commandContext) {
    
        ExecutionEntity executionEntity = (ExecutionEntity) variableScope;
        
        if (CommandContextUtil.getProcessEngineConfiguration(commandContext).isLoggingSessionEnabled()) {
    
            FlowElement flowElement = executionEntity.getCurrentFlowElement();
            BpmnLoggingSessionUtil.addAsyncActivityLoggingData("Executing async job for " + flowElement.getId() + ", with job id " + job.getId(),
                            LoggingSessionConstants.TYPE_SERVICE_TASK_EXECUTE_ASYNC_JOB, job, flowElement, executionEntity);
        }

        CommandContextUtil.getAgenda(commandContext).planContinueProcessSynchronousOperation(executionEntity);
    }

}

AsyncTriggerJobHandler Trigger job processor asynchronously

/** *  Trigger job processor asynchronously  * * @author Tijs Rademakers */
public class AsyncTriggerJobHandler implements JobHandler {
    

    //  type ： Asynchronous trigger 
    public static final String TYPE = "async-trigger";

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

    @Override
    public void execute(JobEntity job, String configuration, VariableScope variableScope, CommandContext commandContext) {
    
        ExecutionEntity executionEntity = (ExecutionEntity) variableScope;

        CommandContextUtil.getAgenda(commandContext).planTriggerExecutionOperation(executionEntity);
    }

}