Method Detail

• public def WorkQueue(@com.android.annotations.NonNull com.android.utils.ILogger logger, @com.android.annotations.NonNull QueueThreadContext<T> queueThreadContext, @com.android.annotations.NonNull String queueName, int workforce, int growthTriggerRatio)

  Creates a new queue, with a number of dedicated threads to process the queue's jobs.

  Parameters:

  logger - to log messages

  queueName - a meaningful descriptive name.

  workforce - the number of dedicated threads for this queue.

  growthTriggerRatio - the ratio between outstanding requests and worker threads that should trigger a growth in worker threads.

• public String getName()

  Return a human readable queue name, mainly used for identification purposes.

  Returns:

  a unique meaningful descriptive name

• public void push(Job<T> job)

• @Override public void run()

  each thread in the mWorkThreads will run this single infinite processing loop until a death action is received.

• public void shutdown()

  Shutdowns the working queue and wait until all pending requests have been processed. This needs to be reviewed as jobs can still be added to the queue once the shutdown process has started....

  throws:

  InterruptedException if the shutdown sequence is interrupted

• public int size()

  Returns the number of jobs waiting to be scheduled.

  Returns:

  the size of the queue.