thread synchronisation

[myggel]

hi!

weiss jemand, warum printme() nicht wirklich exclusiv ausgeführt wird?

public class test extends Thread {
	int a=5;
	public test(int a){
		this.a=a;		
	}
	public synchronized void printme(){
		try{double i=0; 
			while(i<3){
			i++;
			System.out.println(i);
			}
		System.out.println("inside printme()");
		System.out.println(a+"+"+a);}
		catch(Exception e){}
	}
	public void run(){
		printme();
	}
public static void main(String[] args) {
	 test t1=new test(1);
	 test t2=new test(2);
	 test t3=new test(3);
	 t1.start();
	 t2.start();
	 t3.start();
		System.out.println("prog ende");
	}
}

Ausgabe ist bei mir:

1.0
2.0
3.0
1.0
2.0
3.0
inside printme()
2+2
inside printme()
1+1
1.0
prog ende
2.0
3.0
inside printme()
3+3

irgendwie hab ich gehofft, dass mehr so etwas herauskommt:

1.0
2.0
3.0
inside printme()
1+1
1.0
2.0
3.0
inside printme()
2+2
1.0
2.0
3.0
inside printme()
3+3

ist bestimmt was ganz einfaches und logisches, oder?

gruß
micha

 

[byte]

Das Keyword synchronized ist objektbezogen. Da Du drei verschiedene Objekte erzeugst, behindern die sich auch nicht gegenseitig und die Methoden laufen nebenläufig ab. Pack die Methoden in ein Objekt, das von allen drei Threads verwendet wird und Du wirst das von Dir erwartete Verhalten erzeugen.

 

[myggel]

danke für die antwort,
nur kann ich damit nix anfangen, da ich mich mit java nicht wirklich auskenne und etwas rumprobieren will. hab jetzt auch mal diverses ausprobiert, aber das taugt alles nix.

gruß
micha

p.s. und wie bekommeich die ThreadID, es gibt da ja getID(), aber wenn ich z.b. test.getID() schreibe - egal wo im code, oder auch t1.getID() bekomme ich von eclipse immer fehlermeldungen, dass es getID() nicht gäbe?

 

[Murray]

Du kannst auf das Class-Object synchroniesieren, dann sollte es klappen:

public  void printme(){
      synchronized (getClass()) {
        try{double i=0;
           while(i<3){
           i++;
           System.out.println(i);
           }
        System.out.println("inside printme()");
        System.out.println(a+"+"+a);}
        catch(Exception e){
          e.printStackTrace(); //---leere catch-Blöcke sind böse!!
        }
      }
   }

Die Thread-ID bekommst Du mit getId() (mit kleinem 'd')

 

[myggel]

ah, prima,
aber was macht das "getClass()" genau?
gibt mir das genau das objekt (den thread x) zurück, der jetzt gerade die synchronized methode hat?
muss ich eigentlich wenn ich das ganze dann ohne eclipse machen will bei javac irgendwas angeben oder noch einen import machen oder so? javac meint nämlich:

test.java:17: cannot resolve symbol
symbol  : method getId ()
location: class testjavascript:go()
                                System.out.println(locked +" ThreadName:"+ThreadName+" ID:"+getId());

danke

 

[Leroy42]

Wenn du nur getId() schreibst, sucht javac nach einer Methode dieses
Namens in deiner Klasse testjavascript (Klassennamen sollte man übrigens
groß schreiben).

Die Methode ist aber eine Instanzmethode der Klasse Thread; du mußt
sie also auf eine Thread-Instanz anwenden. Um den aktuellen Thread
zu ermitteln schau dir mal getCurrentThread an.

 

[Murray]

Innerhalb Deiner Klasse test (die wirklich besser Test heissen sollte), ist die Methode getId() als Instanzmethode verfügbar; insofern sollte der Compiler (ob in Eclipse oder nicht) t1.getId() verstehen.

Und getClass() liefert für ein Objekt das sog. Class-Object zurück, also ein Objekt, welches die Eigenschaften der Klasse des Objekts kapselt. Das API dieses Class-Objects ist hier nicht so wichtig; entscheidend ist aber, dass für alle Instanzen einer Klasse (zumindest, wenn sie vom gleichen ClassLoader geladen wurden), hier immer dasselbe Objekt geliefert wird. Daduch, dass der kritische Abschnitt jetzt auf dieses Objekt synchronisiert wird, werden die Zugriffe aus allen Instanzen snychronisiert. Anstelle von getClass() könntest Du in Deiner Klassen auch irgendein statisches Objekt halten, also z.B. so:

public class test extends Thread {

   static Object syncObject = new Object();

   int a=5;
   public test(int a){
      this.a=a;      
   }

   public void printme(){
      synchronized (syncObject) {
        try{double i=0;
           while(i<3){
           i++;
           System.out.println(i);
           }
        System.out.println("inside printme()");
        System.out.println(a+"+"+a);}
        catch(Exception e){
          e.printStackTrace(); //---leere catch-Blöcke sind böse!!
        }
      }
   } 

   public void run(){
      printme();
   }
public static void main(String[] args) {
    test t1=new test(1);
    test t2=new test(2);
    test t3=new test(3);
    t1.start();
    t2.start();
    t3.start();
      System.out.println("prog ende");
   }
}