producer-consumer

6Ciepło

4Odpowiedz

wykonania Java Konsumenta Producer rzuca java.lang.IllegalMonitorStateException

import java.util.LinkedList; import java.util.Queue; class Producer extends PubSub implements Runnable{ @Override public void run() { synchronized(queue){ if (queue.size() =

java multithreading exception-handling producer-consumer 2016-04-26

---

5Ciepło

6Odpowiedz

Kafka węzeł, konsument dostaje zawsze stare wiadomości

im pomocą modułu Kafki węzeł https://github.com/SOHU-Co/kafka-node i za każdym razem, kiedy ponownie uruchomić konsumenta dostali wszystkie stare wiadomości, IM za pomocą okrągłego systemu Robin (load

node.js producer-consumer apache-kafka 2014-11-04

---

13Ciepło

2Odpowiedz

Błąd: Nie można znaleźć lub załadować głównej klasy config.zookeeper.properties

Próbuję wykonać przykładową aplikację konsumenta producenta przy użyciu Apache Kafka. Pobrałem go z https://www.apache.org/dyn/closer.cgi?path=/kafka/0.10.0.0/kafka-0.10.0.0-src.tgz. Następnie zacząłe

apache-kafka producer-consumer 2016-06-30

---

5Ciepło

1Odpowiedz

Producent Java-konsument z warunkiem zatrzymania

Mam N pracowników, którzy dzielą kolejkę elementów do obliczenia. W każdej iteracji każdy pracownik usuwa element z kolejki i może wytworzyć więcej elementów do obliczenia, które zostaną umieszczone w

java concurrency producer-consumer 2013-05-16

---

7Ciepło

1Odpowiedz

Wiosenna integracja - Współbieżne aktywatory usług

Mam kanał kolejki i aktywator usług z pollerem, który czyta z tej kolejki. Chciałbym, aby konfiguracja mówiła "Chcę, aby 50 wątków sondowało tę kolejkę, a za każdym razem, gdy odpytujesz i otrzymasz w

spring asynchronous concurrency producer-consumer spring-integration 2012-07-24

---

5Ciepło

4Odpowiedz

Implementowanie kolejki blokowania w JavaME: jak ją zoptymalizować?

Próbuję zaimplementować prostą blokującą kolejkę w Java ME. W JavaME API narzędzia współbieżności Java SE są niedostępne, więc muszę używać wait-notify jak w dawnych czasach. To jest moja wstępna real

java java-me concurrency producer-consumer 2012-04-26

---

10Ciepło

1Odpowiedz

Czy to jest zadanie dla TPL Dataflow?

Prowadzę dość typowy model producenta/konsumenta przy różnych zadaniach. Zadanie 1: Odczytuje partie bajtu [] z plików binarnych i uruchamia nowe zadanie dla każdej kolekcji tablic bajtowych. (operacj

c# concurrency task-parallel-library producer-consumer tpl-dataflow 2012-06-15

---

20Ciepło

1Odpowiedz

Jak działa rebalancing konsumenta w Kafce?

Po dodaniu lub opuszczeniu nowego konsumenta/brokera, Kafka uruchamia operację równoważenia. Czy Kafka Rebalancing jest operacją blokującą. Czy konsumenci Kafki są zablokowani podczas operacji równowa

message-queue producer-consumer apache-kafka kafka-consumer-api 2014-11-28

---

5Ciepło

2Odpowiedz

Problem z wieloma wątkami dla wielu producentów

Mam program, w którym próbuję wdrożyć ustawienia wielu producentów i wielu klientów. Mam kod, który wydaje się działać dobrze, gdy mam jednego konsumenta i wielu producentów, ale wprowadzenie wielu wą

c synchronization pthreads producer-consumer 2013-04-19

---

6Ciepło

3Odpowiedz

C# Oczekiwanie na wiele zdarzeń w Producer/Consumer

Wdrażam warstwę łącza danych przy użyciu producer/consumer pattern. Warstwa łącza danych ma własny wątek i automat stanowy do przesyłania protokołu łącza danych przez przewód (Ethernet, RS-232 ...). I

c# asynchronous producer-consumer 2016-03-02

---