0
ответов
Попробуйте Dequeue в ConcurrentQueue
TryDequeue в ConcurrentQueue вернет false, если в очереди нет элементов. Если очередь пуста, мне нужно, чтобы моя очередь ждала, пока новый элемент не будет добавлен в очередь, и исключит этот новый элемент из очереди, а ...
вопрос задан: 2 July 2014 19:44
0
ответов
Это задание для потока данных TPL?
Я использую довольно типичную модель производитель/потребитель для различных задач. Task1: считывает пакеты byte[] из двоичных файлов и запускает новую задачу для каждой коллекции байтовых массивов. (операция ...
вопрос задан: 2 January 2014 22:08
0
ответов
Блокирующая очередь и многопоточный потребитель, как узнать, когда остановиться
У меня есть однопоточный производитель, который создает некоторые объекты задач, которые затем добавляются в ArrayBlockingQueue (который имеет фиксированный размер). Я также запускаю многопоточный потребитель. Он собирается как ...
вопрос задан: 25 April 2013 19:07
0
ответов
Spring Integration -Параллельные активаторы служб
У меня есть канал очереди и активатор службы с опросчиком, который читает из этой очереди. Я бы хотел, чтобы конфигурация говорила: «Я хочу, чтобы 50 потоков опрашивали эту очередь, и каждый раз, когда вы опрашиваете и получаете...
вопрос задан: 24 July 2012 12:26
0
ответов
Очередь потребителей-производителей C ++ с (очень) быстрой и надежной передачей обслуживания
Привет, я ищу возможность переключения потоков с использованием быстрой и надежной очереди потребителей-производителей. Я работаю в Windows с VC ++. Я основывал свой дизайн на очереди Энтони Вильямса, то есть, в основном ...
вопрос задан: 5 July 2012 08:04
0
ответов
При межпотоковом взаимодействии между производителем и потребителем
возникли проблемы с межпотоковым взаимодействием, и он «решил» их с помощью повсеместных «фиктивных сообщений». Это плохая идея? Какие есть возможные решения? Пример проблемы у меня есть. основной поток ...
вопрос задан: 15 June 2012 17:40
0
ответов
производитель -потребление; как остановится потребитель?
Итак, я смоделировал свою проблему производителя-потребителя, и у меня есть код ниже. Мой вопрос заключается в следующем :как остановится потребитель, если он находится в постоянном состоянии while (true ). В приведенном ниже коде я добавил...
вопрос задан: 27 April 2012 14:47
0
ответов
Хорошо ли использовать BlockingCollection в качестве запроса FIFO для одного производителя и одного потребителя?
Мне нужен запрос FIFO с одним источником и одним потребителем, потому что мне нужно обрабатывать сообщения в том порядке, в котором они были получены.
Мне нужно сделать это асинхронно, потому что вызывающая сторона не должна ждать, пока я обрабатываю...
вопрос задан: 11 April 2012 10:03
0
ответов
Java: Производитель = Потребитель, как узнать, когда остановиться?
У меня есть несколько воркеров, использующих ArrayBlockingQueue. Каждый работник берет один объект из очереди, обрабатывает его, в результате может получить несколько объектов, которые будут поставлены в очередь для дальнейшей обработки. ...
вопрос задан: 3 April 2012 19:20
0
ответов
Многопоточность для ускорения работы приложения для отправки электронной почты
Я создал приложение для отправки почтовых программ для веб-сайта через Amazon SES. Оно написано на C #. Каждое электронное письмо отправляется через API Amazon SES за 0,3 секунды.
Это означает, что с помощью однопоточного ...
вопрос задан: 19 March 2012 13:49
0
ответов
Скорость передачи RabbitMQ увеличивается?
Я ищу идеи, как ускорить передачу сообщений через RabbitMQ. Я установил последнюю версию на 64-битную Windows, запустив сервер на моем локальном компьютере, на котором я также публикую и использую в / из ...
вопрос задан: 5 March 2012 16:03
0
ответов
Java LinkedBlockingQueue с способность сигнализировать о завершении?
У меня есть ситуация, когда один производитель и один потребитель работают с очередью объектов. Есть две ситуации, когда очередь может быть пустой: Потребитель обработал объекты быстрее, чем ...
вопрос задан: 3 March 2012 07:10
0
ответов
Java BlockingQueue с пакетной обработкой?
Меня интересует структура данных, идентичная Java BlockingQueue, за исключением того, что она должна иметь возможность пакетировать объекты в очереди. Другими словами, я хотел бы, чтобы производитель мог ...
вопрос задан: 27 February 2012 16:16
0
ответов
Элегантные способы уведомить потребителя, когда производитель закончил?
I ' m реализует concurrent_blocking_queue с минимальными функциями: // тонкая оболочка над std :: queue
шаблон <имя типа T>
класс concurrent_blocking_queue
{std :: queue ...
вопрос задан: 27 February 2012 12:40
0
ответов
Многопоточный доступ к одному и тому же текстовому файлу
У меня есть огромный текстовый файл с разделителями по строкам, и я хочу произвести некоторые вычисления для каждой строки. Мне нужно создать многопоточную программу для его обработки, потому что на обработку каждой строки уходит ...
вопрос задан: 26 February 2012 12:45
0
ответов
Производитель- Потребитель ждет, когда очередь пуста?
У меня есть список рабочих элементов, которые необходимо обработать по порядку. Иногда список будет пустым, иногда в нем будет тысяча элементов. Только один может быть обработан за раз и за один раз. порядок. В настоящее время я ...
вопрос задан: 31 December 2011 17:40
0
ответов
Производитель / потребитель поисковый робот, использующий очередь с неизвестным размером
Мне нужно сканировать родительские веб-страницы и их дочерние веб-страницы, и я следовал концепции производителя / потребителя из http://www.albahari.com/threading/part4.aspx#%5FWait% 5Fand% 5FPulse. Также я использовал 5 потоков ...
вопрос задан: 12 December 2011 15:40
0
ответов
Неправильно решение Apple doc GCD «Производитель-Потребитель»?
В разделе «Переход от потоков» Руководства Apple по программированию с параллелизмом есть
Изменение реализаций производитель-потребитель , в котором утверждается, что типичный многоступенчатый мьютекс pthread + ...
вопрос задан: 31 October 2011 07:16
0
ответов
Производитель-потребитель - Использование Executors.newFixedThreadPool
Насколько я понимаю, шаблон «производитель-потребитель» может быть реализован с использованием очереди, совместно используемой производителем и потребителем. Производитель отправляет работу в общую очередь, потребитель извлекает ...
вопрос задан: 11 August 2011 20:17
0
ответов
Соответствует ли модель производителя / потребителя Актеру?
Итак, в последнее время я читал много статей о том, насколько сложно параллельное программирование и насколько практически невозможно параллельное программирование с общим состоянием. Итак, такие языки, как Erlang (я думаю, что это ...
вопрос задан: 9 August 2011 19:10
0
ответов
проблема производитель-потребитель с pthreads
Я пытаюсь решить проблему производителя-потребителя, используя pthreads и семафоры, но похоже, что потоки-производители не производят, а потоки-потребители не используют. Похоже, что ...
вопрос задан: 19 May 2011 17:26
0
ответов
Алгоритм обработки потребительских потоков .NET двух очередей (на основе приоритета)
У меня есть приложение C # 4.0 с очередями с «высоким приоритетом» и «низким приоритетом», реализованными как таковые: BlockingCollection highPriority = новая коллекция BlockingCollection (1000);
BlockingCollection lowPriority = new ...
вопрос задан: 1 April 2011 16:56
0
ответов
«Использование семафоров явно неверно»
В прошлом семестре я проходил практику по ОС на языке C, в котором первый проект включал создание пакета потоков, а затем написание программы с несколькими производителями и потребителями для демонстрации функциональности. . ...
вопрос задан: 22 December 2010 23:49
0
ответов
C # производитель / потребитель / наблюдатель?
У меня есть очередь производитель / потребитель, за исключением того, что есть определенные типы объектов. Таким образом, не любой потребитель может потреблять добавленный объект. Я не хочу создавать отдельную очередь для каждого типа, так как там ...
вопрос задан: 16 December 2010 17:22
0
ответов
Очередь получателя-получателя не удаляется
Я создал очередь-получатель-получатель, обертывающую ConcurrentQueue в .net 4.0 с сигнализацией SlimManualResetEvent между производящим (Enqueue) и потребляющим (while (true) на основе ниток.
очередь ...
вопрос задан: 7 October 2010 21:35
0
ответов
Требуется ли синхронизация Monitor.Wait?
Я разработал общую очередь производителя-потребителя, которая генерируется Monitor в следующим образом: enqueue: public void EnqueueTask (T задача) {_workerQueue.Enqueue (задача); ...
вопрос задан: 26 September 2010 13:02
0
ответов
Вопрос интервью: найти медиану из мега числа целых чисел
Существует файл, который содержит 10G (1000000000) целых чисел, пожалуйста, найдите медиану этих целых чисел. вам дают 2G памяти, чтобы сделать это. Кто-нибудь может придумать разумный путь? спасибо!
вопрос задан: 26 August 2010 07:19