probleme, threads zu snychronisieren (race condition)

[Guest]

hey,
ich habe mir folgendes programm gebastelt, um eine race condition sichtbar zu machen:

public class MyThread implements Runnable{
	
	private String name;
	private int count;
	
	public MyThread(String s){
		count = 0;
		name = s;
	}
	
	/* @Override */
	public void run(){
			while(ThreadTest.count < 1000000){
				ThreadTest.count += 1; ThreadTest.total++; count++;
			}
			System.out.println(name+": STOP - count hat Wert: "+ThreadTest.count+" |my: "+count);
	
	}
}

public class ThreadTest{
	
	public static int count = 0;
	public static int total = 0;

	public static void main(String[] args) {
		Thread t1 = new Thread (new MyThread("t1"));
		Thread t2 = new Thread (new MyThread("t2"));
		t1.start();
		t2.start();
		
		try {
			Thread.sleep(200);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		System.out.println("GESAMT: "+total);
		
	}
}

es arbeitet auch so, wie erwartet. das heisst, dass meistens der wert von count (die globale variable, nicht die instanzvariable) am schluss nicht 100000 ist, sondern 1000001.
ausserdem ist der wert von total am schluss meist (weit) über 100000.
passt also.

nun wollte ich aber die race condition vermeiden, und das synchronisieren.

ich kann aber laut eclipse keinen integer-wert synchronisieren.. sprich:

public void run(){
    synchronized(ThreadTest.count){ ... }
}

geht nicht!

genauso wenig kann ich die variable selbst als synchronized deklarieren! das is auch n syntax error..
diese java-oo ist ja ne feine sache, aber manchmal frage ich mich, ob sie es nicht etwas übertrieben haben...

wie kann ich denn jetzt den zugriff auf die _statische_ variable "count" (in der Klasse ThreadTest) synchronisieren?

ich hab hier in meinem skript ein beispiel, wo sie ein objekt synchronisieren. aber das hab ich ja hier gar nicht, ich will einfach nur den zugriff auf eine variable kontrollieren... und das geht wie?

danke

 

[Ariol]

http://www.java-forum.org/de/viewto...ondition&sid=1f694c7ca3f728cfa5dfb478a9248b4f

 

[Guest]

das ist doch wieder mit objekten! mir ist klar, wie es mit objekten geht!

ist es nicht möglich, dass auch mit einer _statischen_ variable zu machen? dass also meine threads
nicht mit einem objekt arbeiten, sondern einfach nur nebeneffekte erzeugen durch das verändern von
statischen variablen?

das war doch die frage

 

[Ariol]

Statische setter benutzen ;-)

package Thread;
public class MyThread extends Thread{
   
   private String name;
   private int count;
   
   public MyThread(String s){
      count = 0;
      name = s;
   }
   
   /* @Override */
   public void run(){
         while(ThreadTest.count < 10000){
        	count++;
            ThreadTest.setCount(ThreadTest.count+1);
            ThreadTest.setTotal(ThreadTest.total+1);
         }
         System.out.println(name+": STOP - count hat Wert: "+ThreadTest.count+" |my: "+count);
   
   }
}

package Thread;

public class ThreadTest
{

	public static int	count	= 0;

	public static int	total	= 0;

	public static void main(String[] args)
	{
		Thread t1 = new Thread(new MyThread("t1"));
		Thread t2 = new Thread(new MyThread("t2"));
		t1.start();
		t2.start();

		try
		{
			Thread.sleep(200);
		}
		catch (InterruptedException e)
		{
			e.printStackTrace();
		}
		System.out.println("GESAMT: " + total);

	}
	
	public static void setCount(int count)
	{
		ThreadTest.count = count;
	}
	
	public static void setTotal(int total)
	{
		ThreadTest.total = total;
	}
}

EDIT: Wenn du ein kurzes sleep() (nicht statisch) in deine Thread-Schleife einbaust wechseln die beiden sich auch ab^^

 

[Guest]

oh man bin ich dumm. ich hatte erst setter verwendet, und sie dann weggelassen weil ich gesehen hab, dass keine race condition auftritt. und jetzt frag ich, wie man die race condition verhindert.

------> :applaus:

liegt wohl daran, dass ich so auf synchronized fixiert war. k danke, hat sich erledigt