Tag: producer-consumer

Habe ich es herausgefunden. Dumme Fehler meinerseits, war ich eigentlich nicht löschen das element aus der queue, ich war nur zu Lesen das erste element. Ich veränderte den code, und der code unten nicht funktioniert. Vielen Dank

Habe ich eine Liste von Arbeitsaufgaben, die bearbeitet werden müssen, um. Manchmal ist die Liste leer, manchmal gibt es tausend Artikel. Nur eine verarbeitet werden können in einer Zeit und in Ordnung. Momentan mache ich die folgenden,

In der JavaDoc für ThreadPoolExecutor ist unklar, ob es akzeptabel ist, fügen Sie die Aufgaben direkt auf die BlockingQueue sichern der Vollstrecker. Die docs sagen aufrufen executor.getQueue() "soll in Erster Linie für debugging und monitoring". Ich Baue

Ich habe zu entwickeln, um eine Multithread-Anwendung, wo gibt es mehrere threads, jeder thread erzeugt benutzerdefinierte Ereignisprotokoll, die gespeichert werden müssen in der Warteschlange (nicht Microsoft MSMQ). Es wird ein weiterer thread liest die log-Daten aus der

In Kafka, ich möchte nur eine einzige broker, einziges Thema und eine einzige partition mit einem Erzeuger und mehrere Verbraucher (jeder Verbraucher erhält seine eigene Kopie der Daten, die vom broker). Angesichts dieser, ich will nicht den

Ich bin Ringen um die beste Art der Umsetzung meiner Bearbeitung pipeline. Meine Produzenten feed Arbeit auf eine BlockingQueue. Auf der consumer-Seite, ich Umfrage der Warteschlange, wickeln, was ich in ein Runnable task, und senden Sie es

Die gesamte Umsetzung der die kritische Sektion mit semaphor ist, was ich versucht habe zu implementieren. Der gesamte code mit Semaphoren ist gezeigt: #include <stdio.h> #include <stdlib.h> #include <pthread.h> #include <semaphore.h> int buf[256]; int in = 0;

Ich versuche Mehrere Produzent - Mehrere Verbraucher bei Erzeuger-Verbraucher-problem. Ich bin mit BlockingQueue für die gemeinsame Warteschlange zwischen mehreren Erzeugern/Verbrauchern. Unten ist mein code. Produzent import java.util.concurrent.BlockingQueue; public class Producer implements Runnable { private BlockingQueue inputQueue; private

Dies ist eine klassische c/p-problem, wo einige threads erzeugen von Daten, während andere die Daten Lesen. Sowohl der Erzeuger und Verbraucher gemeinsam einen const Größe Puffer. Wenn der Puffer leer ist, dann haben die Verbraucher warten, und

Ich habe eine java-Klasse SomeClass implements Runnable Die eine Methode display(). Wenn ich ein thread von dieser Klasse Thread thread1 = new Thread(new SomeClass()); Nun, wie kann ich rufen Sie die display () - Methode unter Verwendung

Ich bin ganz neu bei multithreading-Programmierung, ich weiß nur, das die meisten gemeinsamen Producer-Consumer-Queue. Ich bin mit der boost c++ - Bibliotheken, und ich weiß nicht, ob besser ist die Verwendung von boost::lockfree::queue oder eine wrapper-Klasse um

Wie kann ich das implementieren der Producer/Consumer - Muster in C# mit Ereignisse und Delegaten? Was brauche ich, um ein Auge für zu halten, wenn es um die Ressourcen, wenn Sie diese design-patterns? Gibt es irgendwelche edge-cases

Kennt jemand eine pythonic way of Iteration über die Elemente einer Queue.Queue ohne entfernen Sie Sie aus der Warteschlange. Ich habe eine producer/consumer-Typ-Programm, wo Objekte verarbeitet werden können übergeben werden, indem eine Queue.Queueund ich möchte in der

Ich versuche zu Lesen von Zeilen aus einem Rohr und verarbeiten, aber ich Tue etwas albern und ich kann nicht herausfinden, was. Der Produzent weiter produzieren Linien auf unbestimmte Zeit, wie diese: producer.py import time while True:

Ich versuche zum ausführen einer sample-producer-consumer-Anwendung unter Verwendung von Apache Kafka. Ich habe es runtergeladen von https://www.apache.org/dyn/closer.cgi?path=/kafka/0.10.0.0/kafka-0.10.0.0-src.tgz . Dann begann ich, die folgenden Schritte in http://www.javaworld.com/article/3060078/big-data/big-data-messaging-with-kafka-part-1.html. Wenn ich versuchte zu laufen bin/zookeeper-server-start.sh config/Tierpfleger.Eigenschaften, ich bin immer Fehler:

Den TryDequeue in ConcurrentQueue false zurück, wenn keine Elemente in der Queue. Wenn die Warteschlange leer ist, ich brauche, dass meine queue warten, bis neue Element Hinzugefügt werden in die Warteschlange eingereiht und aus der Warteschlange entfernt,

Ich würde gerne eine Art Producer/Consumer threading-app. Aber ich bin mir nicht sicher, was der beste Weg für die Implementierung einer Warteschlange zwischen den beiden. So, ich habe noch zwei Ideen (beides könnte ganz falsch sein). Ich