Package com.illumon.util.net

Class ConnectionScheduler

java.lang.Object
io.deephaven.enterprise.comm.sched.JobScheduler
com.illumon.util.net.ConnectionScheduler
All Implemented Interfaces:
io.deephaven.enterprise.niowrapper.sched.Scheduler
public class ConnectionScheduler extends io.deephaven.enterprise.comm.sched.JobScheduler
Create a private scheduler to handle jobs for a single connection.

  • Nested Class Summary

    Nested classes/interfaces inherited from class io.deephaven.enterprise.comm.sched.JobScheduler

    io.deephaven.enterprise.comm.sched.JobScheduler.Statistics

    Nested classes/interfaces inherited from interface io.deephaven.enterprise.niowrapper.sched.Scheduler

    io.deephaven.enterprise.niowrapper.sched.Scheduler.ExecutorAdaptor, io.deephaven.enterprise.niowrapper.sched.Scheduler.Null

  • Field Summary

    Fields inherited from class io.deephaven.enterprise.comm.sched.JobScheduler

    log, name

  • Constructor Summary

    Constructors
    Constructor
    Description
    ConnectionScheduler(String name, com.fishlib.io.logger.Logger log, io.deephaven.enterprise.comm.sched.JobScheduler.Statistics statistics, int numThreads)
    Construct a new scheduler designed for use by a single connection, with the supplied name, log, and number of driver threads.

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    delegatedClose()
     
    com.fishlib.io.logger.Logger
    getLog()
    Get this scheduler's log
    void
    start()
    Start this scheduler.
    void
    updateDriverThreadNames(String namePrefix)
    Update the names of the driver threads with a new name prefix, replacing the scheduler's name as a component of the driver thread names.

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

    cancelJob, close, currentTimeMillis, installJob, installJob, isClosed, junitGetAllJobs, junitGetAllKeys, junitGetChannelsAndJobs, junitGetReadyKeys, junitGetSelector, junitGetTimeoutQueue, junitTestTimeoutQueueInvariant, work

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ConnectionScheduler

      public ConnectionScheduler(@NotNull String name, @NotNull com.fishlib.io.logger.Logger log, @NotNull io.deephaven.enterprise.comm.sched.JobScheduler.Statistics statistics, int numThreads) throws IOException
      Construct a new scheduler designed for use by a single connection, with the supplied name, log, and number of driver threads.
      Parameters:
      name - The name of the scheduler
      log - The log to be used by the scheduler
      statistics - Statistics to be reported by the super class
      numThreads - The number of driver threads to create
      Throws:
      IOException

  • Method Details

    • updateDriverThreadNames

      public void updateDriverThreadNames(@NotNull String namePrefix)
      Update the names of the driver threads with a new name prefix, replacing the scheduler's name as a component of the driver thread names. Does not change the name of the scheduler, which becomes fixed at construction time.
      Parameters:
      namePrefix - The new name prefix

    • delegatedClose

      protected void delegatedClose()
      Overrides:
      delegatedClose in class io.deephaven.enterprise.comm.sched.JobScheduler

    • getLog

      public com.fishlib.io.logger.Logger getLog()
      Get this scheduler's log
      Returns:
      The log

    • start

      public void start()
      Start this scheduler.