protected static class WorkManager.ScheduleWork extends WorkManager.AbstractWork
Base.LoggingWriter, Base.StackFrame
m_lWorkId, m_nMemberId
LOG_ALWAYS, LOG_DEBUG, LOG_ERR, LOG_INFO, LOG_MAX, LOG_MIN, LOG_QUIET, LOG_WARN, POWER_0, POWER_G, POWER_K, POWER_M, POWER_T, UNIT_D, UNIT_H, UNIT_M, UNIT_MS, UNIT_NS, UNIT_S, UNIT_US
SCHEDULE_FIRST, SCHEDULE_IMMEDIATE, SCHEDULE_STANDARD, TIMEOUT_DEFAULT, TIMEOUT_NONE
Constructor and Description |
---|
ScheduleWork()
Default constructor (necessary for a lite serialization).
|
ScheduleWork(commonj.work.Work work, long lWorkId, int nMemberId, boolean fFeedback)
Construct the ScheduleWork for a given Work.
|
Modifier and Type | Method and Description |
---|---|
Throwable |
getException()
Return a deserialization exception (if any).
|
long |
getExecutionTimeoutMillis()
Obtain the maximum amount of time this task is allowed to run before the corresponding service will attempt to stop it.
|
int |
getSchedulingPriority()
Obtain this task's scheduling priority.
|
int |
getStatus()
Return a status of the undrlying Work.
|
commonj.work.Work |
getWork()
Return a Work object.
|
void |
init(InvocationService service)
Called by the InvocationService exactly once on this Invocable object as part of its initialization.
|
boolean |
isFeedbackRequested()
Return a feedback flag.
|
void |
readExternal(DataInput in)
Restore the contents of this object by loading the object's state from the passed DataInput object.
|
void |
readExternal(PofReader in)
Restore the contents of a user type instance by reading its state using the specified PofReader object.
|
void |
run()
Called exactly once by the InvocationService to invoke this Invocable object.
|
void |
setStatus(int nStatus)
Change a status of the underlying Work.
|
String |
toString()
Return a human-readable task description.
|
void |
writeExternal(DataOutput out)
Save the contents of this object by storing the object's state into the passed DataOutput object.
|
void |
writeExternal(PofWriter out)
Save the contents of a POF user type instance by writing its state using the specified PofWriter object.
|
getMember, getMemberId, getWorkId
getRequestTimeoutMillis, getResult, getService, isRespondInOrder, runCanceled, setResult
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, 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
public ScheduleWork()
public ScheduleWork(commonj.work.Work work, long lWorkId, int nMemberId, boolean fFeedback) throws commonj.work.WorkException
work
- the Work to executelWorkId
- the Work idnMemberId
- the Member idfFeedback
- true if a feedback is requested (listener)commonj.work.WorkException
- thrown if serialization results in an exceptionpublic void init(InvocationService service)
init
in interface Invocable
init
in class AbstractInvocable
service
- the containing InvocationServicepublic void run()
public int getSchedulingPriority()
This implementation returns SCHEDULE_STANDARD
.
getSchedulingPriority
in interface PriorityTask
getSchedulingPriority
in class WorkManager.AbstractWork
public long getExecutionTimeoutMillis()
The value of TIMEOUT_DEFAULT
indicates a default timeout value configured for the corresponding service; the value of TIMEOUT_NONE
indicates that this task can execute indefinitely.
If, by the time the specified amount of time passed, the task has not finished, the service will attempt to stop the execution by using the Thread.interrupt()
method. In the case that interrupting the thread does not result in the task's termination, the PriorityTask.runCanceled(boolean)
method will be called.
This implementation returns TIMEOUT_DEFAULT
.
getExecutionTimeoutMillis
in interface PriorityTask
getExecutionTimeoutMillis
in class AbstractInvocable
public commonj.work.Work getWork()
public Throwable getException()
public boolean isFeedbackRequested()
public int getStatus()
public void setStatus(int nStatus)
nStatus
- a new status of the underlying Workpublic void readExternal(DataInput in) throws IOException
readExternal
in interface ExternalizableLite
readExternal
in class WorkManager.AbstractWork
in
- the DataInput stream to read data from in order to restore the state of this objectIOException
- if an I/O exception occursNotActiveException
- if the object is not in its initial state, and therefore cannot be deserialized intopublic void writeExternal(DataOutput out) throws IOException
writeExternal
in interface ExternalizableLite
writeExternal
in class WorkManager.AbstractWork
out
- the DataOutput stream to write the state of this object toIOException
- if an I/O exception occurspublic void readExternal(PofReader in) throws IOException
readExternal
in interface PortableObject
readExternal
in class WorkManager.AbstractWork
in
- the PofReader from which to read the object's stateIOException
- if an I/O error occurspublic void writeExternal(PofWriter out) throws IOException
writeExternal
in interface PortableObject
writeExternal
in class WorkManager.AbstractWork
out
- the PofWriter to which to write the object's stateIOException
- if an I/O error occurs