Wie benutze ich eine Warteschlange mit zwei Threads - eine für Consumer und eine für Producer

Question

Ich benutze eine Anwendung, bei der eine Anwendung der unteren Ebene immer einen Callback RecData (char * buf) aufruft, wenn sie Daten empfängt.

Im Callback erstelle ich zwei Threads und übergebe die Consumer- und Producer-Funktion an diese erzeugten Threads.

Mein Code:

Leere RecData (char * buf) {

CreateThread(NULL,0,producer_queue,(void *)buf,0,NULL); 
CreateThread(NULL,0,consumer_queue,NULL,0,NULL); 

}

Die oben genannten Arbeiten, wenn ich ein Datum zu einem Zeitpunkt erhalten. Wenn ich ungefähr 5 Daten fast gleichzeitig bekomme, dann sollte producer_queue zuerst alle Daten in die Warteschlange stellen und dann consumer_queue sollte mit dem Abrufen der Daten beginnen, aber hier, sobald producer_queue die ersten Daten in die Warteschlange legt, ruft consumer_queue sie ab.

Answer 1

Was Sie tun möchten, glaube ich, ist die Kontrolle Zugriff auf die Warteschlange. Sie sollten einen Mutex verwenden, um das Lesen aus der Warteschlange zu steuern.

Wenn Sie Daten empfangen, werden Sie den Mutex sperren und dann die Daten in die Warteschlange stellen. Wenn Sie mit dem Einreihen der Daten fertig sind, geben Sie die Sperre frei.

Beim Lesen aus der Warteschlange sehen Sie, ob der Mutex gesperrt ist. Wenn Sie Daten in die Warteschlange schreiben, können Sie nicht mit dem Lesen beginnen, bis Ihr Produzententhread alle Daten geschrieben und die Sperre aufgehoben hat. Wenn Sie den Mutex tatsächlich sperren, verhindern Sie, dass der Writer-Thread schreibt, während Sie Daten lesen.

Dieser Ansatz könnte potenzielle Deadlocks einführen. Wenn Ihr Writer-Thread vor dem Aufheben der Sperre abstirbt, kann Ihr Reader-Thread nicht fortfahren (dann kann Ihr Threading-Thread erneut einen Fehlerstatus auslösen).

Ich hoffe, das macht Sinn.

Answer 2

Verwenden Sie das Konzept der Bedingungsvariablen. Das Problem, das Sie haben, ist das häufigste in der Multi-Thread Programmierwelt. Die Verwendung von Mutexen hilft der Situation nicht. Denken Sie immer daran, dass Mutexe zum Sperren sind & Zustandsvariablen sind zum Warten. Letzteres ist immer sicherer und fast sicher, wenn ein Thread beginnen sollte, aus einer gemeinsamen Warteschlange zu konsumieren.

Schauen Sie sich den folgenden Link auf, wie Sie eine Zustandsgröße auf eigene Faust auf Windows erstellen können: http://www.cs.wustl.edu/~schmidt/win32-cv-1.html

Wenn Sie Windows Vista verwenden, können die folgenden Msdn Beispiel helfen Ihnen: http://msdn.microsoft.com/en-us/library/ms686903(VS.85).aspx

In allen Fällen verwenden Sie die Logik, wie sie auf der Website von Schmidt angezeigt wird, da sie tragbarer aussieht (oh ja auf verschiedene Versionen von Windows atleast übertragbar). Die Implementierung von Schmidt bietet Ihnen das Standard-POSIX-API, das auf den meisten modernen UNIX/LINUX-Systemen weit verbreitet ist.