blockingqueue

0Hitze

1Antwort

SynchronousQueue in ThreadPoolExecutor

Ich versuche, das Verhalten von Warteschlangen in ThreadPoolExecutor zu verstehen. Im folgenden Programm, wenn ich LinkedBlockingQueue verwende, kann ich nur eine Aufgabe gleichzeitig an den Thread-Po

java concurrency threadpool threadpoolexecutor blockingqueue 2017-12-05

---

3Hitze

1Antwort

Warum kann der Race-Zustand in LogWriter dazu führen, dass der Produzent blockt? [Nebenläufigkeit in der Praxis]

Erstens, um Mark Frage als Duplikat von Jungs zu verhindern, die nicht lesen wollen bis zum Ende Ich habe Producer-Consumer Logging service with Unreliable way to shutdown Frage gelesen. Aber es ist n

java multithreading concurrency shutdown blockingqueue 2017-02-21

---

1Hitze

1Antwort

Java - Single-Thread-Executor

Ich habe blockierende Warteschlange mit mehreren Produzenten und einzelnen Verbraucher (was genug für die Nachbearbeitung von Artikeln). Hersteller startet nach Zeitplan, die Aufgaben an Executor Pool

java spring multithreading architecture blockingqueue 2017-10-31

---

0Hitze

1Antwort

Producer Verbraucherszenario, Lesen aus der Warteschlange anhalten, bis die Ausführung abgeschlossen ist

Ich implementiere ein Producer Consumer-Szenario mit einer BlockingQueue. Das ist mein Verbraucher Methode ausgeführt: @Override public void run() { try { Message msg; System.

java queue producer-consumer blockingqueue 2017-04-19

---

2Hitze

1Antwort

Gibt es eine Methode, um Ros :: spinOnce() eine bestimmte Anzahl von Callbacks aus der Callback-Queue aufrufen zu lassen?

Ich schreibe ein Programm in ROS, das nach jeder Callback-Funktion bestimmte Berechnungen ausführen sollte. Meine Callback-Funktion abonniert grundsätzlich ein Thema und legt den Wert einer Variablen

callback ros blockingqueue 2017-01-12

---

0Hitze

1Antwort

Dequeue aus Queue mit dem Ausdruck

ich eine blockierende Warteschlange Klasse basierend auf Marc Gravell'sBlocking Queue Jetzt habe ich Situationen, in denen ich nur ein bestimmtes Objekt aus der Warteschlange entfernt will, ich weiß,

c# queue mutex blockingqueue 2017-11-08

---

0Hitze

2Antwort

Python mit queue.get Blockierung() ohne Ausnahmen oder besetzt warten

ich die folgenden Threads haben, denn wo die Warteschlange q ist leer die meiste Zeit: def run(self): while True: if not self.exit_flag: items = self.q.get() q.work_it()

python python-2.7 exception blockingqueue busy-waiting 2017-06-16

---

1Hitze

2Antwort

So verwalten Sie Threads im Frühjahr TaskExecutor Framework

Ich habe eine BlockingQueue von Runnable - Ich kann einfach alle Aufgaben mit einer der TaskExecutor Implementierungen ausführen, und alle werden parallel ausgeführt werden. aber einige Runnable hängt

java spring multithreading blockingqueue 2017-03-10

---

0Hitze

1Antwort

Was ist die Verwendung von queueSizeRejectionThreshold in Hystrix, wenn ich bereits max.Queue.poolSize habe?

Warum brauchen wir queueSizeRejectionThreshold in Hystrix mit Ausnahme von maxQueueSize. Per Definition queueSizeRejectionThreshold <= maxQueueSize. Aber ich werde nicht warum nicht Thread ablehnen, w

hystrix blockingqueue 2017-05-17

---

1Hitze

1Antwort

DelayQueue unerwartetes Verhalten. DrainTo Löscht nur 1 abgelaufenes Objekt aus der Warteschlange

Ich möchte in meiner DelayQueue durch nicht abgelaufene Elemente iterieren. Die Klasse Transaktion implementiert Verzögerte und hat ein Feld Zeitstempel, der den Zeitstempel einer Transaktion darstell

java multithreading priority-queue java.util.concurrent blockingqueue 2017-07-11

---