8
ответов
Java Threads on wait () теряет блокировку, но остается внутри синхронизированного блока [duplicate]
Я жестко звонил wait (), тогда поток теряет блокировку и должен ее восстановить? Это правда? Но, очевидно, поток не покидает синхронизированный блок. Он ждет в той же строке, где wait () ...
вопрос задан: 24 June 2009 13:50
6
ответов
Является этот производитель-потребитель Python незапертым ориентированным на многопотоковое исполнение подходом?
Я недавно записал программу, которая использовала простой шаблон производителя/потребителя. Этому первоначально связали ошибку с неправильным использованием поточной обработки. Блокировка, которую я в конечном счете зафиксировал. Но это заставило меня дум
вопрос задан: 12 May 2009 21:15
6
ответов
Как реализовать чтение блокирования с помощью потоков POSIX
Я хотел бы реализовать сценарий производителя/потребителя, который повинуется интерфейсам, которые являются примерно: класс Потребитель {частный: векторное <символьное> чтение (size_t n) {//, Если внутренний буфер имеет '...
вопрос задан: 16 October 2008 00:40
5
ответов
Шаблон Производителя/Потребителя C#
У меня есть простой код one-producer/two-consumers следующим образом, но вывод показывает, что только C2 использует. Есть ли в моем коде какие-либо ошибки? класс Программа {статическая Основная пустота (строка [] args) {...
вопрос задан: 6 September 2017 12:38
4
ответа
за подтверждение сообщения в Kafka / RabbitMQ
У нас есть рабочий кролик. Реализация, из-за объема, мы планируем перейти на кафку. У меня есть сомнения в одном месте. В rabbitMQ, когда потребитель потребляет сообщение от Q, сообщение ...
вопрос задан: 2 March 2019 23:24
4
ответа
Производитель/потребитель C#
я недавно столкнулся с шаблоном производителя/потребителя c# реализация. это очень просто и (для меня, по крайней мере) очень изящный. это, кажется, было создано приблизительно в 2006, таким образом, я задавался вопросом если это...
вопрос задан: 24 February 2011 13:42
3
ответа
Производитель/Потребитель распараллеливает использование Очереди
Я хотел бы создать своего рода Производителя/Потребителя, распараллеливающего приложение. Но я не уверен что лучший способ реализовать очередь между двумя. Таким образом, у меня есть некоторые с двумя идеями (оба из которых могли быть...
вопрос задан: 17 September 2017 20:20
3
ответа
Универсальный.Net Producer/Consumer
Я играю с идеей реализовать универсальную пару Производителя/Потребителя + обрабатывающая очередь в C# для забавы. Идея - Вы, может просто создать объекты, которые реализуют соответствующий IProducer и IConsumer...
вопрос задан: 7 July 2009 03:40
2
ответа
C++: синхронизируйте 5 потребителей с 1 (многопоточным) производителем
У меня есть пять потребителей и один производитель. Эти пять потребителей каждый вывод различные данные, от одного производителя, для ~10ms. Во время тех 10 мс производитель готовит параметры к следующему выводу...
вопрос задан: 4 June 2010 16:37
2
ответа
Используя pthread условную переменную с rwlock
Я ищу способ использовать pthread rwlock структура со стандартными программами условий в C++. У меня есть два вопроса: Во-первых: Как возможно и если мы не можем, почему? Во-вторых: Почему текущий POSIX pthread имеет...
вопрос задан: 23 April 2010 15:53
2
ответа
очереди заданий производителя/потребителя
Я борюсь с лучшим способом реализовать мой конвейер обработки. Мои производители подают работу к BlockingQueue. На потребительской стороне я опрашиваю очередь, обертываю то, что я вхожу в Выполнимую задачу и отправляю...
вопрос задан: 10 February 2010 00:27
2
ответа
Буферизированный фон реализации InputStream
Я записал фону InputStream (и OutputStream) реализации, которые переносят другие потоки и читают вперед на фоновом потоке, прежде всего, позволяя, чтобы распаковка/сжатие произошла в...
вопрос задан: 2 February 2010 10:33
2
ответа
Python - простые строки чтения от канала
Я пытаюсь считать строки из канала и обработать их, но я делаю что-то глупое, и я не могу выяснить что. Производитель собирается продолжать продолжать линии неограниченно долго, как это: producer.py...
вопрос задан: 8 June 2009 14:38
2
ответа
Java поток ждать и уведомлять
У меня есть две темы. Поток A вытягивает некоторые элементы из очереди, а поток B добавляет некоторые элементы в очередь. Я хочу, чтобы поток A перешел в спящий режим, когда очередь пуста. Когда поток B добавляет немного ...
вопрос задан: 5 May 2009 18:40
1
ответ
Как потребитель кафки одной и той же группы делится сообщениями между ними?
Скажем, есть группа потребителей. (Потребители с одинаковым идентификатором группы). Потребительская группа потребляет Тему А от Брокера. Тема А имеет 4 раздела, и в этой группе 4 потребителя. Каждый ...
вопрос задан: 22 March 2019 05:09
1
ответ
Сохраняет ли RabbitMQ открытую связь для потребителя?
Я пытаюсь реализовать решение RabbitMQ в среде, где все соединения должны быть запущены из безопасной зоны в менее безопасную зону. Стандартная реализация RabbitMQ предусматривает ...
вопрос задан: 8 February 2019 16:27
1
ответ
RabbitMQ C # API Потребление сообщений на основе событий
while (true)
{BasicDeliverEventArgs e = (BasicDeliverEventArgs) Consumer.Queue.Dequeue (); IBasicProperties properties = e.BasicProperties; byte [] body = e.Body; Console.WriteLine ("...
вопрос задан: 19 December 2012 10:28
0
ответов
Несколько производителей, один потребитель
Мне нужно разработать многопоточное приложение, в котором будет несколько потоков, каждый поток создает настраиваемый журнал событий, который необходимо сохранять в очереди (не Microsoft MSMQ). Будет еще один ...
вопрос задан: 19 September 2019 02:54
0
ответов
Предоставление приоритета производителя над потребителем в общей очереди
Если основной поток записывается в очередь, а рабочий поток задан с его обработкой, то как создать код так, чтобы основной поток получал приоритет, когда дело доходило до записи в очередь, а не ...
вопрос задан: 13 July 2018 22:29
0
ответов
Реализация Шаблона Производителя/Потребителя в C#
Как я могу реализовать шаблоны Производителя/Потребителя в Событиях использования C# и Делегатах? За чем я должен внимательно наблюдать когда дело доходит до ресурсов при использовании этих шаблонов разработки? Есть ли любой...
вопрос задан: 6 June 2018 08:09
0
ответов
Использование именованного мьютекса для блокировки файла
Я использую именованный мьютекс для блокировки доступа к файлу (с путем 'strFilePath') в такой конструкции: private void DoSomethingsWithAFile(string strFilePath)
{ Mutex mutex = new Mutex(false,...
вопрос задан: 7 February 2018 11:43
0
ответов
Сообщения HornetQ все еще остаются в очереди после использования с использованием ядра api
Я новичок в HornetQ, так что, пожалуйста, несите меня. Позвольте мне сначала рассказать вам о своих требованиях: мне нужно промежуточное программное обеспечение для очереди сообщений, которое может передавать сообщения размером около 1 КБ между различны
вопрос задан: 7 December 2017 15:51
0
ответов
Как перебрать элементы Queue.Queue в Python?
Кто-нибудь знает питонный способ итерации по элементам Queue.Queue, не удаляя их из очереди. У меня есть программа типа производителя / потребителя, где элементы, которые будут обработаны, передаются ...
вопрос задан: 7 December 2017 15:25
0
ответов
Producer work consistently hashing to consumers via a message queue?
I have a producer that I want to distribute work consistently across consumers by consistent hashing. For example, with consumer nodes X and Y, tasks A, B, C should always go to consumer X, and D, E, ...
вопрос задан: 23 May 2017 12:30
0
ответов
Целесообразно ли добавлять задачи в BlockingQueue для ThreadPoolExecutor?
В JavaDoc для ThreadPoolExecutor неясно, допустимо ли добавлять задачи непосредственно в BlockingQueue, поддерживающую исполнителя. В документации говорится, что вызов executeor.getQueue () «предназначен ...
вопрос задан: 23 May 2017 12:22
0
ответов
Вызов Dispose для BlockingCollection
Я повторно использовал пример очереди потребителей-производителей из C # в Краткой книге Альбахари (http://www.albahari.com/threading/part5.aspx#_BlockingCollectionT ) и коллега заметил:
«Почему не ...
вопрос задан: 23 May 2017 12:08
0
ответов
Модель производитель-потребитель - двоичный семафор или мьютекс?
В основном это касается понимания концепции, что меня смущает. Мьютекс означает, что один поток берет на себя управление доступом к общему ресурсу, выполняет операции и разблокирует его, затем ...
вопрос задан: 23 May 2017 12:00
0
ответов
Java: высокоэффективная передача сообщений (single-producer/single-consumer)
Я первоначально задал этот вопрос здесь, но я понял, что мой вопрос не о в то время как - истинный цикл. То, что я хочу знать, что является надлежащим способом сделать высокоэффективное асинхронное сообщение-...
вопрос задан: 23 May 2017 11:53
0
ответов
Очередь заданий в виде таблицы SQL с несколькими потребителями (PostgreSQL)
У меня типичная проблема производитель-потребитель: несколько приложений-производителей записывают запросы заданий в таблицу заданий в базе данных PostgreSQL. В запросах заданий есть поле состояния, которое начинается с QUEUED ...
вопрос задан: 23 May 2017 11:47
0
ответов
Как происходит перебалансирование потребителей в Кафке?
Когда новый потребитель / посредник добавляется или выходит из строя, Kafka запускает операцию восстановления баланса. Является ли Кафка ребалансировкой операции блокировки? Блокируются ли потребители Kafka, когда происходит операция по восстановлению бал
вопрос задан: 17 July 2015 18:01