conversant/disruptor

Support for timeouts

brettwooldridge opened this issue · 1 comments

brettwooldridge commented

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

Nevermind.