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

MSMQ — быстрый производитель/медленный потребитель
У меня проблема с обменом сообщениями (с MSMQ), который является разновидностью быстрого производителя/медленного потребителя. Есть ли способ получить количество невыполненных неизрасходованных сообщений в частной очереди MSMQ? Я хотел бы...
1302 просмотров

Модель производитель-потребитель - бинарный семафор или мьютекс?
В основном это касается понимания концепции, что меня смущает. Mutex означает, что один поток берет на себя управление доступом к общему ресурсу, выполняет операции и разблокирует его, после чего только другой поток может получить доступ к...
3254 просмотров

Правильная реализация сценария производитель-потребитель и корректное завершение пула потоков
Я работаю над своим первым многопоточным проектом, и поэтому у меня есть пара вещей, в которых я не уверен. Подробная информация о моей настройке была в предыдущем вопросе , вкратце: у меня есть пул потоков, реализованный...
791 просмотров
schedule 03.05.2022

Каков самый простой способ приостановить Consumer в шаблоне PC?
У меня типичное приложение производитель-потребитель. У меня есть BlockingCollection для обеспечения механизма производства-потребления. Что мне нужно, так это добавить возможность приостанавливать выполнение потребительского потока из другого...
100 просмотров
schedule 24.04.2022

Сообщения HornetQ все еще остаются в очереди после использования с использованием основного API
Я новичок в HornetQ, поэтому, пожалуйста, потерпите меня. Позвольте мне сначала сказать вам мои требования: Мне нужно промежуточное программное обеспечение для очереди сообщений, которое может передавать сообщения размером около 1 КБ между...
8377 просмотров

Очередь заданий в виде таблицы SQL с несколькими потребителями (PostgreSQL)
У меня типичная проблема производитель-потребитель: Несколько приложений-производителей записывают запросы на работу в таблицу вакансий в базе данных PostgreSQL. Запросы на работу имеют поле состояния, которое при создании содержит "Очередь"....
23154 просмотров
schedule 05.03.2023

Несколько производителей, один потребитель
У меня есть задача T , которую нужно выполнять с фиксированной скоростью R . У меня есть несколько java-программ P1 , P2 и т. д., выполняющих эту задачу независимо друг от друга с входными данными разных типов. Я хочу, чтобы задача выполнялась...
1122 просмотров
schedule 18.05.2023

Производитель-Потребитель с ExecutorService.newFixedThreadPool - Сколько потоков создано?
public class MainClass { private static final int producerPoolSize = 10; private static final int consumerPoolSize = 20; private ExecutorService prodExec = Executors.newFixedThreadPool(producerPoolSize); private ExecutorService consExec =...
11208 просмотров

shmat() возвращает другой shmaddr для того же shmkey
Вот моя установка... /* Bounded Buffer item structure */ struct item { int id; /* string index value */ char str[80]; /* string value */ }; /* Structure for the shared memory region */ typedef struct { int debug; /*...
3374 просмотров
schedule 17.01.2024

Почему GC не собирает неиспользуемые объекты?
Я реализовал шаблон Producer/Consumer с BlockingCollection для своего эксперимента. PerformanceCounter c = null; void Main() { var p =System.Diagnostics.Process.GetCurrentProcess(); c = new PerformanceCounter("Process", "Working Set -...
1219 просмотров
schedule 07.03.2024

Запуск Producer-Tasks из вызываемого метода?
Я новичок в задачах и должен решить проблему здесь. Я постоянно получаю int и float (примерно каждые 10 мс), которые изначально фильтруются из постоянного потока данных, а затем обрабатываются разными алгоритмами. Я хочу сложить их в...
73 просмотров
schedule 21.02.2023

C++, что и/или где выполняется pthread?
Я создал многопоточный производитель-потребитель (добавляю в очередь, потребляю из очереди, используя многочисленные потоки), но я пытаюсь еще больше оптимизировать это, отправляя новый продукт() непосредственно в потоки выполнения, если они...
236 просмотров

Производитель-потребитель в Java с переключателем пользовательского интерфейса
Я пытаюсь и не могу реализовать шаблон Producer Consumer в java с учетом следующих ограничений: Производитель создает (а Потребитель потребляет) очередь конечного размера. Существует пользовательский интерфейс с кнопками, переключающими...
1062 просмотров
schedule 10.07.2023

производитель/потребитель, использующий ускоренные потоки и циклические зависания буфера
Я понял. Глупая ошибка с моей стороны, я на самом деле не удалял элемент из очереди, я просто читал первый элемент. Я изменил код, и код ниже не работает. Спасибо всем за помощь. Я пытаюсь реализовать проблему производителя-потребителя,...
8281 просмотров
schedule 08.04.2022

Это работа для TPL Dataflow?
Я использую довольно типичную модель производитель / потребитель для разных задач. Задача 1: считывает пакеты byte [] из двоичных файлов и запускает новую задачу для каждой коллекции массивов байтов. (операция запрограммирована в целях управления...
2570 просмотров

Как реализовать общий буфер между потоками Java?
Я намеревался написать общий буфер между потоком-производителем и потоком-потребителем. Вот мои коды: class PQueue { Token token; boolean flag = false; // false: add, true: poll PQueue() { token = null; }...
3022 просмотров

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

Производитель-потребитель на Яве для рейсов в аэропорт
У меня есть массив из 40 регулярных рейсов; каждый объект полета хранит данные: номер рейса, авиакомпанию, город вылета, город прибытия, время полета, продолжительность полета. По мере того, как происходит время каждого рейса, поток генератора...
628 просмотров
schedule 13.11.2023

Производитель-потребитель в Java - несколько потребителей
У меня есть модель производитель-потребитель на Java с несколькими потребителями. Я передаю объект между производителями и потребителями, у которого есть переменная, назовем ее «имя». Теперь это имя может быть A, B или C. Если значение равно A,...
731 просмотров
schedule 13.08.2022

Параллельный двусвязный список — очередь FIFO с несколькими производителями/потребителями — тупиковая ситуация
Я играл с двусвязным списком для MPMC FIFO-Queue (в основном в демонстрационных целях). Сейчас я пытаюсь зафиксировать свою ошибку на какое-то время, и я действительно не добился прогресса. Я попадаю в тупик вскоре после того, как все...
1062 просмотров