producer-consumer

0зной

1ответ

Одиночный производитель для нескольких потребителей (одна и та же группа потребителей)

Я попытался до отправки сообщения от одного производителя до 2-х разных потребителей с РАЗНОЕ группа потребителей. В результате оба потребителя могут прочитать полное сообщение (оба потребителя получа

python producer-consumer kafka-python 2016-09-21

---

0зной

1ответ

Что не так с кодом? Почему потоки не чередуются?

class Producer implements Runnable{ //producer job here Vector<Integer> sQueue; public Producer(Vector<Integer> queue) { this.sQueue=queue; } public void run(){ int i=0

java multithreading synchronization producer-consumer 2016-08-18

---

1зной

1ответ

BlockingCollection.IsComplete никогда не верно

В .NET BlockingCollection класс работает очень хорошо для меня, но по какой-то причине свойство IsCompleted всегда возвращает ложь ... даже тогда, когда BlockingCollection.Count является 0. while (!Wo

.net c#-4.0 producer-consumer blockingcollection 2016-09-03

---

1зной

2ответ

Блокировка коллекции с несколькими элементами?

Все C# реализаций для производителей-потребители коллекций [1] [2], кажется, имеют интерфейсы смутно похожие на: private Queue<T> items; public void Produce(T item) public T Consume() Любых реали

c# .net producer-consumer 2016-09-16

---

1зной

1ответ

Один продюсера несколько потребителей за один государственный объект

У меня есть один производитель, который: maintains ref StateRef to object StateObj implements method modify() method which modifies StateObj implements getRef() method which will be used by consumer

java java-8 locking synchronized producer-consumer 2016-08-07

---

0зной

1ответ

Как добиться высокоскоростной обработки с использованием концентратора событий Azure?

Я работаю над концентраторами POC для Azure, чтобы реализовать их в нашем приложении. Краткая информация о потоке. Созданный инструмент для считывания данных CSV из локальной папки и отправки его в ко

azure producer-consumer azure-eventhub 2016-08-08

---

0зной

1ответ

Trigger SheduledExecutor с blockingQueue Java

В настоящее время я работаю над java-приложением, которое имеет сценарий нескольких производителей, добавляющих задачи в очередь, и всякий раз, когда очередь не пустая, задачи должны выполняться с зар

java multithreading producer-consumer blockingqueue scheduledexecutorservice 2016-08-21

---

0зной

1ответ

Очередь блокировки массива с емкостью 1 неправильное поведение производителя-потребителя

Я сделал следующую проблему с производителем с блокировкой очереди с емкостью 1. Так что производитель может производить только один элемент, но запуск производителя кода может производить 2 элемента,

java multithreading concurrency producer-consumer blockingqueue 2016-08-29

---