Class BackPressureTeamSource

    • Field Detail

      • BACK_PRESSURE_EXCEPTION

        public static final java.util.concurrent.RejectedExecutionException BACK_PRESSURE_EXCEPTION
        RejectedExecutionException thrown to indicate back pressure.
    • Constructor Detail

      • BackPressureTeamSource

        public BackPressureTeamSource()
    • Method Detail

      • getBackPressureEscalationCount

        public static int getBackPressureEscalationCount()
        Obtains the number of back pressure Escalation instances that have occurred.
        Returns:
        Number of back pressure Escalation instances that have occurred.
      • resetBackPressureEscalationCount

        public static void resetBackPressureEscalationCount​(int count)
        Resets the back pressure Escalation count.
        Parameters:
        count - Count to reset the Escalation count.
      • startWorking

        public void startWorking()
        Description copied from interface: Team
        Indicates for the Team to start working.
        Specified by:
        startWorking in interface Team
      • assignJob

        public void assignJob​(Job job)
        Description copied from interface: Team
        Assigns a Job to be executed by this Team.
        Specified by:
        assignJob in interface Team
        Parameters:
        job - Job.
      • stopWorking

        public void stopWorking()
        Description copied from interface: Team

        Indicates for the Team to stop working.

        This method should block and only return control when the Team has stopped working and is no longer assigned Job instances to complete.

        Specified by:
        stopWorking in interface Team