Class CurrentTaskFuture.UpOneLevel

  • All Implemented Interfaces:
    java.lang.Runnable
    Enclosing class:
    CurrentTaskFuture

    private class CurrentTaskFuture.UpOneLevel
    extends java.lang.Object
    implements java.lang.Runnable
    • Field Detail

      • lock

        private final java.lang.Object lock
      • queueLock

        private final java.lang.Object queueLock
      • upToThisLevel

        private final int upToThisLevel
      • maxThreads

        private final int maxThreads
      • cancelTimeout

        private final long cancelTimeout
      • numJobs

        private int numJobs
      • completedJobs

        private int completedJobs
      • cancelled

        private boolean cancelled
      • numJobsRunning

        private int numJobsRunning
      • hardCancelled

        private boolean hardCancelled
      • outstandingHandles

        private final java.util.HashSet<ServiceHandle<?>> outstandingHandles
    • Method Detail

      • cancel

        private void cancel()
      • hardCancel

        private void hardCancel()
      • jobRunning

        private void jobRunning​(ServiceHandle<?> handle)
      • jobFinished

        private void jobFinished​(ServiceHandle<?> handle)
      • getJobsRunning

        private int getJobsRunning()
      • run

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

        private void fail​(java.lang.Throwable th,
                          Descriptor descriptor)
      • jobComplete

        private void jobComplete()