A modified version of ArrayBlockingQueue that allows one to set a max fill threshold that determines when the queue will be emptied.
The queue expects multiple threads enqueuing data and a single thread waiting to deque data via the drainTo function.
A sample usage is as follows:
// build queue and launch threads
MeteredBlockingQueue<YourDataType> mbq;
...
// main loop for dequeuing data
while (!mbq.isPoisoned() || (mbq.isPoisoned() && mbq.size() != 0)) {
status = "Waiting";
List<YourDataType> data = new LinkedList<>();
if (mbq.drainTo(data, maxWorkCycleTimeNanos) != 0) {
// Do something with your list of data
...
}
}MeteredBlockingQueue is licensed under the MIT License. (See LICENSE)
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent