程序包 gu.sql2java

类 QueueBufferProducerAction.SimpleQueueProducerAction<B extends gu.sql2java.BaseBean>

java.lang.Object

gu.sql2java.QueueBufferProducerAction<B,B>

gu.sql2java.QueueBufferProducerAction.SimpleQueueProducerAction<B>

类型参数:

B - 从数据库读取的原始记录对象类型

所有已实现的接口:

gu.sql2java.TableManager.Action<B>

封闭类:

QueueBufferProducerAction<B extends gu.sql2java.BaseBean,T>

public static class QueueBufferProducerAction.SimpleQueueProducerAction<B extends gu.sql2java.BaseBean>
extends QueueBufferProducerAction<B,B>

QueueBufferProducerAction的简化版本,队列类型为数据库原始记录类型

从以下版本开始:

3.15.4

作者:

guyadong

嵌套类概要

从类继承的嵌套类/接口 gu.sql2java.QueueBufferProducerAction

QueueBufferProducerAction.SimpleQueueProducerAction<B extends gu.sql2java.BaseBean>

构造器概要

构造器

构造器	说明
SimpleQueueProducerAction(int queueCapaticy, int bufferCapacity, int queueTimeout, AtomicBoolean stopped, boolean outputProgress, long rowCount)	构造方法
SimpleQueueProducerAction(QueueBufferProducerAction.SimpleQueueProducerAction<B> action, long rowCount)	构造方法
SimpleQueueProducerAction(AtomicBoolean stopped, long rowCount)	构造方法 队列容量和插入队列超时时间使用默认值
SimpleQueueProducerAction(BlockingQueue<List<B>> queue, int bufferCapacity, int queueTimeout, AtomicBoolean stopped, long rowCount)	构造方法

方法概要

从类继承的方法 gu.sql2java.QueueBufferProducerAction

call, getBufferCapacity, getQueue, getRowCount

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

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

构造器详细资料

SimpleQueueProducerAction

public SimpleQueueProducerAction(BlockingQueue<List<B>> queue,
 int bufferCapacity,
 int queueTimeout,
 AtomicBoolean stopped,
 long rowCount)

构造方法

参数:

queue - 阻塞队列

bufferCapacity - 缓冲区容量

queueTimeout - 插入队列超时时间(秒), 队列满后超过这个时间不能插入新记录即视消费端中止,并中止插入 小于等于0使用默认值QueueBufferProducerAction.DEFAULT_QUEUE_TIMEOUT

stopped - 停止标志,为null忽略,为true时不再向队列添加数据，抛出QueueTimeoutException，结束循环

rowCount - 当前查询的记录总数

SimpleQueueProducerAction

public SimpleQueueProducerAction(int queueCapaticy,
 int bufferCapacity,
 int queueTimeout,
 AtomicBoolean stopped,
 boolean outputProgress,
 long rowCount)

构造方法

参数:

queueCapaticy - 队列容量,小于等于0使用默认值QueueBufferProducerAction.DEFAULT_QUEUE_CAPACITY

bufferCapacity - 缓冲区容量

queueTimeout - 插入队列超时时间(秒), 队列满后超过这个时间不能插入新记录即视消费端中止,并中止插入 小于等于0使用默认值QueueBufferProducerAction.DEFAULT_QUEUE_TIMEOUT

stopped - 停止标志,为null忽略,为true时不再向队列添加数据，抛出QueueTimeoutException，结束循环

outputProgress - 是否输出进度

rowCount - 记录总数

SimpleQueueProducerAction

public SimpleQueueProducerAction(AtomicBoolean stopped,
 long rowCount)

构造方法
队列容量和插入队列超时时间使用默认值

参数:

stopped - 停止标志,为null忽略,为true时不再向队列添加数据，抛出QueueTimeoutException，结束循环

rowCount - 当前查询的记录总数

SimpleQueueProducerAction

public SimpleQueueProducerAction(QueueBufferProducerAction.SimpleQueueProducerAction<B> action,
 long rowCount)

构造方法

另请参阅:

• QueueBufferProducerAction(QueueBufferProducerAction, long)