Описание тега producer-consumer
Проблема производителя и потребителя (также известная как проблема ограниченного буфера) является классическим примером проблемы синхронизации нескольких процессов. Проблема описывает два процесса, производителя и потребителя, которые используют общий буфер фиксированного размера, используемый в качестве очереди.
1
ответ
Использование EventMachine для настройки бесконечного цикла для генерации случайных данных
Я пытаюсь настроить автоматический стресс-тест и передать случайно сгенерированные данные в Redis, а затем заставить потребителя (как другой компонент, считываемый из Redis) обрабатывать случайные данные. Чтобы симулировать случайно сгенерированные …
26 мар '14 в 06:47
4
ответа
Реализация очереди блокировки в JavaME: как ее оптимизировать?
Я пытаюсь реализовать простую очередь блокировки в Java ME. В JavaME API утилиты параллелизма Java SE недоступны, поэтому я должен использовать ожидание-уведомление, как в старые времена. Это моя предварительная реализация. я использую notify вместо…
26 апр '12 в 08:38
3
ответа
Java Servlet Threading
Я выполнил следующую конструкцию Java-сервлета: [Я считаю, что основная идея - идея потребителя-производителя] Java-сервлет, который получает несколько запросов HTTP POST Он помещает все запросы в очередь [ConcurrentLinkedQueue] Все запросы в очеред…
22 июл '12 в 13:38
1
ответ
Домашняя работа, Java, Предотвращение тупиковой ситуации при использовании notify() вместо notifyAll() в модели multiProducer/singleConsumer
Поэтому я работаю над этим отчетом, и последним заданием является создание модели производителя / потребителя с n Продюсеры и один потребитель, хитрость в том, что мне нужно заставить его работать notify() вместо notifyAll() в пут и получить методы.…
29 ноя '15 в 17:37
1
ответ
Каково значение condition.notify() в поточном модуле python?
Поэтому я использую условие Python из модуля потоков: from threading import Thread, Condition condition = Condition() У меня есть класс Producer (подкласс Thread), который, по существу, в цикле for добавляет элементы в очередь до тех пор, пока очере…
20 сен '17 в 18:16
1
ответ
Конструктор по умолчанию TPL BufferBlock: значение DataFlowBlockOptions
Если вы используете конструктор по умолчанию для создания TPL BufferBlockявляются DataFlowBlockOptions неограничен? Другими словами, что такое BoundedCapacity из BufferBlock? Как указано в этом ответе SO, невозможно ни запросить, ни изменить значени…
18 май '17 в 09:04
1
ответ
Производитель / Потребитель, использующий ожидание и уведомление
Я пытаюсь согласовать проблему с продюсером и потребителем. Производитель ставит в очередь 10 объектов. То есть метод запуска продюсера включает в себя простой цикл для добавления 10 объектов, после чего он завершается. Когда очередь заполнена (разм…
23 ноя '12 в 17:04
1
ответ
Производитель-потребитель между двумя детьми раздвоены [C]
У меня проблема с этим известным вопросом. Я должен раскошелиться на двух детей (производитель и потребитель), которые общаются благодаря трубе. Первый дочерний элемент (производитель) должен прочитать строки из стандартного ввода, отправить их втор…
30 янв '17 в 17:50
3
ответа
Вызвать метод класса Java, который реализует runnable после создания своего объекта потока
У меня есть класс Java SomeClass implements Runnable Который имеет метод display(). Когда я создаю поток этого класса Thread thread1 = new Thread(new SomeClass()); Теперь, как я могу вызвать метод display (), используя экземпляр потока?
13 ноя '12 в 22:31
0
ответов
Как решить проблему производителя и потребителя в Android
У меня есть метод обратного вызова в моем классе обслуживания, который будет вызываться каждую секунду со списком данных, и он непрерывно записывается в JSONArray, как показано ниже. Этот метод onDataCapturemethod() вызывается каждую секунду. Так чт…
28 окт '18 в 17:34
1
ответ
Почему condition_variable ожидает блокировки у производителя-потребителя? C++
Смотрите следующий классический код производителя-потребителя: int main() { std::queue<int> produced_nums; std::mutex m; std::condition_variable cond_var; bool done = false; bool notified = false; std::thread producer([&]() { for (int i = …
21 май '18 в 07:57
0
ответов
Задача не работает параллельно
У меня есть две задачи, которые работают как производитель и потребитель, но они не работают параллельно. Второй ждет первого, чтобы соревноваться. Можете ли вы объяснить, почему и как я могу это исправить? Я хочу, чтобы они оба запускались одноврем…
06 апр '14 в 09:15
1
ответ
Реализация многопользовательского буфера pthread одного производителя с использованием условных переменных
Я пишу наивную реализацию буфера с несколькими потребителями одного производителя с pthreads и условными переменными, используя список C++ в качестве буфера. Меня не слишком беспокоит скорость выполнения моего кода, я просто хочу избавиться от ошибо…
03 авг '15 в 05:14
1
ответ
Шаблон производитель-потребитель с использованием Java и Spring
Мне нужно решить проблему, используя шаблон производителя-потребителя, используя Java и Spring Framework. Проблема в том, что я новичок в Spring Framework (я понятия не имею), поэтому кто-нибудь может направить меня в правильном направлении о том, к…
05 фев '16 в 19:35
2
ответа
Асинхронно потребляющая труба с башом
У меня есть такой скрипт data_generator_that_never_guits | while read data do an_expensive_process_with data done Первый процесс непрерывно генерирует события (с нерегулярными интервалами), которые необходимо обрабатывать по мере их появления. Пробл…
24 сен '14 в 14:39
3
ответа
Детерминированный мониторинг импульса / ожидания и реализация таймаута в коллекции производителя-потребителя
Я пытаюсь реализовать параллельную коллекцию производитель-потребитель (несколько производителей и потребителей), которая поддерживает тайм-ауты для потребителей. Теперь фактическая коллекция довольно сложна (к сожалению, ничего в System.Collections…
20 май '12 в 15:17
1
ответ
Гибридное решение алгоритма потребительского производителя
Я пытаюсь показать, что следующее решение проблемы производителя / потребителя не работает, показывая, что, когда потребитель находится в начале M1, есть случай, когда он не сможет удалить из очереди конечный элемент время и / или есть случай, когда…
16 апр '13 в 17:21
1
ответ
Кафка производитель плохая производительность
У меня проблема с производителем кафки. На самом деле я использую Spring Kafka и отправляю сообщения через KafkaTemplate следующим образом: DefaultKafkaProducerFactory<K, V> defaultKafkaProducerFactory = new DefaultKafkaProducerFactory<>…
13 окт '18 в 07:27
1
ответ
Многократный потребительский производитель в Java
Я пытался создать 2 темы для потребителя и 2 темы для производителя. Все 4 темы связаны с одним ресурсом. Двое из них пытаются потреблять ресурсы, а двое пытаются добывать. Ниже приведен код package com.threading; import java.util.ArrayList; import …
29 авг '18 в 17:28
1
ответ
Camel; Простой маршрут от седы к бобу не сработает
Я новичок в Camel и пытаюсь настроить очень простое приложение, чтобы привыкнуть к нему, я запускаю следующий код: CamelContext cc = (CamelContext)ac.getBean("testCamelContext"); ProducerTemplate template = cc.createProducerTemplate(); System.out.pr…
23 ноя '12 в 11:52