producer-consumer

У меня есть очередь производителя / потребителя, за исключением того, что есть определенные типы объектов. Таким образом, не только любой потребитель может потреблять добавленный объект. Я не хочу делать определенную очередь для каждого типа, так как их слишком много. (Это как бы растягивает определение произ...

У меня есть ситуация, в которой у меня есть сценарий производителя/потребителя. Производитель никогда не останавливается, что означает, что даже если есть время, когда нет элементов в BC, другие элементы могут быть добавлены позже. Переходя от .NET Framework 3.5 к 4.0, я решил использовать BlockingCollection...

Я довольно новичок в многопоточном программировании,я просто знаю самую распространенную очередь производитель-потребитель. Я использую библиотеки boost c++ , и я не знаю, лучше ли использовать boost:: lockfree:: queue или класс-оболочку вокруг std:: queue, который использует 'mutex` и' condition_variable`. ...

Я работаю над небольшим многопоточным проектом.Система может быть разделена на 2 части, А и В. потоки данных от А к Б. Часть продолжает получать необработанные данные из внешнего мира, выполнять некоторые преобразования и затем генерировать тысячи новых данных, назовем это A_OUTPUT. B часть сделать некоторые ...

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

Мы имитируем ресторан-буфет с курицей тандури с одним шеф-поваром и несколько гостей, что похоже на проблему одного производителя / нескольких потребителей. Мы реализуйте одну программу с несколькими потоками, каждый из которых содержит либо шеф-повара, либо гостя. Мы также применяем один инструмент синхрониз...

Я недавно узнал о Разрушителе LMAX и провел некоторые эксперименты. Одна вещь, которая меня озадачивает, - это параметр endOfBatch метода обработчика onEvent метода EventHandler. Рассмотрим мой следующий код. Во-первых, фиктивные классы сообщений и потребителей, которые я называю Test1 и Test1Worker: public...

у меня есть один потоковый производитель, который создает некоторые объекты задачи, которые затем добавляются в ArrayBlockingQueue (который имеет фиксированный размер). Я также запускаю многопоточный потребитель. Это сборка в виде фиксированного пула потоков (Executors.newFixedThreadPool(threadCount);). Зате...