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

Уведомление потребителя, когда производитель готов
Я читаю много данных из ldap, которые нужно сравнить с соответствующими записями в базе данных. Чтобы свести к минимуму количество запросов SQL, я хочу объединить несколько записей ldap в один запрос. Все это довольно просто: поток для получения...
498 просмотров
schedule 20.12.2022

Как сигнализировать NSStreamEventEndEncountered при чтении NSInputStream из NSMutableData
В Cocoa я настроил два NSThreads, одного производителя и одного потребителя. Производитель добавляет данные в NSMutableData, а получатель открывает NSInputStream из этих данных и считывает их порциями. Поток-производитель пишет намного быстрее,...
1473 просмотров

Синхронизированный производитель и потребитель с круговым буфером
У меня есть производитель и потребитель. Производитель записывает элементы фиксированного размера в заданную область общей памяти, а потребитель извлекает их. Производитель может быть заметно медленнее или быстрее потребителя случайным образом....
3582 просмотров
schedule 05.02.2023

Использование переменной условия pthread с rwlock
Я ищу способ использовать структуру pthread rwlock с подпрограммами conditions в C++. У меня есть два вопроса: Первый: как это возможно, а если нельзя, то почему? Во-вторых: почему текущий поток POSIX не реализовал это поведение? Чтобы...
7018 просмотров
schedule 27.05.2022

Производитель/потребитель в Grails?
Я пытаюсь реализовать приложение Consumer/Producer в Grails после нескольких безуспешных попыток реализации параллельных потоков. По сути, я хочу хранить все события, поступающие от клиентов (через отдельные вызовы AJAX) в одной очереди , а затем...
631 просмотров

что не так с моей схемой очереди производитель-потребитель?
Я начну с примера кода C# здесь . Я пытаюсь адаптировать его по нескольким причинам: 1) в моем сценарии все задачи будут помещены в очередь заранее, прежде чем запустятся потребители, и 2) я хотел абстрагировать работника в отдельный класс вместо...
996 просмотров

C++: синхронизировать 5 потребителей с 1 производителем (многопоточный)
У меня пять потребителей и один производитель. Каждый из пяти потребителей выводит разные данные от одного производителя в течение ~ 10 мс. В течение этих 10 мс производитель подготавливает параметры для следующего вывода. Когда параметры вывода...
859 просмотров

Эффективный потребительский поток с несколькими производителями
Я пытаюсь сделать ситуацию с потоком производителя/потребителя более эффективной, пропуская при необходимости дорогостоящие операции с событиями, например: //cas(variable, compare, set) is atomic compare and swap //queue is already lock free...
833 просмотров

очень уникальное исключение для BlockingCollection на .net 4.0
я использую BlockingCollection для шаблона Producer Consumer, и у меня есть исключение, я думаю написать на него патент - только два результата в google! ожидается, что «CompleteAdding не может использоваться одновременно с добавлениями в...
1473 просмотров
schedule 03.05.2023

производитель-потребитель с использованием синхронизации
Я написал код для реализации проблемы «производитель-потребитель», и, похоже, он работает нормально без необходимости синхронизации. Возможно ли это? Как протестировать код и проверить, работает ли он на самом деле правильно или нет? Как узнать,...
2436 просмотров
schedule 27.01.2024

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

java Производитель-Потребитель Не всегда завершается
У меня есть система, которая считывает имена из списка, вызывает внешний сервер для проверки истинного/ложного статуса и выполняет действия с истинным статусом. вызов внешнего сервера занимает некоторое время, поэтому запуск всего в одном потоке не...
714 просмотров
schedule 28.06.2023

проблема производитель-потребитель с pthreads
Я пытаюсь решить проблему производитель-потребитель, используя pthreads и семафоры, но похоже, что потоки-производители не производят, а потоки-потребители не потребляют. Похоже, что потоки создаются: /* Do actual work from this point forward...
23633 просмотров

Как разработать приложение, похожее на производителя-потребителя в java?
Мне нужно разработать приложение, похожее на проблему производителя-потребителя в java. Однако я мало что знаю о java, и у меня есть пара вопросов. И производитель, и потребитель, которые являются разными потоками, и им обоим нужен доступ к...
872 просмотров

Решение Apple doc GCD "производитель-потребитель" неверно?
В разделе «Переход от потоков» Руководства Apple по программированию с параллелизмом есть Changing Producer-Consumer Implementations , в котором утверждается, что типичная реализация многоступенчатого мьютекса pthread + условная переменная может...
4926 просмотров

Причина состояния гонки в стеке производителя/потребителя
Я попытался создать стек производитель-потребитель на основе событий уведомлений, который позволил бы одному потоку передавать данные, а другому потоку извлекать данные. Когда буфер заполнен/пуст, один поток ждет другого, пока не сможет продолжить...
535 просмотров

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

Очередь блокировки и многопоточный потребитель, как узнать, когда остановиться
У меня есть однопоточный производитель, который создает некоторые объекты задач, которые затем добавляются в ArrayBlockingQueue (который имеет фиксированный размер). Я также запускаю многопоточного потребителя. Он построен как фиксированный пул...
59456 просмотров

Многопоточность типа производителя/потребителя в python
Типичная проблема производителя-потребителя решается в python, как показано ниже: from queue import Queue job_queue = Queue(maxsize=10) def manager(): while i_have_some_job_do: job = get_data_from_somewhere()...
1075 просмотров

Java LinkedBlockingQueue с возможностью сигнализировать о завершении?
У меня есть ситуация, когда один производитель и один потребитель работают с очередью объектов. Есть две ситуации, когда очередь может быть пустой: Потребитель обрабатывал объекты быстрее, чем производитель мог создавать новые объекты...
1680 просмотров
schedule 27.01.2023