Synchronisiertes Attribut in anderer Klasse

Question

Ich versuche, 2 Threads einzurichten, die eine Ganzzahl in einer anderen Klasse entweder erhöhen oder verringern. Ich habe einige Probleme mit der Synchronisierung dieses Attributs.

Das ist meine Hauptklasse, wo ich meine Themen und Gegen Klasse einzurichten:

public class Main { 
public static void main(String[] arg) { 
    Counter c = new Counter(10000000); 
    Thread1 t1 = new Thread1(c); 
    Runnable2 r2 = new Runnable2(c); 
    Thread t2 = new Thread(r2); 
    t1.start(); 
    t2.start(); 
    System.out.println(t.getNumber()); 
    } 
} 

Dies ist meine Gegen Klasse:

public class Counter{ 
private int number; 
private static final Object countLock = new Object(); 

public Counter(int number){ 
    this.number= number; 
} 

public void increase(){ 
    synchronized(countLock){ 
     number++; 
    } 
} 

public void decrease(){ 
    synchronized(countLock){ 
     number--; 
    } 
} 

public int getNumber(){ 
    return number; 
} 

} 

Und das ist meine Thread1 Klasse: (Die runnable Klasse statt 'erstreckt Thread')

public class Thread1 extends Thread{ 
private Counter c; 

public Thread1(Counter c){ 
    this.c = c; 
} 

public void run(){ 
    for(int i = 0; i < c.getNumber(); i++){ 
     c.increase(); 
    } 
} 
} 

ist das gleiche, nur mit 'implementiert Runnable'

jedoch meine out put ist immer 10000000. Obwohl ich beide Methoden synchronisiert habe. Gibt es jemanden, der erklären kann, was vor sich geht?

Answer 1

Wenn ich Ihren Code ausführen, wird System.out.println(t.getNumber()); ausgeführt, bevor einer der Threads hochgesponnen wird.

Answer 2

Zunächst einmal sollte dies eigentlich nie enden, da Sie den Wert, den Sie als obere Grenze in Ihrer for Schleife in der gleichen Schleife verwenden, erhöhen. Nicht sicher, ob dies das gewünschte Verhalten ist.

Zweitens wird Ihre System.out.println (wahrscheinlich) immer den Anfangswert Counter drucken, da die Threads keine Zeit hatten, ihre Arbeit zu erledigen. Zu Testzwecken können Sie etwas wie TimeUnit.SECONDS.sleep(10); hinzufügen. Für einen anspruchsvolleren Ansatz schlage ich jedoch vor, dass Sie sich java.util.concurrent.Executors und java.util.concurrent.ExecutorService ansehen (es gibt viele Beispiele dafür).

Drittens wird Ihr Leben viel einfacher sein, wenn Sie Ihre Counter s int number durch eine java.util.concurrent.atomic.AtomicInteger ersetzen.

Answer 3

Fügen Sie t1.join(); t2.join(); hinzu, nachdem Sie sie gestartet haben, damit die Threads ihre Aufgabe abschließen, bevor der Thread main Sysout ausführt.

Zu einem anderen Hinweis, ich glaube nicht, dass der Thread jemals aus der for loop als c.getNumber() weiter steigt kommen wird.

Ich glaube, Sie

int number=c.getNumber(); for(int i = 0; i < number; i++) {

statt

for(int i = 0; i < c.getNumber(); i++) {