Execution of works
Definition
A work is an execution unit. It is java runnable object executed in a thread pool. It’s the most basic component of the Bonita Engine, and is central to the execution of processes.
A work often wraps one another to add specific behaviors.
An ExecuteFlowNodeWork contains the flownode execution logic.
It is wrapped in a TxBonitaWork, to ensure everything is executing inside a transaction.
It is itself wrapped into a LockProcessInstanceWork, to allow to lock any concurrent access to the same process instance.
It is itself wrapped into a InSessionBonitaWork, to set the tenant context (tenantId).
Basic call flow
The ThreadPoolExecutor is responsible for executing works. It calls the work() method on the parent Work. The parent will then call work() on the wrapped work who will call work() on its wrapped work and so on.
Example : flownode execution
The BonitaThreadPoolExecutor is responsible for executing the work. The basic call flow is explained below:
-
The top-level work (of type InSessionBonitaWork) sets the tenantId and then calls the work() method on its wrapped lower-level work, which is of type ProcessInstanceContextWork.
-
ProcessInstanceContextWork fills in some context information and then calls work() on its wrapped lower-level work, which is of type LockProcessInstanceWork.
-
LockProcessInstanceWork [[tries to obtain an exclusive lock
Work-locking]] on the containing process instance corresponding to the flownode to execute:
-
If it cannot get the lock within 20ms (by default), a LockTimeoutException is thrown so that the work is placed at the end of the work queue, for later execution
-
In any case, if the lock has been obtained, it is released after the execution (in a
finally
block) -
Then the wrapped TxBonitaWork is executed, which wraps the wrapped work into a JTA transaction
-
Then the ExecuteFlowNodeWork executes its logic.
Error management
There are 3 types of errors:
-
No lock could be acquired.
-
An exception of temporary nature occurred (Timeout, OptimisticLockException, database connection issues…).
-
All the other type of exceptions.
If the lock could not be acquired a specific set of action occurs. [[see here|Work-locking]]. If an exception of temporary nature occurred, the work would be retried (see below). Other exceptions are handled by the method handleFailure() . On a flownode it sets its state to "failed".
Auditing
A special logger can help identify potential issue of work execution:
29-Jul-2020 17:24:04.674 AVERTISSEMENT [Bonita-Worker-1-09] org.bonitasoft.engine.work.audit.AuditListener.abnormalExecutionStatusDetected Potential abnormal execution detected - cause TOO_MANY_EXECUTIONS. org.bonitasoft.engine.work.WorkDescriptor@323b63d6[uuid=55a92f06-7061-43e9-8523-1c6955a26fc2,type=EXECUTE_FLOWNODE,tenantId=1,parameters={processDefinitionId=XXXX, processInstanceId=XXXX, stateCanceling=false, stateExecuting=false, stateId=37, stateAborting=false, flowNodeInstanceId=CCC},retryCount=Y,executionThreshold=2020-07-29T06:24:04.674Z,executionCount=10,registrationDate=2020-07-29T06:11:44.943Z,abnormalExecutionDetected=true]
In that case the warning tells us the work was taken for execution but not completed 10 times.
We can see here:
-
executionCount
is the counter of every time was taken for execution. -
retryCount
is the counter of each time the work failed because of a retryable exception.
see Work executiuon audit for more details.