org.globus.wsrf.impl.work
Class WorkManagerImpl

java.lang.Object
  org.globus.wsrf.impl.work.WorkManagerImpl

All Implemented Interfaces:

commonj.work.WorkManager

public class WorkManagerImpl

extends java.lang.Object

implements commonj.work.WorkManager

Nested Class Summary

protected class

WorkManagerImpl.WorkWrapper

Field Summary

private static org.globus.util.I18n	i18n
protected static int	MAX_POOL_SIZE
private EDU.oswego.cs.dl.util.concurrent.PooledExecutor	pool
private java.util.Map	workItems

Fields inherited from interface commonj.work.WorkManager

IMMEDIATE, INDEFINITE

Constructor Summary

WorkManagerImpl()

WorkManagerImpl(int maxPoolSize)

Method Summary

int	getMaximumPoolSize()
protected void	processEvent(commonj.work.WorkEvent event)
commonj.work.WorkItem	schedule(commonj.work.Work work)
commonj.work.WorkItem	schedule(commonj.work.Work work, commonj.work.WorkListener listener)
void	setMaximumPoolSize(int maxPoolSize)
boolean	waitForAll(java.util.Collection workItems, long timeout)
java.util.Collection	waitForAny(java.util.Collection workItems, long timeout)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MAX_POOL_SIZE

protected static final int MAX_POOL_SIZE

See Also:

Constant Field Values

pool

private EDU.oswego.cs.dl.util.concurrent.PooledExecutor pool

workItems

private java.util.Map workItems

i18n

private static org.globus.util.I18n i18n

Constructor Detail

WorkManagerImpl

public WorkManagerImpl()

WorkManagerImpl

public WorkManagerImpl(int maxPoolSize)

Method Detail

setMaximumPoolSize

public void setMaximumPoolSize(int maxPoolSize)

getMaximumPoolSize

public int getMaximumPoolSize()

schedule

public commonj.work.WorkItem schedule(commonj.work.Work work,
                                      commonj.work.WorkListener listener)
                               throws commonj.work.WorkException,
                                      java.lang.IllegalArgumentException

Specified by:

schedule in interface commonj.work.WorkManager

Throws:

commonj.work.WorkException

java.lang.IllegalArgumentException

schedule

public commonj.work.WorkItem schedule(commonj.work.Work work)
                               throws commonj.work.WorkException,
                                      java.lang.IllegalArgumentException

Specified by:

schedule in interface commonj.work.WorkManager

Throws:

commonj.work.WorkException

java.lang.IllegalArgumentException

waitForAll

public boolean waitForAll(java.util.Collection workItems,
                          long timeout)

Specified by:

waitForAll in interface commonj.work.WorkManager

waitForAny

public java.util.Collection waitForAny(java.util.Collection workItems,
                                       long timeout)

Specified by:

waitForAny in interface commonj.work.WorkManager

processEvent

protected void processEvent(commonj.work.WorkEvent event)