Threads Kommunikation zwischen SocketThread und WorkerThread

[Stroker89]

Hallo,

gegeben sind mehrere SocketThreads (Multiuser), die jeweils einen WorkerThread starten. Kommuniziert wird über zwei LinkedBlockingQueues.

Ablauf: SocketThread bekommt Daten -> Daten werden weitergereicht an Worker über Queue -> Worker verarbeitet die Daten schickt das Ergebnis über den anderen Queue zum SocketThread zurück.

Jetzt kommt das Problem:
Da der read auf dem Socket immer blockierend ist, kann ich natürlich den Queue nur dann lesen, wenn der Client neue Daten schickt, was niemals passiert, wenn der Queue nicht gelesen werden kann und der Client keine Antwort bekommt.

Hoffe meine Erklärung ist soweit verständlich.

Wie kann ich dieses Problem umgehen? Gibt es sowas wie eine Best Practise für dieses Problem?

Gruß

 

[Michael...]

Hoffe meine Erklärung ist soweit verständlich.

Ich hab's nicht verstanden. Mir sind die Zusammenhänge zwischen dem Lese-Thread vom InputStream des Sockets und dem WorkerThread nicht ganz klar. Wie hängt das Lesen von der Queue mit dem Lesen vom InputStream zusammen? Warum soll im Lese-Thread (der ja ausschließlich für Empfang und ggf. Weitergabe von Daten des InputStreams) auch noch von der Queue gelesen werden?

 

[Stroker89]

Weil das Ergebnis vom WorkerThread ja irgendwie wieder zu dem SocketThread zurück muss...

 

[Michael...]

Weil das Ergebnis vom WorkerThread ja irgendwie wieder zu dem SocketThread zurück muss...

Warum muss? Der SocketThread sollte ausschließlich vom InputStream lesen - dafür wird er ja extra angelegt.

 

[Stroker89]

Er ließt und schreibt auf dem Socket.

 

[dayaftereh]

Der SocketThread Liest vom Socket und gibt die Daten an den WorkerThread und der verarbeitet diese Daten und gibt sie dann wieder an den SocketThread zurück , um auf den Socket geschrieben zu werden.

Warum schreibst du nicht die Daten direkt aus dem WorkerThread auf den Sockel?

 

[Stroker89]

Habe ich mir auch schon überlegt, aber das erschien mir als nicht ganz logisch. SocketThread ist für Socket zuständig und Worker für den Rest.

"Darf" man das denn so machen?

Gruß

 

[Michael...]

Er ließt und schreibt auf dem Socket.

Kann mich nur wiederholen. Ein SocketThread (um sicher zu gehen, dass wir über das selbe reden: Das ist der Thread, der die Daten eines bestimmten Clients empfängt/liest) sollte ausschließlich lesen. Die Antwort erfolgt ausserhalb dieses Threads. z.b direkt aus dem WorkerThread heraus.

 

[Michael...]

"Darf" man das denn so machen?

Warum nicht? Ansonsten ist ja der ganze SocketThread nutztlos bzw. nicht verwendbar, wie Du ja selbst festgestellt hast.

 

[Stroker89]

Ok vielen vielen Dank für die Aufklärung

Ja wir haben über das selbe gesprochen

 

[dayaftereh]

Ich glaube mina von Apache und netty geben auch nicht die zu schreibenden Daten an den Boss-Thread zurück.

 

[TKausL]

Wenn sie mit nio arbeiten sollten sie das aber...