Constructor Detail

• PoolQueue

  PoolQueue()

Method Detail

• getSize

  @Synchronized() Integer getSize()

• getTimeReport

  @Synchronized() final String getTimeReport()

• add

  @Synchronized() Boolean add(TaskPool element)

• offer

  @Synchronized() Boolean offer(TaskPool taskPool)

• poll

  @Synchronized() TaskPool poll()

• peek

  @Synchronized() TaskPool peek()

• remove

  @Synchronized() Boolean remove(TaskPool element)

• iterator

   Iterator<TaskPool> iterator()

• isEmpty

  @Synchronized() Boolean isEmpty()

• clear

  @Synchronized() Unit clear()

• enable

  @Synchronized() final Unit enable(TaskPool queue)

• disable

  @Synchronized() final Unit disable(TaskPool pool)

  Retired queues do not serve any more, but the tasks can be find out and finished. The tasks in detached queues can be find out to finish.

  A queue should be detached if

  • the queue is too slow, or

  • all tasks are done

• hasPriorPendingTasks

  @Synchronized() final Boolean hasPriorPendingTasks(Integer priority)

• find

  @Synchronized() final TaskPool find(PoolId id)

• findExtend

  @Synchronized() final TaskPool findExtend(PoolId id)

• search

  @Synchronized() final TaskPool search(PoolId id, Boolean searchInactive)

• dump

  @Synchronized() final Unit dump(Integer limit, Boolean drop)