Sellerieschlag: Beschränkt auf jeweils eine Task-Instanz

Ich habe Sellerie-Beat und Sellerie (vier Arbeiter), um einige Verarbeitungsschritte in loser Schüttung durchzuführen. Eine dieser Aufgaben ist in etwa wie folgt: "Für jedes X, für das kein Y erstellt wurde, muss ein Y erstellt werden." Die Task ...

Concurrent Sammlungen in C #

Ich suche nach einer Möglichkeit, eine gleichzeitige Auflistung in C # oder zumindest eine Auflistung zu erhalten, die einen gleichzeitigen Enumerator unterstützt. Im Moment erhalte ich eine InvalidOperationException, wenn sich die Sammlung, ...

Greenlet Vs. Themen

Wie vermeide ich die HashMap-Ausnahme "ConcurrentModificationException", während ich "values ()" und "put ()" in gleichzeitigen Threads bearbeite?

Code Ich habe eine HashMap private Map<K, V> map = new HashMap<>();Eine Methode fügt ein K-V-Paar hinzu, indem sie @ aufrufput(K,V). Die andere Methode möchte eine Reihe zufälliger Elemente aus ihren Werten extrahieren: int size = map.size(); ...

ConcurrentModificationException trotz Verwendung von synchronized

Parallelströme, Sammler und Fadensicherheit

Das folgende einfache Beispiel zählt die Anzahl der Vorkommen jedes Wortes in einer Liste: Stream<String> words = Stream.of("a", "b", "a", "c"); Map<String, Integer> wordsCount = words.collect(toMap(s -> s, s -> 1, (i, j) -> i + ...

Können Scala-Akteure mehrere Nachrichten gleichzeitig verarbeiten?

Sind LinkedBlockingQueue's Einfüge- und Entfernungsmethoden threadsicher?

Ich benutzeLinkedBlockingQueue zwischen zwei verschiedenen Threads. Ein Thread fügt Daten über @ hinadd, während der andere Thread Daten über @ empfäntake. Meine Frage ist, muss ich den Zugriff auf @ synchronisiereadd ...

Node.js / Express und parallele Warteschlangen

Wir bauen eine Infrastruktur mit einem Node.js-Server und Express auf. Auf dem Server geschieht Folgendes: Der Server akzeptiert eine eingehende HTTP-Anfrage vom Client.Server erzeugt zwei Dateien (dieser Vorgang kann "relativ lang" sein, was ...

Implementieren einer gleichzeitigen LinkedHashMap

Ich versuche, eine gleichzeitige LinkedHashMap für eine Multithread-Architektur zu erstellen. Wenn ich benutzeCollections#synchronizedMap(), Ich müsste synchronisierte Blöcke für die Iteration verwenden. Diese Implementierung würde zum ...