Package io.deephaven.enterprise.comm.impl.nio

Class FastNIODriver

java.lang.Object

io.deephaven.enterprise.comm.impl.nio.FastNIODriver

All Implemented Interfaces:

Runnable

public final class FastNIODriver
extends Object
implements Runnable

Method Summary

Modifier and Type	Method	Description
static FastNIODriver	createDrivers(String name, com.fishlib.io.logger.Logger log, int initialThreads, int maxThreads, long workTimeout, int spinsUntilPark, boolean crashOnMax)
static FastNIODriver	createDrivers(String name, com.fishlib.io.logger.Logger log, int initialThreads, int maxThreads, long workTimeout, int spinsUntilPark, boolean crashOnMax, boolean doTimingStats, boolean doSpinSelect)
static Scheduler[]	createSchedulers(String name, String property, com.fishlib.io.logger.Logger log)
static Scheduler[]	createSchedulers(String name, String property, com.fishlib.io.logger.Logger log, com.fishlib.configuration.Configuration config)
Scheduler	getScheduler()
boolean	isShutdown()
int	junit_getCreated()
int	junit_getDestroyed()
int	junit_getWaiting()
static int	numTotalThreads(String property)
void	run()
boolean	shutdown(long maxWait)
String	summary()
static int	threadsPerScheduler(String property)

Methods inherited from class java.lang.Object

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

Method Details

numTotalThreads

public static int numTotalThreads(String property)

threadsPerScheduler

public static int threadsPerScheduler(String property)

createSchedulers

public static Scheduler[] createSchedulers(String name,
 String property,
 com.fishlib.io.logger.Logger log)

createSchedulers

public static Scheduler[] createSchedulers(String name,
 String property,
 com.fishlib.io.logger.Logger log,
 com.fishlib.configuration.Configuration config)

createDrivers

public static FastNIODriver createDrivers(String name,
 com.fishlib.io.logger.Logger log,
 int initialThreads,
 int maxThreads,
 long workTimeout,
 int spinsUntilPark,
 boolean crashOnMax)

createDrivers

public static FastNIODriver createDrivers(String name,
 com.fishlib.io.logger.Logger log,
 int initialThreads,
 int maxThreads,
 long workTimeout,
 int spinsUntilPark,
 boolean crashOnMax,
 boolean doTimingStats,
 boolean doSpinSelect)

summary

public String summary()

run

public void run()

Specified by:

run in interface Runnable

isShutdown

public boolean isShutdown()

shutdown

public boolean shutdown(long maxWait)

getScheduler

public Scheduler getScheduler()

junit_getWaiting

public int junit_getWaiting()

junit_getCreated

public int junit_getCreated()

junit_getDestroyed

public int junit_getDestroyed()