producer-consumer

4зной

1ответ

Параллельность: как реализовать исполнителя с входящими и исходящими очередями?

Как известно, ThreadPoolExecutor использует некоторый BlockingQueue в качестве очереди входящих задач. Я хочу, чтобы у ThreadPoolExecutor была очередь для результатов задачи, которые были готовы. Я хо

2зной

2ответ

Производитель и потребитель нитей Java

Я написал небольшую программу для использования ReentrantLock вместо synchronized проблемы производителя и потребителя. Но программа застряла, потому что, как только произведенные предметы будут потре

0зной

1ответ

Как написать пробный носик kafka с помощью нового API-интерфейса Kafka?

Нравится шторм-кафка-клиент, меня использовал штормовой кафка-клиент, но он не может хорошо работать, а новый носик тоже не работает. Кто может помочь мне написать пробный кафка.

1зной

1ответ

Ожидание многократных событий импульсов

Мне приложено приложение, которое сводится к тому, чтобы быть образцом производителя-потребителя. Несколько потоков выполняют некоторую работу и обновляют один набор данных, так что еще несколько пото

0зной

2ответ

ошибка с сегментацией производителя-потребителя для больших значений

Я делаю одну проблему с производителем-одним потребителем с двумя потоками в c. Я сделал это, используя общий связанный список, в котором производитель помещает что-то, и потребитель берет его из того

1зной

1ответ

Async Producer/Consumer с дроссельной продолжительностью и потребляемым количеством пакетов

Я пытаюсь создать службу, которая предоставляет очередь для многих асинхронных клиентов для выполнения запросов и ожидания ответа. Мне нужно уметь обрабатывать обработку очереди по X-запросам на Y-дли