Package software.xdev.tci.network

Class LazyNetworkPool

java.lang.Object

software.xdev.tci.network.LazyNetworkPool

public class LazyNetworkPool
extends Object

Provides a pool of LazyNetwork

Field Summary

Fields

Modifier and Type	Field	Description
protected final Executor	executor
protected static final AtomicInteger	NETWORK_COUNTER
protected Supplier<LazyNetwork>	networkSupplier
protected static final AtomicInteger	POOL_COUNTER
protected final LinkedBlockingQueue<LazyNetwork>	queue

Constructor Summary

Constructors

Constructor	Description
LazyNetworkPool()	Like LazyNetworkPool(int) but uses PreStartConfig to determine the size
LazyNetworkPool(int size)
LazyNetworkPool(int size, Executor executor)

Method Summary

Modifier and Type	Method	Description
protected LazyNetwork	bootNew()
static ThreadFactory	defaultThreadFactory()
LazyNetwork	getNew()
void	managePoolAsync()
protected void	managePoolInternal()
LazyNetworkPool	withNetworkSupplier(Supplier<LazyNetwork> networkSupplier)

Methods inherited from class java.lang.Object

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

Field Details

POOL_COUNTER

protected static final AtomicInteger POOL_COUNTER

NETWORK_COUNTER

protected static final AtomicInteger NETWORK_COUNTER

networkSupplier

protected Supplier<LazyNetwork> networkSupplier

queue

protected final LinkedBlockingQueue<LazyNetwork> queue

executor

protected final Executor executor

Constructor Details

LazyNetworkPool

public LazyNetworkPool()

Like LazyNetworkPool(int) but uses PreStartConfig to determine the size

LazyNetworkPool

public LazyNetworkPool(int size)

LazyNetworkPool

public LazyNetworkPool(int size,
 Executor executor)

Method Details

withNetworkSupplier

public LazyNetworkPool withNetworkSupplier(Supplier<LazyNetwork> networkSupplier)

bootNew

protected LazyNetwork bootNew()

managePoolAsync

public void managePoolAsync()

managePoolInternal

protected void managePoolInternal()

getNew

public LazyNetwork getNew()

defaultThreadFactory

public static ThreadFactory defaultThreadFactory()