to.etc.webapp.pendingoperations
Class PollingWorkerQueue

java.lang.Object
  extended by to.etc.webapp.pendingoperations.PollingWorkerQueue

public class PollingWorkerQueue
extends java.lang.Object

Generic Executor which polls for jobs to execute. Providers for jobs can be easily registered.

Author:
Frits Jalvingh Created on Mar 4, 2009

Constructor Summary
PollingWorkerQueue()
           
 
Method Summary
 void addWork(java.lang.Runnable run)
           
 void checkProvider(IPollQueueTaskProvider provider)
           
static PollingWorkerQueue getInstance()
           
 int getRunningThreads()
           
 long getTsLastBlock()
           
 long getTsLastCheck()
           
static void initialize()
           
 void registerProvider(IPollQueueTaskProvider provider)
          Register another provider to get tasks from.
 void terminate()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

PollingWorkerQueue

public PollingWorkerQueue()
Method Detail

initialize

public static void initialize()
                       throws java.lang.Exception
Throws:
java.lang.Exception

getInstance

public static PollingWorkerQueue getInstance()

registerProvider

public void registerProvider(IPollQueueTaskProvider provider)
Register another provider to get tasks from.

Parameters:
provider -

checkProvider

public void checkProvider(IPollQueueTaskProvider provider)

terminate

public void terminate()

addWork

public void addWork(java.lang.Runnable run)

getTsLastBlock

public long getTsLastBlock()

getTsLastCheck

public long getTsLastCheck()

getRunningThreads

public int getRunningThreads()