Class AbstractExecutorTaskRunnerFactory.AbstractExecutorAsynchronousRunner

java.lang.Object
com.mchange.v2.c3p0.AbstractExecutorTaskRunnerFactory.AbstractExecutorAsynchronousRunner
All Implemented Interfaces:
com.mchange.v1.util.ClosableResource, com.mchange.v2.async.AsynchronousRunner, com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner
Direct Known Subclasses:
FixedThreadPoolExecutorTaskRunnerFactory.FixedThreadPoolExecutorAsynchronousRunner
Enclosing class:
AbstractExecutorTaskRunnerFactory
protected abstract class AbstractExecutorTaskRunnerFactory.AbstractExecutorAsynchronousRunner extends Object implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner
This implementation includes uninformative stub implementations of 
  public int getThreadCount()      { return -1; }
  public int getIdleCount()        { return -1; }
  public int getPendingTaskCount() { return -1; }
Consider overriding those if you can!

  • Field Details

  • Constructor Details

    • AbstractExecutorAsynchronousRunner

      protected AbstractExecutorAsynchronousRunner(TaskRunnerInit init, Timer timer)

  • Method Details

    • registerActive

      protected void registerActive(com.mchange.v2.c3p0.AbstractExecutorTaskRunnerFactory.AbstractExecutorAsynchronousRunner.WrapperRunnable wr)

    • unregisterActive

      protected void unregisterActive(com.mchange.v2.c3p0.AbstractExecutorTaskRunnerFactory.AbstractExecutorAsynchronousRunner.WrapperRunnable wr)

    • activeCount

      protected int activeCount()

    • snapshotActives

      protected HashSet snapshotActives()

    • isClosed

      protected boolean isClosed()

    • executor

      protected Executor executor()

    • postRunnable

      public void postRunnable(Runnable r)
      Specified by:
      postRunnable in interface com.mchange.v2.async.AsynchronousRunner

    • close

      public void close(boolean skip_remaining_tasks)
      Specified by:
      close in interface com.mchange.v2.async.AsynchronousRunner

    • close

      public void close()
      Specified by:
      close in interface com.mchange.v2.async.AsynchronousRunner
      Specified by:
      close in interface com.mchange.v1.util.ClosableResource

    • getThreadCount

      public int getThreadCount()
      Specified by:
      getThreadCount in interface com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner

    • getActiveCount

      public int getActiveCount()
      Specified by:
      getActiveCount in interface com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner

    • getIdleCount

      public int getIdleCount()
      Specified by:
      getIdleCount in interface com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner

    • getPendingTaskCount

      public int getPendingTaskCount()
      Specified by:
      getPendingTaskCount in interface com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner

    • getStatus

      public String getStatus()
      Specified by:
      getStatus in interface com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner

    • getStackTraces

      public String getStackTraces()
      Specified by:
      getStackTraces in interface com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner