wang.bigbird.domain.framework.core.prosumer

类 AccumulatorConsumer<T>

java.lang.Object

wang.bigbird.domain.framework.core.prosumer.AccumulatorConsumer<T>

所有已实现的接口:

Runnable

public class AccumulatorConsumer<T>
extends Object
implements Runnable

累加消费器，当缓存数据超过指定数量或者缓存时间超过指定时间，就一次性消费缓存中的数据

作者:

Bigbird

构造器概要

构造器

构造器和说明
AccumulatorConsumer(int maxSize, int timeOut, BlockingQueue<T> blockingQueue, java.util.function.Consumer<List<T>> consumer, IProducer producer)

方法概要

限定符和类型	方法和说明
void	forceConsume() 强制消费，一般用于任务终止时，将缓存中的剩余数据消费完毕
void	run()

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

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

构造器详细资料

AccumulatorConsumer

public AccumulatorConsumer(int maxSize,
                           int timeOut,
                           BlockingQueue<T> blockingQueue,
                           java.util.function.Consumer<List<T>> consumer,
                           IProducer producer)

方法详细资料

run

public void run()

指定者:

run 在接口中 Runnable

forceConsume

public void forceConsume()

强制消费，一般用于任务终止时，将缓存中的剩余数据消费完毕