Class CurrentTaskFuture.DownAllTheWay

    • Method Detail

      • cancel

        private void cancel()
      • setGoingTo

        private void setGoingTo​(int goingTo,
                                boolean repurposed)
      • getGoingTo

        private int getGoingTo()
      • run

        public void run()
        Specified by:
        run in interface java.lang.Runnable
      • waitForResult

        public java.lang.Boolean waitForResult​(long timeout,
                                               java.util.concurrent.TimeUnit unit)
                                        throws java.lang.InterruptedException,
                                               MultiException
        Description copied from interface: CurrentTaskFuture.AllTheWay
        The method to call on the internal job
        Specified by:
        waitForResult in interface CurrentTaskFuture.AllTheWay
        Parameters:
        timeout - The amount of time to wait for a result
        unit - The unit of the above time value
        Returns:
        True if the job finished, False if the timeout is up prior to the job finishing, and null if the job was repurposed and the caller may now need to listen on a different job
        Throws:
        java.lang.InterruptedException - On a thread getting jacked
        MultiException - Other exceptions