Frage zu Synchronized

Alex04

Bekanntes Mitglied
Hallo,
wir sind dabei einen Fifo Aspect Springseitig zu implementieren (MethodInvocation). Zu Testzwecken habe ich dies via Proxy nachgebildet. Um die Details geht es aber eigentlich garnicht, sondern eher um die richtige Verwendung des Lock Objekts mit den synchronized Blöcken.
Meine erste Lösung war folgende:

Java:
public class FifoServiceInvocationHandler implements InvocationHandler {

      private Object lock = new Object();
      private Object service;
      private Queue<Thread> queue = new LinkedList<Thread>();
      
      public FifoServiceInvocationHandler() {
            service = new MySimpleService();
      }
      
      @Override
      public Object invoke(Object proxy, Method method, Object[] args)
                  throws Throwable {
            System.out.println("Invoked by " + (String)args[0]);
            queue.add(Thread.currentThread());
            synchronized (lock) {
                  try {
                        while(queue.peek() != Thread.currentThread()) {
                             lock.wait();
                        }
                        return method.invoke(service, (String)args[0]);
                  } finally {
                        queue.remove();
                        lock.notifyAll();
                  }
            }
      }
}

Allerdings ist laut Dozent die Anordnung der synchronized Blöcke falsch + die queue.add(...) Methode sollte innerhalb eines synchronen Blocks aufgerufen werden. Die "gesamte FIFO-Funktionalität sei so kaputtgemacht"

Jetzt hätte ich noch folgende Lösung:

Java:
public class FifoServiceInvocationHandler implements InvocationHandler {

	private Object lock = new Object();
	private Object service;
	private Queue<Thread> queue = new LinkedList<Thread>();

	public FifoServiceInvocationHandler() {
		service = new MySimpleService();
	}

	@Override
	public Object invoke(Object proxy, Method method, Object[] args)
			throws Throwable {
		System.out.println("Invoked by " + Thread.currentThread().getId() + " command " + (String)args[0]);
		try {
			synchronized (lock) {
				queue.add(Thread.currentThread());
				while (queue.peek() != Thread.currentThread()) {
					lock.wait();
				}
			}
			return method.invoke(service, (String)args[0]);
		} finally {
			synchronized (lock) {
				queue.remove();
				lock.notifyAll();
			}
		}
	}
}

Ich sehe aber nicht wirklich warum das besser sein sollte bzw. was der Unterschied ist...
Außer der Tatsache, dass die Threads schon während der MethodInvocation gequeued werden können....???
Warum sollte queue.add(...) in den synchronized Block?
Und Warum ist bei Variante 1 die Fifo-Funktionalität kaputtgemacht? Laut meinen Tests werden die Threads in richtiger Reihenfolge abgearbeitet... :???

P.S.: Ich weiß nicht, ob Variante 2 richtig ist, wenn Fehler auffallen bitte korrigieren :)

Vielen Dank schon mal für die Hilfe!!!

LG
Alex
 
Zuletzt bearbeitet:

Ariol

Top Contributor
Wenn das Lock erst nach dem Add kommt wären folgende Szenarien möglich:


gewünscht:
Code:
T1 -> add(T1) -> waitForLock -> lock         -> wait -> remove(T1)
T2            -> add(T2)     -> waitForLock                        -> lock -> wait -> remove(T2)

gefährlich:
Code:
T1            -> add(T1) -> waitForLock -> lock        -> wait=Endlosscheife
T2 -> add(T2)                           -> waitForLock
 
S

SlaterB

Gast
@Alex04
warum verwendest du überhaupt synchronized, wie wäre es denn ganz ohne?
welche Ziele verfolgst du bei dem Einsatz und kannst du nicht auch beantworten warum sie wahrscheinlich mit oder eben ohne snychronisiertes add() erreicht werden?

ich selber könnte jetzt natürlich alles aufschreiben (in der Hoffnung dass ich richtig liege, will ich mal nicht überheblich voraussetzen)
aber wenn du gar nichts schreibst außer fragwürdigen Code, ist da noch bisschen mehr Luft zu Vorarbeit auf deiner Seite

edit:
ok, zu spät ;) auch wenn es noch zu interpretieren ist, für mich nicht ganz leicht
 
Zuletzt bearbeitet von einem Moderator:

Alex04

Bekanntes Mitglied
Hallo und danke schon mal für die Antworten!

Also das ist eine Uni Aufgabe (habe am Montag Prüfung ;) )
Es geht darum, einen Fifo Aspekt zu basteln, allerdings ohne ReentrantLocks und mit eigenem Lock Objekten.

Mit einem ReentrantLock wäre es sicherlich ziemlich einfach oder:

Java:
public class FifoServiceInvocationHandler implements InvocationHandler {

	private Lock lock = new ReentrantLock(true); // true indicates fifo handling
	private Object service;

	public FifoServiceInvocationHandler() {
		service = new MySimpleService();
	}

	@Override
	public Object invoke(Object proxy, Method method, Object[] args)
			throws Throwable {
		System.out.println("Invoked by " + Thread.currentThread().getId() + " command " + (String)args[0]);
		try {
			lock.lock();
			return method.invoke(service, (String)args[0]);
		} finally {
			lock.unlock();
		}
	}
	
}

Wenn ich es richtig verstanden habe liefert mir obiger Code einen Fifo Aspekt. ICh könnte ihn jetzt in Spring per MethodInvocation und AOP-Aspect integrieren usw.
Nun will ich diesen Aspekt aber ohne die Hilfe von Java, sprich mit eigenen Objekten nachbilden. Dafür die beiden Varianten aus Thread 1.

Meine Erläuterung zu den Unterschieden in den jeweiligen Varianten:
Ich verstehe warum queue.add() innerhalb des synchronized Blocks sein muss. Da gemeinsam genutzte Resource, die eben sonst je nach scheduling unterschiedlich befüllt wird (siehe Ariol Problem, danke!).
Als Konsequenz der Tatsache, dass wir die queue.add() Methode in den synchronized Block packen, stimmt jedoch der gesamte Block nicht mehr. Problem ist, dass wir alle Threads außer den ersten der den synchronen Block betritt "suspendieren". D.h. in der Queue ist immer nur der Thread, der als erstes in den synchronized Block gerät. Das ist Zufall, denn notifyAll() weckt alle Threads auf, d.h. irgendeiner kommt in den synchronized Block und fügt sich allein wieder zur Queue hinzu. DIe andern Threads werden wieder suspendiert usw. . Dadurch ist FIFO im endeffekt dann dahin, weil doch wieder random gescheduled wird.
Variante 2 schafft hier Abhilfe, denn nachdem der erste Thread den synchronized Block verlassen hat, werden nach und nach alle andern 1. zur Queue hinzugefügt, 2. schlafend gelegt (wait()) und ermöglichen dadurch das queuen der weiteren Threads...

So viel dazu :)
 
Zuletzt bearbeitet:
S

SlaterB

Gast
> Mit einem ReentrantLock wäre es sicherlich ziemlich einfach oder:
ist denn da die Reihenfolge sichergestellt? Frage ich jetzt weil ich das wirklich nicht kenne,

zum Rest:
> Ich verstehe warum queue.add() innerhalb des synchronized Blocks sein muss.
na das war doch deine Hauptfrage, also schon geklärt?
das mit der Reihenfolge hatte ich gar nicht bedacht, wäre alles nur ein großes synchronized, dann wäre das sicher ein Problem,
je nachdem wie FIFO definiert ist, ab welchem Zeitpunkt ist das zwingend, beim Eintritt in die Methode invoke?
strenggenommen könnte ja vor dem ersten Befehl dieser Methode noch ein Threadwechsel stattfinden und ein anderer Thread überholen..,
aber das wären sicher nur ms-Probleme, wer 5 sec später ankommt dürfte keine derartige Chance haben

mit deinem zweiten Code-Block vom ersten Post dürfte jedenfalls FIFO gut umgesetzt sein, dort sehe ich kein Random,
da die lange Bearbeitung des Threads nicht synchronisiert ist sondern immer nur ganz kurze Abschnitte,
ergo langet jeder neuer Thread im Sekundenabstand sofort in der Liste, die Reihenfolge ist gegeben,

> Variante 2 schafft hier Abhilfe,
klingt danach als wäre dir auch das inzwischen (oder schon von Anfang an?) klar, besteht noch irgendeine Frage?
 

Alex04

Bekanntes Mitglied
*EDIT
ReentrantLock stellt, sofern mit true im Ctor initialisiert, sicher, dass die Abhandlung der Threads fair, d.h. in der Regel nach FIFO, abgehandelt wird!

Ne es besteht keine Frage mehr, konnte es mir mit euren Hilfen usw. selbst erklären.
Wollte aber keinem meine Erläuterungen vorenthalten, weshalb ich die Erklärung in eigenen Worten nochmal verfasst habe ;)

Also nochmals Danke!
 
Zuletzt bearbeitet:
Ähnliche Java Themen
  Titel Forum Antworten Datum
KonradN Mal eine Frage zu Binary Serialization Allgemeine Java-Themen 15
8u3631984 Frage zu Java Streams min / max Allgemeine Java-Themen 17
8u3631984 Frage Performance bei Linked List und Array List Allgemeine Java-Themen 5
H Frage regex greater than less than Allgemeine Java-Themen 7
berserkerdq2 Frage zu IntelliJ und JavaFX Allgemeine Java-Themen 1
W Timer Konzept-Frage Allgemeine Java-Themen 16
T Eine Frage des Designs Allgemeine Java-Themen 2
C Frage zu eigenem TableCellRenderer Allgemeine Java-Themen 11
C Programmvorstellung & Frage zum Thema Geschäftsform Allgemeine Java-Themen 51
J Frage zu System.getproperties. Allgemeine Java-Themen 60
molat100 wie kann man die Frage beantworten Allgemeine Java-Themen 1
pkm Frage zur Präzision von Calendar.WEEK_OF_YEAR Allgemeine Java-Themen 12
J Eine Frage zu den Threads und Task Allgemeine Java-Themen 1
pkm Frage nach eventuellem syntaktischen Zucker bei der Konkatenation von ArrayLists Allgemeine Java-Themen 4
M Frage-Antwortspiel wie Wer wird Millionär Allgemeine Java-Themen 1
F Frage zu System.in Allgemeine Java-Themen 3
marcooooo Frage zum Beispiel im Anhang Allgemeine Java-Themen 16
T Meine Frage lautet wie ich 2 CSV Dateien miteinander in Java verbinde und Spalten die zueinander gehören durch den gleichen Key zusammen ausgebe? Allgemeine Java-Themen 5
S Noch eine Design-Frage zu Setter Allgemeine Java-Themen 6
B For-Loop Frage Allgemeine Java-Themen 21
L Java frage Allgemeine Java-Themen 3
bueseb84 Frage zu Mock und UpperBound Allgemeine Java-Themen 2
M Frage zum Konstruktor Allgemeine Java-Themen 2
W Best Practice Frage zur Umsetzung MVC Allgemeine Java-Themen 9
P String-Verschlüsselung - Frage zur Sicherheit Allgemeine Java-Themen 21
B Frage zu Unit-Tests Allgemeine Java-Themen 6
T Allgemeine Frage: GUI für 3D-Visualisierung Allgemeine Java-Themen 5
R Allgemeine Frage zu RMI bei MVC Allgemeine Java-Themen 2
O Frage zum Runtimeverhalten von Java ... Allgemeine Java-Themen 2
H Rundreise frage (Algorithmus) Allgemeine Java-Themen 18
B Generelle Frage bei einer Webanwendung / Reduzierung von DB Abfragen Allgemeine Java-Themen 1
D Frage zu Vererbung Allgemeine Java-Themen 5
J Frage zu regulärem Ausdruck Allgemeine Java-Themen 2
M Allgemeine Frage: Wie lernt man Java / Programmieren von Grund auf? Allgemeine Java-Themen 7
rentasad Design-Frage - Interfaces, Klassen, statische Methoden Allgemeine Java-Themen 3
S Frage zur JLS Allgemeine Java-Themen 0
J Verständnis Frage zur Instanz, Objekte, Instanzierung, Referenz Allgemeine Java-Themen 14
A Methoden Allgemeine Java Frage Allgemeine Java-Themen 3
E String Frage Allgemeine Java-Themen 9
I bin neu bei GitHub, Frage zur Sicherheit Allgemeine Java-Themen 14
C J2V8 NodeJs Java Bride Problem und Frage!?!? Allgemeine Java-Themen 1
C KeyListener Frage Allgemeine Java-Themen 3
T Frage zu UML in Java programmieren Allgemeine Java-Themen 1
R Konstanten initialisieren - FRAGE Allgemeine Java-Themen 3
MTJ004 FTP Frage zu FTP Speicherung Java-Android-FTP Allgemeine Java-Themen 5
J Frage zum Entwurf / json-Datenmodell Allgemeine Java-Themen 8
A Frage zu meinem Code Allgemeine Java-Themen 2
RalleYTN Classpath Nur ne kleine Frage zur MANIFEST.MF Allgemeine Java-Themen 4
T Frage zu Access Modifiers Allgemeine Java-Themen 6
W Input/Output Frage zu pdfbox und FileUtils Allgemeine Java-Themen 2
O Frage zur Implementierungsweise Allgemeine Java-Themen 4
B Frage zu Bitshift Allgemeine Java-Themen 3
J Java Zufallsgenerator (6 aus 49) Frage Allgemeine Java-Themen 7
L Frage zu RIA und GWT Allgemeine Java-Themen 0
P Concurrency Frage Allgemeine Java-Themen 8
M Frage zu Enumerations Allgemeine Java-Themen 2
F Unlimited Strength Policy. Frage Verbreitung der Anwendung Allgemeine Java-Themen 1
F Frage zur Library JTS Allgemeine Java-Themen 5
S Java Design Frage Allgemeine Java-Themen 10
E Reflection? Frage Allgemeine Java-Themen 4
C FileInputStream frage Allgemeine Java-Themen 6
G Polymorphie Programmdesign Frage Allgemeine Java-Themen 20
Uzi21 Frage zu NetBeans ( Console) Allgemeine Java-Themen 11
D Classpath Frage zum Java Resource Loading Allgemeine Java-Themen 2
G Frage zu JPA Allgemeine Java-Themen 1
S Methoden Frage Allgemeine Java-Themen 2
P MVC - Frage zu Model Allgemeine Java-Themen 4
K Frage zu Locks Allgemeine Java-Themen 1
S Frage zu abstract Allgemeine Java-Themen 5
M ArrayList<String> Frage Allgemeine Java-Themen 7
M OOP Design Frage Allgemeine Java-Themen 2
N Frage zur while-Schleife Allgemeine Java-Themen 18
T Best Practice Auslesen von Zeichenketten (Frage, Antworten, usw) Allgemeine Java-Themen 4
C Eine Frage zur Bearbeitungszeit Allgemeine Java-Themen 8
H Frage wegen Heap-Speicher Allgemeine Java-Themen 2
T Garbage Collection Frage Allgemeine Java-Themen 15
P Kurze Frage: aus einer File die Zeilenanzahl auslesen Allgemeine Java-Themen 9
D Frage zu Java und Umlauten / charsets Allgemeine Java-Themen 2
B Frage zu Java und OpenGL? Allgemeine Java-Themen 3
Q Kapselung Allgemeine Design- Frage Allgemeine Java-Themen 8
A eine test thread.join() frage Allgemeine Java-Themen 2
DStrohma LayoutManager Frage zum GridBagLayout Allgemeine Java-Themen 4
F Frage zu Regex möglich Allgemeine Java-Themen 4
H XML-File mit Java erzeugt Frage Allgemeine Java-Themen 10
D Frage und Antwort Programm, Problem bei Methodenaufruf Allgemeine Java-Themen 3
J NetBeans Frage bezüglich der Scanner-Klasse Allgemeine Java-Themen 6
H Java Vector Frage Allgemeine Java-Themen 9
W Frage... Allgemeine Java-Themen 29
R Frage zur topologischen Sortierung Allgemeine Java-Themen 2
H Frage zu weka.core.Instance Allgemeine Java-Themen 3
Y Kleine Frage zu String.split Allgemeine Java-Themen 3
T Frage zu Klassendesing Allgemeine Java-Themen 3
W Frage zu Refactoring statischer Methoden Allgemeine Java-Themen 4
C Eclipse Wichtige frage Allgemeine Java-Themen 5
H Frage zu java.weka.core.Instances Allgemeine Java-Themen 3
S Frage zu Format Modifiers in Log4j Allgemeine Java-Themen 11
H Frage zu clone() Allgemeine Java-Themen 5
4 Simple(?) Frage zu Threads Allgemeine Java-Themen 14
H2SO3- SCJP Chapter 3 Frage 10. Falsche Antwort? Allgemeine Java-Themen 15
H Frage sinnvolle Datenspeicherung und -verarbeitung Allgemeine Java-Themen 3

Ähnliche Java Themen

Neue Themen


Oben