er.workerchannel
Class ERLocalWorkerChannel

java.lang.Object
  er.workerchannel.ERLocalWorkerChannel

All Implemented Interfaces:

ERWorkerChannel

public class ERLocalWorkerChannel

extends Object

implements ERWorkerChannel

Field Summary

static ERXLogger

log

Constructor Summary

ERLocalWorkerChannel(int numberOfThreads, int queueSize)

Method Summary

void	cancelScheduledWorkUnits()
int	currentQueueSize()
ERWorkUnit	dispatchWorkUnit()
void	resumeWorkers()
ERResultUnit	scheduleWorkUnit(ERWorkUnit workUnit)
void	shutdownWorkers()
void	startWorkers()
void	suspendWorkers()

Methods inherited from class java.lang.Object

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

Field Detail

log

public static final ERXLogger log

Constructor Detail

ERLocalWorkerChannel

public ERLocalWorkerChannel(int numberOfThreads,
                            int queueSize)

Method Detail

startWorkers

public void startWorkers()

Specified by:

startWorkers in interface ERWorkerChannel

shutdownWorkers

public void shutdownWorkers()

Specified by:

shutdownWorkers in interface ERWorkerChannel

suspendWorkers

public void suspendWorkers()

Specified by:

suspendWorkers in interface ERWorkerChannel

resumeWorkers

public void resumeWorkers()

Specified by:

resumeWorkers in interface ERWorkerChannel

scheduleWorkUnit

public ERResultUnit scheduleWorkUnit(ERWorkUnit workUnit)

Specified by:

scheduleWorkUnit in interface ERWorkerChannel

dispatchWorkUnit

public ERWorkUnit dispatchWorkUnit()

Specified by:

dispatchWorkUnit in interface ERWorkerChannel

cancelScheduledWorkUnits

public void cancelScheduledWorkUnits()

Specified by:

cancelScheduledWorkUnits in interface ERWorkerChannel

currentQueueSize

public int currentQueueSize()

Specified by:

currentQueueSize in interface ERWorkerChannel