void releaseResources ( JobInstance ji ) { this . peremption . remove ( ji . getId ( ) ) ; this . actualNbThread . decrementAndGet ( ) ; for ( ResourceManagerBase rm : this . resourceManagers ) { rm . releaseResource ( ji ) ; } if ( ! this . strictPollingPeriod ) { // Force a new loop at once. This makes queues more fluid. loop . release ( 1 ) ; } this . engine . signalEndOfRun ( ) ; }
Called when a payload thread has ended . This also notifies the poller to poll once again .