Synchronized Probleme

[JavaNoob1988]

Guten Tag Java-Freunde,

könnte mir jemand sagen, weshalb mein Programm immernoch unterschiedliche Werte als Result zurückgibt, obwohl ich eine synchronized-Methode für die Zählvariable verwende?

public class AppSynchronizedKeyword {

    private int count = 0;

    public synchronized void increment() {
        count++;
    }

    public static void main(String[] args) {
        AppSynchronizedKeyword dummyObject = new AppSynchronizedKeyword();
        dummyObject.doWork();
    }

    public void doWork() {

        Thread threadOne = new Thread(new Runnable() {
            public void run() {

                for (int i = 0; i < 1000; i++) {
                    increment();
                }
            }
        });

        Thread threadTwo = new Thread(new Runnable() {
            public void run() {

                for (int i = 0; i < 1000; i++) {
                    increment();
                }
            }
        });

        threadOne.start();
        threadTwo.start();
        System.out.println("Count is " + count);
    }
}

Danke und Grüße

 

[Flown]

Erst einmal bitte JAVA tags für deinen Code verwenden.

Was hast du dir denn für ein Ergebnis erwartet?

Ich glaube eher, dass du soetwas in der Art erwartest:

public class AppSynchronizedKeyword {
  
  private static int count = 0;
  
  public static synchronized void increment() {
    count++;
  }
  
  public static void main(String[] args) {
    AppSynchronizedKeyword dummyObject = new AppSynchronizedKeyword();
    dummyObject.doWork();
  }
  
  public void doWork() {
    
    Thread threadOne = new Thread(() -> {
      
      for (int i = 0; i < 1000; i++) {
        AppSynchronizedKeyword.increment();
      }
    });
    
    Thread threadTwo = new Thread(() -> {
      
      for (int i = 0; i < 1000; i++) {
        AppSynchronizedKeyword.increment();
      }
    });
    
    threadOne.start();
    threadTwo.start();
    try {
      threadOne.join();
      threadTwo.join();
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    System.out.println("Count is " + count);
  }
}

Hier wird die die increment Methode als static deklariert, damit beide Threads diesen erhöhen. Dann warten beide darauf bis sie fertig sind und somit erhälst du immer das selbe Ergebnis.

Wenn du nicht joinst, dann wird sofort nachdem der Thread wegen Multithreading wartet, der Hauptthread wieder aktiv und gibt den derzeitigen Stand des increment aus!

 

[JavaNoob1988]

Also muss ich immer joinen, sobald ich mehrere Threads habe, die sich eine Arbeit teilen?
Interessant....werde mir die Methode mal genauer durchlesen.

Mich verwirrt das nur, weil ich die Übung aus einem Tutorial habe und der Programmierer dort überhaupt nicht join verwendent. Der benutzt nur die synchronized Methode und bei ihm funktioniert das dann.

Grüße und Danke für deine Antwort

 

[Admiral Helmut]

Hallo
Naja es ist denke ich so: Threads sind ja völlig getrennt laufende Ausführungsstränge die vom Schedular CPU Zeit zugeteilt bekommen. Dein MainThread baut 2 andere Threads auf und startet diese dann. Die Arbeit die du diesen Threads in der Run Methode mitgibst laufen nun in diesen seperaten Ausführungssträngen. Dein MainThread macht seine Arbeit ganz normal weiter, also direkt nach dem Start der Threads die Ausgabe des Counters...

Da der Schedular die CPU Zeit jedesmal ein bisschen anders verteilt, je nachdem was gerade auf deiner CPU los ist... wirst du bei jedem Programm start einen anderen Counter kriegen, weil die Worker Threads in der Regel schon etwas CPU zeit bekommen haben und mit dem inkrementieren schon angefangen haben.

Dennoch ist das was Flown schon gemeint hat, der Zugriff auf die AppSynchronizedKeyword Felder über die Threads nicht so schön. Also entweder über static, oder man macht das glaube ich über ein Datenobject, welches man beiden Threads mitgibt.

Verbessert mich bitte, bin selbst Anfänger

Gruß Helmut

 

[Flown]

Was hast du denn für ein Ergebnis erwartet? Vielleicht kannst du den Link zu dem Übungsbeispiel herzeigen.

 

[JavaNoob1988]

Also so wie ich mein Code reingeschrieben habe, müsste es schon funktionieren. Ich habe das Beispiel aus einem Tutorialvideo. Der Code wurde im Video auch ausgeführt und hat immer das gleiche Ergebnis geliefert. Ich mache es zu Hause nach und es liefert immer wieder unterschiedliche Ergebnisse.
Das mit dem join() hat der Tutorialist (is das ein Wort?) auch zuerst gezeigt, meinte aber auch, dass das eine ungeeignete Implementierung sei....

Deswegen bin ich so verwirrt. Das mit den Threads habe ich schon verstanden @Helmut, aber danke für die detaillierte Erklärung.

 

[Flown]

Wenn du einmal bitte den Link zu dem Video posten könntest, dann könnte man nachverfolgen, was er gemacht hat.

Der derzeitige Code, den du am Anfang an geliefert hast, macht genau das, was er soll und liefert immer unterschiedliche Ergebnisse!

 

[arilou]

'synchronized [Methode]' sorgt dafür, dass immer nur ein Zugreifer zur gleichen Zeit auf die Methode zugreifen kann.
Mehr nicht.
Im Prinzip genügt das, um sich selbst eine Semaphore bauen zu können, womit ein .join() ersetzt werden kann, und tatsächlich nicht mehr nötig ist. Aber das muss man dann von Hand selber bauen/sicherstellen.