protected class WorkManager.WorkHolder extends Base implements commonj.work.RemoteWorkItem
Modifier and Type | Class and Description |
---|---|
protected class |
WorkManager.WorkHolder.Event
A WorkEvent implementation.
|
Base.LoggingWriter, Base.StackFrame
Modifier and Type | Field and Description |
---|---|
protected commonj.work.WorkListener |
m_listener
A work listener associated with the corresponding Work.
|
protected List |
m_listWaits
A list of collections waiting for this Work to complete.
|
protected long |
m_lWorkId
The corresponding work id.
|
protected Member |
m_member
The server Member that is to run the Work.
|
protected InvocationService |
m_service
The underlying Invocation service.
|
protected WorkManager.WorkStatus |
m_status
Current Work status.
|
Constructor and Description |
---|
WorkHolder(long lWorkId, commonj.work.WorkListener listener, InvocationService service, Member member)
Construct a WorkHolder for a Work with a given work id that is scheduled to be executed on a specified service.
|
Modifier and Type | Method and Description |
---|---|
void |
addWait(Collection collWait)
Add a collection to a wait list.
|
int |
compareTo(Object o)
Compare this WorkItem with the specified object for order.
|
boolean |
equals(Object o)
Compare this WorkItem with the specified object for equality.
|
commonj.work.WorkListener |
getListener()
Return the associated WorkListener.
|
commonj.work.WorkManager |
getPinnedWorkManager()
Return a pinned WorkManager which represents the JVM that was used to execute this Work.
|
commonj.work.Work |
getResult()
Return the Work once it has completed.
|
InvocationService |
getService()
Return the InvocationService used to execute the corresponding Work.
|
int |
getStatus()
Return the current status of dispatching the Work.
|
Member |
getTargetMember()
Return the Member that the corresponding Work is to be executed at.
|
Collection[] |
getWaits()
Assemble an array of collection that wait for this Work.
|
long |
getWorkId()
Return the work id.
|
WorkManager.WorkStatus |
getWorkStatus()
Return the WorkStatus object.
|
int |
hashCode()
Return a hash code value for this WorkHolder.
|
void |
release()
Calls the remote Work object's
Work.release() method. |
void |
removeWait(Collection collWait)
Remove a collection from a wait list.
|
protected void |
setWorkStatus(WorkManager.WorkStatus status)
Update the WorkStatus.
|
String |
toString()
Return a string representation of the WorkHolder object.
|
azzert, azzert, azzert, azzertFailed, breakLines, breakLines, capitalize, checkNotEmpty, checkNotNull, checkRange, computeSafeWaitTime, decimalValue, dup, dup, ensureBigDecimal, ensureClassLoader, ensureRuntimeException, ensureRuntimeException, equals, equalsDeep, err, err, err, err, err, escape, formatDateTime, getCallerStackFrame, getCommonMonitor, getCommonMonitor, getCommonMonitor, getContextClassLoader, getContextClassLoader, getDeepMessage, getErr, getLastSafeTimeMillis, getLog, getMaxDecDigits, getMaxHexDigits, getOriginalException, getOut, getRandom, getRandomBinary, getRandomBinary, getRandomString, getSafeTimeMillis, getStackFrame, getStackFrames, getStackTrace, getStackTrace, getThreadFactory, getTimeZone, getUpTimeMillis, hashCode, hexValue, indentString, indentString, isDecimal, isHex, isLogEcho, isOctal, log, log, log, log, log, makeInteger, makeLong, makeThread, mod, mod, octalValue, out, out, out, out, out, pad, parseBandwidth, parseBandwidth, parseDelimitedString, parseHex, parseHex, parseMemorySize, parseMemorySize, parsePercentage, parseTime, parseTime, parseTimeNanos, parseTimeNanos, printStackTrace, randomize, randomize, randomize, read, read, read, read, read, read, read, replace, setErr, setLog, setLogEcho, setOut, sleep, toBandwidthString, toBandwidthString, toCharEscape, toCrc, toCrc, toCrc, toCrc, toCrc, toDecString, toDelimitedString, toDelimitedString, toDelimitedString, toDelimitedString, toHex, toHex, toHexDump, toHexEscape, toHexEscape, toHexEscape, toHexEscape, toHexString, toMemorySizeString, toMemorySizeString, toQuotedCharEscape, toQuotedStringEscape, toSqlString, toString, toString, toStringEscape, toUnicodeEscape, trace, trace, trace, trace, trace, trace, trace, trace, trace, truncateString, truncateString, wait
protected long m_lWorkId
protected commonj.work.WorkListener m_listener
protected InvocationService m_service
protected Member m_member
protected WorkManager.WorkStatus m_status
protected List m_listWaits
public WorkHolder(long lWorkId, commonj.work.WorkListener listener, InvocationService service, Member member)
lWorkId
- the Work idlistener
- the WorkListenerservice
- the InvocationService to usemember
- the target Memberpublic int getStatus()
WorkEvent
for the values.getStatus
in interface commonj.work.WorkItem
WorkEvent
public commonj.work.Work getResult() throws commonj.work.WorkException
getResult
in interface commonj.work.WorkItem
commonj.work.WorkException
public commonj.work.WorkManager getPinnedWorkManager()
getPinnedWorkManager
in interface commonj.work.RemoteWorkItem
public void release()
Work.release()
method.release
in interface commonj.work.RemoteWorkItem
public int compareTo(Object o)
compareTo
in interface Comparable
public long getWorkId()
public WorkManager.WorkStatus getWorkStatus()
public InvocationService getService()
public Member getTargetMember()
public commonj.work.WorkListener getListener()
protected void setWorkStatus(WorkManager.WorkStatus status)
status
- the WorkStatus object to updatepublic void addWait(Collection collWait)
collWait
- a collection that waits for this Workpublic void removeWait(Collection collWait)
addWait(java.util.Collection)
call.collWait
- a collection that waits for this Workpublic Collection[] getWaits()
public int hashCode()
public boolean equals(Object o)