org.redkale.source

类 PoolTcpSource

java.lang.Object

org.redkale.source.PoolSource<AsyncConnection>

org.redkale.source.PoolTcpSource

public abstract class PoolTcpSource
extends PoolSource<AsyncConnection>

字段概要

字段

限定符和类型	字段和说明
protected ObjectPool<java.nio.ByteBuffer>	bufferPool
protected java.util.concurrent.ArrayBlockingQueue<AsyncConnection>	connQueue
protected java.util.concurrent.ThreadPoolExecutor	executor
protected java.nio.channels.AsynchronousChannelGroup	group
protected java.util.concurrent.ExecutorService	pollExecutor

从类继承的字段 org.redkale.source.PoolSource

attributes, closeCounter, connectTimeoutSeconds, creatCounter, cycleCounter, database, dbtype, encoding, logger, maxconns, password, props, readTimeoutSeconds, rwtype, saveCounter, semaphore, servaddr, url, username, usingCounter, writeTimeoutSeconds

构造器概要

构造器

构造器和说明
PoolTcpSource(java.lang.String rwtype, java.util.concurrent.ArrayBlockingQueue queue, java.util.concurrent.Semaphore semaphore, java.util.Properties prop, java.util.logging.Logger logger, ObjectPool<java.nio.ByteBuffer> bufferPool, java.util.concurrent.ThreadPoolExecutor executor)

方法概要

限定符和类型	方法和说明
void	change(java.util.Properties prop)
void	close()
void	offerConnection(AsyncConnection conn)
AsyncConnection	poll()
java.util.concurrent.CompletableFuture<AsyncConnection>	pollAsync()
protected java.util.concurrent.CompletableFuture<AsyncConnection>	pollAsync(int count)
protected abstract java.nio.ByteBuffer	reqConnectBuffer(AsyncConnection conn)
protected abstract void	respConnectBuffer(java.nio.ByteBuffer buffer, java.util.concurrent.CompletableFuture<AsyncConnection> future, AsyncConnection conn)
protected abstract java.util.concurrent.CompletableFuture<AsyncConnection>	sendCloseCommand(AsyncConnection conn)

从类继承的方法 org.redkale.source.PoolSource

getCloseCount, getConnectTimeoutSeconds, getCreatCount, getCycleCount, getDatabase, getDbtype, getDefaultPort, getMaxconns, getPassword, getReadTimeoutSeconds, getSaveCount, getServaddr, getUrl, getUsername, getUsingCount, getWriteTimeoutSeconds, parseAddressAndDbnameAndAttrs

从类继承的方法 java.lang.Object

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

字段详细资料

bufferPool

protected ObjectPool<java.nio.ByteBuffer> bufferPool

executor

protected java.util.concurrent.ThreadPoolExecutor executor

pollExecutor

protected java.util.concurrent.ExecutorService pollExecutor

group

protected java.nio.channels.AsynchronousChannelGroup group

connQueue

protected final java.util.concurrent.ArrayBlockingQueue<AsyncConnection> connQueue

构造器详细资料

PoolTcpSource

public PoolTcpSource(java.lang.String rwtype,
                     java.util.concurrent.ArrayBlockingQueue queue,
                     java.util.concurrent.Semaphore semaphore,
                     java.util.Properties prop,
                     java.util.logging.Logger logger,
                     ObjectPool<java.nio.ByteBuffer> bufferPool,
                     java.util.concurrent.ThreadPoolExecutor executor)

方法详细资料

offerConnection

public void offerConnection(AsyncConnection conn)

指定者:

offerConnection 在类中 PoolSource<AsyncConnection>

change

public void change(java.util.Properties prop)

指定者:

change 在类中 PoolSource<AsyncConnection>

poll

public final AsyncConnection poll()

指定者:

poll 在类中 PoolSource<AsyncConnection>

reqConnectBuffer

protected abstract java.nio.ByteBuffer reqConnectBuffer(AsyncConnection conn)

respConnectBuffer

protected abstract void respConnectBuffer(java.nio.ByteBuffer buffer,
                                          java.util.concurrent.CompletableFuture<AsyncConnection> future,
                                          AsyncConnection conn)

pollAsync

public java.util.concurrent.CompletableFuture<AsyncConnection> pollAsync()

指定者:

pollAsync 在类中 PoolSource<AsyncConnection>

pollAsync

protected java.util.concurrent.CompletableFuture<AsyncConnection> pollAsync(int count)

close

public void close()

指定者:

close 在类中 PoolSource<AsyncConnection>

sendCloseCommand

protected abstract java.util.concurrent.CompletableFuture<AsyncConnection> sendCloseCommand(AsyncConnection conn)