Package | Description |
---|---|
io.netty.util.concurrent |
Utility classes for concurrent / async tasks.
|
Modifier and Type | Method and Description |
---|---|
int |
MpscIntQueue.drain(int limit,
IntConsumer consumer)
Remove up to the given limit of elements from the queue, and pass them to the consumer in order.
|
int |
MpscAtomicIntegerArrayQueue.drain(int limit,
IntConsumer consumer) |
Copyright © 2008–2025 The Netty Project. All rights reserved.