# buffer-trigger

**Repository Path**: mirrors_hsiafan/buffer-trigger

## Basic Information

- **Project Name**: buffer-trigger
- **Description**: No description available
- **Primary Language**: Unknown
- **License**: Artistic-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2020-10-13
- **Last Updated**: 2026-01-17

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

buffer-trigger
=======================
[![Build Status](https://travis-ci.org/PhantomThief/buffer-trigger.svg)](https://travis-ci.org/PhantomThief/buffer-trigger)
[![Coverage Status](https://coveralls.io/repos/PhantomThief/buffer-trigger/badge.svg?branch=master)](https://coveralls.io/r/PhantomThief/buffer-trigger?branch=master)
[![Total alerts](https://img.shields.io/lgtm/alerts/g/PhantomThief/buffer-trigger.svg?logo=lgtm&logoWidth=18)](https://lgtm.com/projects/g/PhantomThief/buffer-trigger/alerts/)
[![Language grade: Java](https://img.shields.io/lgtm/grade/java/g/PhantomThief/buffer-trigger.svg?logo=lgtm&logoWidth=18)](https://lgtm.com/projects/g/PhantomThief/buffer-trigger/context:java)
[![Maven Central](https://img.shields.io/maven-central/v/com.github.phantomthief/buffer-trigger)](https://search.maven.org/artifact/com.github.phantomthief/buffer-trigger/)

A local data buffer with customizable data trigger

* customize trigger strategy
* buffer container can be customized
* jdk1.8 only

## Usage

```Java

// declare
BufferTrigger<String> buffer = SimpleBufferTrigger.<String, Set<String>> newBuilder()
        .triggerStrategy(new MultiIntervalTriggerStrategy()
            .on(10, SECONDS, 1)
            .on(5, SECONDS, 10)
            .on(1, SECONDS, 100)
        )
        .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()
                .batchSize(3)
                .setConsumerEx(this::out)
                .bufferSize(5)
                .linger(ofSeconds(2))
                .build();
    
```

## Special Thanks

perlmonk with his great team gives me a huge help.
(https://github.com/aloha-app)