Wie kann ich einen Produzenten und einen Verbraucher in beide Richtungen kommunizieren lassen?

Question

Ich möchte einen Worker-Thread warten auf einen Befehl, tun Sie es, und senden Sie das Ergebnis zurück an den Aufrufer. Dies unterscheidet sich von dem normalen Producer/Consumer-Problem wegen der Antwort zurück.

Das ist, was ich denke:

main 
{ 
construct workers 
push to shared input buffers 
notify workers 
wait 
print results from shared output buffer 
} 

worker 
{ 
wait 
read from shared input buffer 
do work 
notify main 
} 

Bin ich auf dem richtigen Weg? Gibt es eine Chance, dass der Arbeiter antworten kann, bevor der Main anfängt zu warten?

(Ich verwende C++, wenn diese relevant ist)

Answer 1

Sie auf dem richtigen Weg sind, aber man kann die Dinge ein wenig vereinfachen und die Notwendigkeit zu beseitigen, um zu signalisieren, oder für das Signal warten

main 
{ 
    push to shared input buffers 
    construct workers // create and immediately run. No need for signal 
    while more workers 
     join worker // will block until worker thread exits 
    print results from shared output buffer 
} 

worker 
{ 
    read from shared input buffer 
    do work 
} 

Je nachdem, wie Sie den freigegebenen Puffer partitionieren oder nicht partitionieren, müssen Sie ihn möglicherweise vor gleichzeitigem Schreiben schützen.