org.teiid.dqp.internal.process
Class AbstractWorkItem

java.lang.Object
  org.teiid.dqp.internal.process.AbstractWorkItem

All Implemented Interfaces:

Runnable, EventListener, javax.resource.spi.work.Work, javax.resource.spi.work.WorkListener

Direct Known Subclasses:

RequestWorkItem

public abstract class AbstractWorkItem
extends Object
implements javax.resource.spi.work.Work, javax.resource.spi.work.WorkListener

Represents a task that performs work that may take more than one processing pass to complete. During processing the WorkItem may receive events asynchronously through the moreWork method.

Constructor Summary

AbstractWorkItem()

Method Summary

protected abstract boolean	isDoneProcessing()
protected boolean	isIdle()
boolean	isProcessing()
void	moreWork()
protected void	moreWork(boolean ignoreDone)
protected void	pauseProcessing()
protected abstract void	process()
void	release()
protected abstract void	resumeProcessing()
void	run()
abstract String	toString()
void	workAccepted(javax.resource.spi.work.WorkEvent arg0)
void	workCompleted(javax.resource.spi.work.WorkEvent arg0)
void	workRejected(javax.resource.spi.work.WorkEvent event)
void	workStarted(javax.resource.spi.work.WorkEvent arg0)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractWorkItem

public AbstractWorkItem()

Method Detail

run

public void run()

Specified by:

run in interface Runnable

isProcessing

public boolean isProcessing()

isIdle

protected boolean isIdle()

moreWork

public void moreWork()

moreWork

protected void moreWork(boolean ignoreDone)

process

protected abstract void process()

pauseProcessing

protected void pauseProcessing()

resumeProcessing

protected abstract void resumeProcessing()

isDoneProcessing

protected abstract boolean isDoneProcessing()

toString

public abstract String toString()

Overrides:

toString in class Object

release

public void release()

Specified by:

release in interface javax.resource.spi.work.Work

workAccepted

public void workAccepted(javax.resource.spi.work.WorkEvent arg0)

Specified by:

workAccepted in interface javax.resource.spi.work.WorkListener

workCompleted

public void workCompleted(javax.resource.spi.work.WorkEvent arg0)

Specified by:

workCompleted in interface javax.resource.spi.work.WorkListener

workRejected

public void workRejected(javax.resource.spi.work.WorkEvent event)

Specified by:

workRejected in interface javax.resource.spi.work.WorkListener

workStarted

public void workStarted(javax.resource.spi.work.WorkEvent arg0)

Specified by:

workStarted in interface javax.resource.spi.work.WorkListener