conversant / disruptor

Disruptor BlockingQueue
Apache License 2.0
310 stars 48 forks source link

Support for timeouts #6

Closed brettwooldridge closed 7 years ago

brettwooldridge commented 7 years ago

Would it be possible to add support for timeouts? For example:

final T entry = handoffQueue.poll(timeout, NANOSECONDS);

In our case, MultithreadConcurrentQueue is the queue we would desire to use.

brettwooldridge commented 7 years ago

Nevermind.