A local data buffer with customizable data trigger
- multiple data trigger
- buffer container can be customized
- jdk1.8 only
<dependency>
<groupId>com.github.phantomthief</groupId>
<artifactId>buffer-trigger</artifactId>
<version>0.2.6-SNAPSHOT</version>
</dependency>// declare
BufferTrigger<String> buffer = SimpleBufferTrigger.<String, Set<String>> newBuilder() //
.on(3, TimeUnit.SECONDS, 1) //
.on(2, TimeUnit.SECONDS, 10) //
.on(1, TimeUnit.SECONDS, 10000) //
.consumer(this::out) //
.setContainer(ConcurrentSkipListSet::new, Set::add) // default is Collections.newSetFromMap(new ConcurrentHashMap<>())
.build();
// enqueue
buffer.enqueue("i'm ok");
// consumer declare
private void out(Collection<String> set) {
set.forEach(System.out::println);
}
// batch consumer blocking queue
BufferTrigger<String> buffer = BatchConsumeBlockingQueueTrigger.<String> newBuilder() //
.batchConsumerSize(3) //
.setConsumer(this::out) //
.queueCapacity(5) //
.build();
perlmonk with his great team gives me a huge help. (https://github.com/aloha-app)