Threads anhand eines Tokens abarbeiten

[akkie]

Hallo,

Ich habe ein MessageBean welches Nachrichten von einem Chat-Client erhält. Bis jetzt verarbeite ich die Nachrichten asynchron. Ich möchte das Verhalten aber ändern. Es sollen immer jeweils die Nachrichten zu einer SenderId(token) asynchron und alle anderen synchron verarbeitet werden.

Sagen wir mal wir haben 3 User. Von User 1 kommen zehn Nachrichten, von User 2 kommen fünf Nachrichten und von User 3 kommt eine Nachricht an. So sollen die Nachrichten von User 1 alle hintereinander(synchronized) verarbeitet werden. Parallel dazu sollen von User 2 alle hintereinander(synchronized) verarbeitet werden. Und die Nachricht von User 3 soll genauso parallel abgearbeitet werden.

Lässt sich das irgendwie bewerkstelligen?

Bis jetzt sieht das ganze so aus:

synchronized(queue) {
	queue.offer((TextMessage) msg);
	TextMessage txtMsg = queue.poll();
	MessageService msgService = new MessageService();
	msgService.handleMessage(
		this.getType(txtMsg), 
		this.getSenderId(txtMsg), 
		this.getRecipientId(txtMsg), 
		this.getText(txtMsg),
		this.getForward(txtMsg)
	);
}

Mfg Akkie

 

[SlaterB]

es ist nicht so richtig klar, wohin das hinführt,

synchronized, in Java für den sicheren Umgang bei Nebenläufigkeit, hat nicht unbedingt was mit synchron/ asynchron zu tun

synchron ist ein normaler Methodenaufruf: der Aufrufer muss warten, bis dieser fertig bearbeitet ist,
und sei es, dass die aufgerufene Methoden eine sleep-Schleife enthält, bis irgend anderer Thread irgendwas fertig bearbeitet hat

asynron bedeutet z.B., das die Arbeit in einer Queue kommt und der Aufrufer gleich wieder weitermachen kann,
aus freien Stücken vielleicht selber alle x Sekunden nachschaut, ob der Auftrag erledigt ist, bzw. besser noch die Gegenseite meldet sich, wenn sie fertig ist,

all das kann gerne programmieren, besteht dazu eine Frage?

 

[akkie]

Hi

Mein Problem hier ist ja das ich eine Mischung aus beiden Varianten will. Ein Teil soll synchron und eine teil soll asynchron abgearbeitet werden.

Mein vorgehen wäre eine Queue zu erstellen in die ich anhand eines Tokens, Nachrichten speichere. Wenn eine neue Nachricht ankommt würde ich die Queue fragen ob den schon eine Nachricht mit dem selben Token gespeichert ist. Wenn ja muss gewartet werden bis die Queue frei ist. Wenn kein eintrag existiert kann die Message gleich abgearbeitet werden. Den Zugriff auf die Queue muss ich ja aber Threadsicher programmieren. Wenn ich hier jetzt einen synchronized Block darum lege kann ja jeder Thread nur nacheinander abgearbeitet werden. Und das möchte ich ja vermeiden.

Oder sehe ich das Falsch???:L

Mfg Akkie

 

[SlaterB]

synchronized ist nur für den Zugriff nötig, der in paar ms abgearbeitet werden kann,
falls eine Methode dann länger wartet, bis was frei ist, muss das nicht die ganze Zeit im synchronized-Block sein,

wenn man Thread.sleep() verwendet, dann eben außerhalb eines derartigen Blocks schlafen,

mit wait/ notify geht es noch komfortabler ohne Wechsel

 

[faetzminator]

Du kannst [c]Map<Token, Queue<TextMessage>>[/c] o.ä. machen und für jedes Token eine eigene Queue verwenden.

 

[akkie]

Du kannst [c]Map<Token, Queue<TextMessage>>[/c] o.ä. machen und für jedes Token eine eigene Queue verwenden.

Die Idee hatte ich gestern auch schon mal, habe es aber nicht hinbekommen.

Das ganze sah in etwa so aus.

synchronized(map.get(token)) {
    Queue queue = map.get(token);
    queue.offer((TextMessage) msg);
    TextMessage txtMsg = queue.poll();
    MessageService msgService = new MessageService();
    msgService.handleMessage(
        this.getType(txtMsg), 
        this.getSenderId(txtMsg), 
        this.getRecipientId(txtMsg), 
        this.getText(txtMsg),
        this.getForward(txtMsg)
    );
}

Mfg Akkie

 

[faetzminator]

Was war/ist denn das Problem?

 

[akkie]

Was war/ist denn das Problem?

Ich habe das ganze jetzt noch mal ausprobiert und hinbekommen. Jetzt funktioniert es wie gewollt.

Noch mal vielen dank für eure Hilfe.

Mfg Akkie