Constructor and Description |
---|
WorkerContext(javax.resource.spi.work.Work work,
Collection<WorkContextHandler> workContextHandlers)
Create a WorkWrapper.
|
WorkerContext(javax.resource.spi.work.Work aWork,
long aStartTimeout,
javax.resource.spi.work.ExecutionContext execContext,
javax.resource.spi.work.WorkListener workListener,
Collection<WorkContextHandler> workContextHandlers)
Create a WorkWrapper with the specified execution context.
|
Modifier and Type | Method and Description |
---|---|
long |
getAcceptedTime()
System.currentTimeMillis() when the Work has been accepted.
|
long |
getStartTimeout()
Gets the time duration (in milliseconds) within which the execution of
the Work instance must start.
|
int |
getThreadPriority()
Gets the priority level of the thread, which will be dispatched
to process this work.
|
javax.resource.spi.work.WorkException |
getWorkException()
Gets the WorkException, if any, thrown during the execution.
|
boolean |
isTimedOut()
Used by a Work executor in order to know if this work, which should be
accepted but not started has timed out.
|
CountDownLatch |
provideEndLatch()
Provides a latch, which can be used to wait the end of a work
execution.
|
CountDownLatch |
provideStartLatch()
Provides a latch, which can be used to wait the start of a work
execution.
|
void |
release() |
void |
run() |
void |
setThreadPriority(int aPriority)
Defines the thread priority level of the thread, which will be dispatched
to process this work.
|
String |
toString() |
void |
workAccepted(Object anObject)
Call-back method used by a Work executor in order to notify this
instance that the wrapped Work instance has been accepted.
|
public WorkerContext(javax.resource.spi.work.Work work, Collection<WorkContextHandler> workContextHandlers)
work
- Work to be wrapped.workContextHandlers
- WorkContextHandlers supported by this work managerpublic WorkerContext(javax.resource.spi.work.Work aWork, long aStartTimeout, javax.resource.spi.work.ExecutionContext execContext, javax.resource.spi.work.WorkListener workListener, Collection<WorkContextHandler> workContextHandlers) throws javax.resource.spi.work.WorkRejectedException
aWork
- Work to be wrapped.aStartTimeout
- a time duration (in milliseconds) within which the
execution of the Work instance must start.execContext
- an object containing the execution context with which
the submitted Work instance must be executed.workListener
- an object which would be notified when the variousworkContextHandlers
- WorkContextHandlers supported by this work managerjavax.resource.spi.work.WorkRejectedException
- if executionContext supplied yet Work implements WorkContextProviderpublic void release()
release
in interface javax.resource.spi.work.Work
public void setThreadPriority(int aPriority)
aPriority
- Priority of the thread to be used to process the wrapped
Work instance.public int getThreadPriority()
public void workAccepted(Object anObject)
anObject
- Object on which the event initially occurred. It should
be the work executor.public long getAcceptedTime()
public long getStartTimeout()
public boolean isTimedOut()
public javax.resource.spi.work.WorkException getWorkException()
public CountDownLatch provideStartLatch()
public CountDownLatch provideEndLatch()
Copyright © 2015. All rights reserved.