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 underlying 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, getProcessRandom, getRandom, getRandomBinary, getRandomBinary, getRandomString, getSafeTimeMillis, getStackFrame, getStackFrames, getStackTrace, getStackTrace, getStackTrace, getThreadFactory, getTimeZone, getUpTimeMillis, hashCode, hexValue, indentString, indentString, isDecimal, isHex, isLogEcho, isOctal, log, log, log, log, log, makeInteger, makeLong, makeThread, mergeArray, mergeBooleanArray, mergeByteArray, mergeCharArray, mergeDoubleArray, mergeFloatArray, mergeIntArray, mergeLongArray, 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, 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