Class JobWorkerInterruptionTimeoutObject
- java.lang.Object
-
- org.apache.ignite.internal.processors.job.JobWorkerInterruptionTimeoutObject
-
- All Implemented Interfaces:
GridTimeoutObject
public class JobWorkerInterruptionTimeoutObject extends Object implements GridTimeoutObject
Timeout object for delayedworkerinterruption.After calling
GridJobWorker.cancel()the worker should try to complete gracefully, if it doesn't then it willinterruptafter some time.
-
-
Constructor Summary
Constructors Constructor Description JobWorkerInterruptionTimeoutObject(GridJobWorker jobWorker, long endTime)Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description longendTime()GridJobWorkerjobWorker()voidonTimeout()Timeout callback.IgniteUuidtimeoutId()StringtoString()
-
-
-
Constructor Detail
-
JobWorkerInterruptionTimeoutObject
public JobWorkerInterruptionTimeoutObject(GridJobWorker jobWorker, long endTime)
Constructor.- Parameters:
jobWorker- Compute job worker.endTime- Time when the timeout object should be executed in mills.
-
-
Method Detail
-
timeoutId
public IgniteUuid timeoutId()
- Specified by:
timeoutIdin interfaceGridTimeoutObject- Returns:
- ID of the object.
-
endTime
public long endTime()
- Specified by:
endTimein interfaceGridTimeoutObject- Returns:
- End time.
-
onTimeout
public void onTimeout()
Timeout callback.- Specified by:
onTimeoutin interfaceGridTimeoutObject
-
jobWorker
public GridJobWorker jobWorker()
- Returns:
- Compute job worker.
-
-