Вопросы по теме 'producer-consumer'
Потоки производителя / потребителя, использующие очередь
Я хочу создать какое-нибудь Producer/Consumer приложение для потоковой передачи. Но я не уверен, как лучше всего реализовать очередь между ними.
Итак, у меня есть две идеи (обе могут быть совершенно неправильными). Я хотел бы знать, что было бы...
122143 просмотров
schedule
03.01.2024
ActiveMQ: медленная обработка потребителей
Что касается ActiveMQ: у меня есть сценарий, в котором у меня есть один производитель, который отправляет небольшие (около 10 КБ) файлы потребителям. Хотя файлы небольшие, потребителям требуется около 10 секунд, чтобы проанализировать их и вернуть...
3112 просмотров
schedule
23.02.2024
Проблема с потоками Java с использованием ConcurrentLinkedQueue
У меня проблема со следующим фрагментом кода. Он предназначен для обработки событий (предоставляемых через вызовы метода processEvent), которые добавляются в очередь событий (ConcurrentLinkedQueue). События добавляются в очередь событий и...
4218 просмотров
schedule
15.11.2022
Проблема с селектором MessageConsumer в ActiveMQ
Может кто-нибудь, пожалуйста, подтвердите, прав я или нет в этом. Мне кажется, что операция "селектор" выполняется в реализации MessageConsumer. (т. е. ВСЕ сообщения по-прежнему отправляются от брокера сообщений к MessageConsumer, а затем над этими...
1970 просмотров
schedule
19.10.2022
производитель-потребитель с ресурсом
Я пытаюсь реализовать шаблон производителя/потребителя с набором ресурсов, поэтому с каждым потоком связан один ресурс. Например, у меня может быть очередь задач, где каждая задача требует StreamWriter для записи результата. Каждой задаче также...
836 просмотров
schedule
09.11.2023
Как улучшить этот дизайн пула соединений?
Во-первых, я разрабатываю свою собственную реализацию DBCP (пул соединений с базой данных), как таковой,
Я не приму никаких предложений по использованию стороннего DBCP, такого как c3p0.
Я использую модель проектирования...
1004 просмотров
schedule
28.01.2024
Элегантные способы уведомить потребителя об окончании работы производителя?
Я реализую concurrent_blocking_queue с минимальными функциями:
//a thin wrapper over std::queue
template<typename T>
class concurrent_blocking_queue
{
std::queue<T> m_internal_queue;
//...
public:
void add(T const...
1894 просмотров
schedule
01.10.2022
Шаблон производителя-потребителя с concurrenthashmap в java
У меня есть следующая проблема, и я не уверен, как спроектировать части решения:
У меня есть большой текстовый файл, который я читаю построчно. Мне нужно обработать каждую строку и обновить HashMap.
Насколько мне известно, мне нужен один поток...
1221 просмотров
schedule
13.08.2022
Go: Один производитель много потребителей
Итак, я видел много способов реализации одного потребителя и множества производителей в Go — классическая функция fanIn из Параллелизм в Go .
Я хочу функцию fanOut. Он принимает в качестве параметра канал, из которого он считывает значение, и...
12333 просмотров
schedule
20.07.2022
Проблема проектирования модели производитель-потребитель
Я работаю над созданием дерева, представляющего собой электрический цирк (без кругов, как на этом рисунке)
Я использую эту реализацию:
Binary_Oprtator
public abstract class Binary_Oprtator {
abstract int calc(int x, int y);...
98 просмотров
schedule
25.08.2022
Производитель/Потребитель: один Производитель, несколько Потребителей, каждый из которых работает с одними и теми же данными.
У меня есть сценарий «производитель/потребитель», в котором я не хочу, чтобы один производитель доставлял продукты, а несколько потребителей потребляли эти продукты. Однако общий сценарий заключается в том, что доставленный продукт потребляется...
1223 просмотров
schedule
21.10.2022
Один производитель, несколько потребителей
Я работаю над некоторым кодом, но мне нужна помощь. Я создал одного производителя и одного потребителя, однако мне нужно создать несколько потребителей, которые будут потреблять конкретный String от производителя, например. Мне нужен потребитель,...
5253 просмотров
schedule
17.11.2023
Многопоточность с бесконечным циклом
Я написал это решение проблемы производителя/потребителя. Кажется, это работает, кроме бесконечного цикла. У меня сложилось впечатление, что pthread_exit(NULL); остановит это, но, честно говоря, я потерялся и запутался. Может ли кто-нибудь...
1093 просмотров
schedule
24.11.2023
Производитель-потребитель С# с использованием семафоров
Вдохновленный «Маленькой книгой семафоров», я решил реализовать проблему «производитель-потребитель» с помощью семафоров.
Я специально хочу иметь возможность останавливать все рабочие потоки по своему желанию. Я тщательно протестировал свою...
1472 просмотров
schedule
18.10.2023
Как установить принципала в производителе / потребителе консоли Kafka?
Я хочу поэкспериментировать с ACL в Kafka. Итак, я создал несколько списков ACL для образца темы test в моем Zookeeper, который разрешает производителю разрешение User: Bob для принципала и разрешение потребителя на Пользователь: Алиса ....
1205 просмотров
schedule
05.10.2022
Семафор в Аде
Это задание, и меня попросили реализовать семафор на Аде, как описано ниже.
Однако я реализовал Semaphore.adb и назвал этот семафор в producerconsumer_sem.adb , который я создал.
Я получаю следующий вывод.
Я не уверен, что моя...
2691 просмотров
schedule
19.11.2023
Производитель-Потребитель. Потребитель ждет, пока все производители закончат, ядовитая таблетка
У меня есть два производителя и один потребитель:
public class Main {
public static void main(String[] args) throws InterruptedException {
final BlockingQueue<Integer> integersQueue = new ArrayBlockingQueue<>(20);...
141 просмотров
schedule
07.09.2022
какая существенная разница между akka и ThreadPool+BlockingQueue в ОДНОМ процессе?
Мы знаем, что Akka — это одна из реализаций шаблона актера. Без Akka я обычно реализую простой шаблон актора, используя ThreadPool+BlockingQueue. Таким образом, сообщение предлагается в очередь, и работы (актеры) берут сообщение из очереди, а затем...
235 просмотров
schedule
11.11.2023
Как создать очередь производителей-потребителей
У меня есть производитель, который создает POJO со свойством type. Может быть только два типа: «А» и «В». У меня есть пул потоков для Consumer. Всякий раз, когда я получаю сообщение типа «B» от производителя, прежде чем я смогу приступить к...
313 просмотров
schedule
15.10.2022
Производитель-потребитель с pthreads + семафорами в C (одновременный доступ к буферным слотам)
Я написал многопоточную программу производитель-потребитель на C. Моя первоначальная программа не была минимальной/полной/проверяемой, поэтому я переписал ее с нуля, и ошибка все еще возникает. Я обнаружил, что несколько потоков производителей...
310 просмотров
schedule
18.04.2024
