Kontroll-Pipeline mit atomaren Nachrichten

Content

Die erarbeitete Lösung ist nicht wirklich geeignet, wenn die einzelnen Worker prinzipiell unbeschränkt Resultate erzeugen können und diese vom Hauptprozess zügig abgeholt werden müssen, damit eifrige Worker nicht unerwünscht blockiert werden. Wie kann hier der Hauptprozess darauf warten, dass irgendeiner der Worker etwas abzuliefern hat und dann genau aus dessen Pipeline lesen?

Eine denkbare Lösung für dieses Problem wäre die Einrichtung einer zusätzlichen Kontroll-Pipeline:

Aufgabe

Passen Sie Ihre Lösung aus dem letzten Schritt an das neue Schema an: