Package io.deephaven.enterprise.comm

Class CommBase.SingleThreadedScheduler

java.lang.Object

io.deephaven.enterprise.niowrapper.sched.YASchedulerImpl

io.deephaven.enterprise.comm.CommBase.SingleThreadedScheduler

All Implemented Interfaces:

Scheduler

Enclosing class:

CommBase

public static class CommBase.SingleThreadedScheduler
extends YASchedulerImpl

Create a private, single-threaded scheduler and driver thread

Nested Class Summary

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

Scheduler.ExecutorAdaptor, Scheduler.Null

Field Summary

Fields inherited from class io.deephaven.enterprise.niowrapper.sched.YASchedulerImpl

log, name

Constructor Summary

Constructors

Constructor	Description
SingleThreadedScheduler(String name, com.fishlib.io.logger.Logger log)

Method Summary

Modifier and Type	Method	Description
CommBase.SingleThreadedScheduler	start()
void	stop()

Methods inherited from class io.deephaven.enterprise.niowrapper.sched.YASchedulerImpl

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

SingleThreadedScheduler

public SingleThreadedScheduler(String name,
 com.fishlib.io.logger.Logger log)
                        throws IOException

Throws:

IOException

Method Details

start

public CommBase.SingleThreadedScheduler start()

stop

public void stop()