Package io.deephaven.enterprise.niowrapper.sched

Class TimedJob

java.lang.Object
io.deephaven.enterprise.comm.sched.Job
io.deephaven.enterprise.niowrapper.sched.TimedJob
All Implemented Interfaces:
com.fishlib.base.log.LogOutputAppendable
Direct Known Subclasses:
DeephavenLeaseHandler, FutureJob, HungReportJob, PeriodicJob, StatsDriver, WorkerTtlCheckJob
public abstract class TimedJob extends Job
This is the base class for jobs which are only interested in timing events. It provides default invoke() and cancelled() method which do nothing. Created by IntelliJ IDEA. User: jrauser Date: Mar 10, 2007 Time: 8:48:40 AM To change this template use File | Settings | File Templates.

  • Constructor Summary

    Constructors
    Constructor
    Description
    TimedJob()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    com.fishlib.base.log.LogOutput
    append(com.fishlib.base.log.LogOutput logOutput)
     
    void
    cancelled()
    This method is called if the job is explicitly cancelled before it becomes ready or times out.
    int
    invoke(SelectableChannel channel, int readyOps, com.fishlib.base.Procedure.Nullary handoff)
    This method is invoked by the scheduler when the job's channel becomes ready.

    Methods inherited from class io.deephaven.enterprise.comm.sched.Job

    getStateFor, makeStateFor, timedOut

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • TimedJob

      public TimedJob()

  • Method Details

    • invoke

      public int invoke(SelectableChannel channel, int readyOps, com.fishlib.base.Procedure.Nullary handoff)
      Description copied from class: Job
      This method is invoked by the scheduler when the job's channel becomes ready.
      Specified by:
      invoke in class Job
      Parameters:
      channel - the channel which has become ready
      readyOps - the operations which can be performed on this channel without blocking
      Returns:
      the modified readyOps after the invocation; if non-zero, the job will be invoked again with these

    • cancelled

      public void cancelled()
      Description copied from class: Job
      This method is called if the job is explicitly cancelled before it becomes ready or times out.
      Specified by:
      cancelled in class Job

    • append

      public com.fishlib.base.log.LogOutput append(com.fishlib.base.log.LogOutput logOutput)
      Specified by:
      append in interface com.fishlib.base.log.LogOutputAppendable
      Overrides:
      append in class Job