Interface WorkProgressDispatcher

    • Method Detail

      • heartbeatTs

        long heartbeatTs()
        Last heatbeat timestamp.
      • updateHeartbeat

        void updateHeartbeat()
        Notifying dispatcher that work is in progress and thread didn't freeze.
      • blockingSectionBegin

        void blockingSectionBegin()
        Protects the worker from timeout penalties if subsequent instructions in the calling thread does not update heartbeat timestamp timely, e.g. due to blocking operations, up to the nearest blockingSectionEnd() call. Nested calls are not supported.
      • blockingSectionEnd

        void blockingSectionEnd()
        Closes the protection section previously opened by blockingSectionBegin().