Вопросы по теме 'producer-consumer'

Общий .Net Производитель / Потребитель
Я обдумываю идею реализации общей пары «производитель / потребитель + очередь обработки» на C # для развлечения. Идея состоит в том, что вы можете просто создать объекты, реализующие соответствующие интерфейсы IProducer и IConsumer (поставляемые...
5216 просмотров
schedule 22.02.2022

Включает ли .NET 4 Parallel Extensions реализацию свободной от блокировки очереди Producer/Consumer?
Включает ли .NET 4 Parallel Extensions реализацию свободной от блокировки очереди Producer/Consumer? Есть ли какой-либо класс или интерфейс для реализации, который мог бы помочь мне правильно реализовать этот шаблон? Спасибо!
485 просмотров

Проблема нерегулярной передачи с Python Twisted Push Producer
Я хочу передавать данные из очереди с помощью Twisted. В настоящее время я использую push-производитель для опроса очереди на наличие элементов и записи в транспорт. class Producer: implements(interfaces.IPushProducer) def...
756 просмотров
schedule 10.08.2022

Подождите, пока будет выполнено ровно n работ: производитель, потребитель и счетчик.
Проблема, с которой я сталкиваюсь, заключается в том, что у меня есть поток A, и нужно выполнить n работ. Поток A должен ждать, пока эти n операций не будут полностью выполнены. Моя идея заключается в использовании CountDownLatch со счетом n и...
560 просмотров

BlockingCollection — проблема высокой синхронизации
Каков наилучший способ получать сообщения из многих потоков в очередь и иметь отдельные потоки, обрабатывающие элементы этой очереди по одному? Я часто использую этот шаблон, когда пытаюсь отключить действия от многих потоков. Я использую для...
2542 просмотров
schedule 11.01.2024

Чтение незаписанной страницы из другого процесса
У меня есть процесс-производитель, который записывает в файл mmap, и процесс-потребитель, который читает из него. Это на линуксе. Если производитель вносит изменения в mmap и он не очищается мгновенно, что происходит, когда потребитель обращается...
114 просмотров
schedule 01.07.2022

Что предлагают сопрограммы в python, которые улучшают наивную настройку потребителя/производителя?
Я немного почитал про сопрограммы, в частности про питон, и что-то мне не совсем очевидно. Я реализовал модель производитель/потребитель, базовая версия которой выглядит следующим образом: #!/usr/bin/env python class MyConsumer(object):...
918 просмотров

Потребление сообщений JMS
Я не уверен, что происходит в приведенных ниже сценариях, было бы очень полезно, если бы кто-нибудь объяснил это. Производитель (P) посылает сообщения M1, M2, M3, M4, M5, M6, M7; предполагая, что он отправлен с момента времени T1 до T7....
812 просмотров
schedule 07.12.2022

Разве это не должно потерпеть неудачу без использования блокировки? Простой производитель-потребитель
У меня есть очередь, список с потоками производителей и список с потоками потребителей. Мой код выглядит так public class Runner { List<Thread> Producers; List<Thread> Consumers; Queue<int> queue; Random...
293 просмотров

Модель Производитель/Потребитель равна Актеру?
Поэтому в последнее время я читал много статей о том, как сложно параллельное программирование и как почти невозможно параллельное программирование с общим состоянием. Таким образом, такие языки, как Erlang (я думаю, что это включено, если вопрос не...
1100 просмотров

Архитектура производитель-потребитель с Java RealTime
Я работаю над проектированием торговой системы с использованием Java Realtime ( Sun JRTS 2.2 ) и хотел бы задать несколько вопросов о лучших практиках, потому что боюсь изобретать велосипед и почти уверен, что моя задача уже решена. Итак, у меня...
1958 просмотров

C - потребитель/производитель оказывается в тупике, когда производитель превышает размер буфера
У меня есть задание работать над проблемой производителя и потребителя, используя поток и семафор. Задача состоит в том, чтобы позволить пользователю определить # производителя, # потребителя и размер буфера. Программа всегда блокируется, если...
3062 просмотров

Пример Java использования ExecutorService и PipedReader/PipedWriter (или PipedInputStream/PipedOutputStream) для потребителя-производителя
Я ищу простую реализацию производителя-потребителя на Java и не хочу изобретать велосипед. Мне не удалось найти пример, в котором используется как новый пакет параллелизма, так и любой из классов Piped. Есть ли пример использования как...
4342 просмотров

Как создать службу WCF, которая действует в очереди «Производитель\Потребитель»?
У меня есть служба WCF, к которой подключаются несколько клиентов и подписываются на события. У меня также есть рабочий поток , который работает в фоновом режиме вместе с размещенной службой WCF и выполняет операции и помещает элементы в...
768 просмотров
schedule 11.04.2023

boost::thread производитель потребитель
Я новичок в boost::thread . Я создаю производителя-потребителя с монитором. Вот как я закодировал это до сих пор. //{ Declarations in header private: boost::condition_variable _condition; boost::mutex _mutex;...
1008 просмотров
schedule 27.07.2023

абстрактный класс и тип значения, не допускающий значения NULL
Я пытаюсь скомпилировать код ( Больше удовольствия от итератора с производителем / потребителем шаблон ), предложенный гуру Джо Даффи для класса производитель / потребитель, но возникает эта ошибка: (Я использую Visual Studio 2010 и net 4.0.3)...
2069 просмотров

Реализуйте пакетный процесс с помощью производителя-потребителя
Партия читать текст из файла или SQL разобрать текст на слова загрузить слова в SQL Сегодня .NET 4.0 Шаг 1 выполняется очень быстро. Шаги 2 и 3 имеют примерно одинаковую длину (в среднем 0,1 секунды) для файла одинакового размера. На...
871 просмотров

Многопоточность нескольких потоков производителя и потребителя не будет синхронизировать условие гонки BlockingCollection
У меня есть несколько производителей и несколько потребителей. Мой общий ресурс — BlockingCollection. Однако мой код работает, только если у меня есть один потребитель. Я знаю, что это состояние гонки, так как вывод каждый раз разный, когда я...
1655 просмотров

Производитель/потребитель Меса против семантики Хоара
Я столкнулся с двумя разными реализациями мониторов. Тот, который использует цикл while, который проверяет, верно ли определенное условие каждый раз перед сном и снова при пробуждении ото сна. Другой просто проверяет один раз, истинно ли условие if,...
3265 просмотров

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