Constructor Detail

• RxTaskPool

  public RxTaskPool(int maxTasks,
            int minTasks,
            RxTaskPool.TaskCreator creator)
             throws Exception

  Throws:

  Exception

Method Detail

• configureTask

  protected void configureTask(AbstractRxTask task)

• getRxTask

  public AbstractRxTask getRxTask()

  Find an idle worker thread, if any. Could return null.

  Returns:

  a worker

• available

  public int available()

• returnWorker

  public void returnWorker(AbstractRxTask worker)

  Called by the worker thread to return itself to the idle pool.

  Parameters:

  worker - The worker

• getMaxThreads

  public int getMaxThreads()

• getMinThreads

  public int getMinThreads()

• stop

  public void stop()

• setMaxTasks

  public void setMaxTasks(int maxThreads)

• setMinTasks

  public void setMinTasks(int minThreads)

• getTaskCreator

  public RxTaskPool.TaskCreator getTaskCreator()