Disruptor Consumer проверяет доступную последовательность - PullRequest
0 голосов
/ 04 декабря 2018

Я использую Disruptor для своего многопоточного приложения, и теперь у меня есть пример использования, когда для моего потребителя кольцевого буфера я не хочу, чтобы он ждал.Я просто хочу проверить, есть ли доступная последовательность.Если есть, я буду потреблять, в противном случае двигаться дальше.Тем не менее, все, что я вижу до сих пор, - это ожидание чего-то, что блокирует ... тогда как для издателя у нас есть tryNext, который не ждет, если не сможет опубликовать.Есть ли эквивалент для потребителя?Я не хочу взламывать его с помощью Alert / TimeoutException и т. Д.

Спасибо,

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...