Schauen wir uns zuerst einen Code an:
class MyThread implements Runnable{ private int count = 10; @Override public void run() { while(count > 0) { System.out.println(Thread.currentThread().getName() + "开始执行"); System.out.println("count还剩" + --count); System.out.println(Thread.currentThread().getName() + "执行结束"); System.out.println(); } } } public class Test{ public static void main(String[] args) { MyThread myThread = new MyThread(); new Thread(myThread).start(); new Thread(myThread).start(); new Thread(myThread).start(); } }
Das laufende Ergebnis ist wie folgt:
Thread-0开始执行 Thread-2开始执行 Thread-1开始执行 count还剩8 count还剩9 Thread-2执行结束 count还剩7 Thread-1执行结束 Thread-1开始执行 Thread-0执行结束 Thread-0开始执行 count还剩5 Thread-0执行结束 Thread-2开始执行 count还剩4 Thread-2执行结束 Thread-2开始执行 count还剩3 count还剩6 Thread-2执行结束 Thread-2开始执行 Thread-0开始执行 count还剩2 Thread-2执行结束 Thread-2开始执行 count还剩0 Thread-2执行结束 Thread-1执行结束 count还剩1 Thread-0执行结束
Offensichtlich ist dies nicht das Ergebnis, das wir wollen. Das Ergebnis, das wir wollen, ist: ein vollständiges Drücken Sie alleine. Führen Sie Ihre eigenen run()-Methoden nacheinander aus, aber die oben genannten Ergebnisse sind nicht in der richtigen Reihenfolge: Der zweite Thread ist eingegangen, bevor der vorherige Thread die Ausführung seiner eigenen Aufgabe abgeschlossen hat. Wie kann man dieses Problem lösen?
Lassen Sie uns zunächst das von uns erstellte Objekt myThread analysieren und dann diese drei Threads gleichzeitig zur Ausführung aufrufen . Wenn wir möchten, dass jeder Thread seine Aufgabe nach der Eingabe abschließt, müssen wir das myThread-Objekt sperren und verhindern, dass andere Threads es erhalten. Wenn es beispielsweise einen Raum gibt, müssen Sie nach dem Betreten die Tür abschließen, wenn Sie nicht möchten, dass andere wieder hereinkommen.
Java stellt uns eine Sperre namens „synchronized“ zur Verfügung. Wie soll es also verwendet werden?
Zwei Modi von „synchronisiert“: synchronisierte Methode und synchronisierter Codeblock.
1. Objektsperre:
1. Synchronisierter Codeblock: Synchronisiert (das zu sperrende Objekt) vor dem Codeblock hinzufügen.
class MyThread implements Runnable{ private int count = 10; @Override public void run() { synchronized (this) { while(count > 0) { System.out.println(Thread.currentThread().getName() + "开始执行"); System.out.println("count还剩" + --count); System.out.println(Thread.currentThread().getName() + "执行结束"); System.out.println(); } } } } public class Test{ public static void main(String[] args) { MyThread myThread = new MyThread(); new Thread(myThread).start(); new Thread(myThread).start(); new Thread(myThread).start(); } }
2. Synchrone Methode: Fügen Sie das synchronisierte Schlüsselwort vor dem Rückgabewert der Methode hinzu.
class MyThread implements Runnable{ private int count = 10; @Override public void run() { while(count > 0) { count--; fun(); } } public synchronized void fun() { System.out.println(Thread.currentThread().getName() + "开始执行"); System.out.println("count还剩" + count); System.out.println(Thread.currentThread().getName() + "执行结束"); System.out.println(); } } public class Test{ public static void main(String[] args) { MyThread myThread = new MyThread(); new Thread(myThread).start(); new Thread(myThread).start(); new Thread(myThread).start(); } }
2. Globale Sperre:
Oben sperren wir alle myThread-Objekte. Was ist, wenn wir dieselbe Methode mehrerer Objekte sperren möchten?
Es gibt auch zwei Methoden mit Objektsperren: die synchronisierte Methode und den synchronisierten Codeblock.
1. Schreiben Sie in die Klammern vor dem Synchronisationscodeblock die Klasse der Methode, die Sie sperren möchten
class MyThread implements Runnable{ private static int count = 10; @Override public void run() { synchronized (MyThread.class) { while(count > 0) { count--; fun(); } } } public void fun() { System.out.println(Thread.currentThread().getName() + "开始执行"); System.out.println("count还剩" + count); System.out.println(Thread.currentThread().getName() + "执行结束"); System.out.println(); } } public class Test{ public static void main(String[] args) { MyThread myThread = new MyThread(); new Thread(myThread).start(); new Thread(myThread).start(); new Thread(myThread).start(); } }
2 Fügen Sie auf der Grundlage der oben genannten Synchronisationsmethode die hinzu statisches Schlüsselwort, Sie können eine globale Sperre erreichen.
class MyThread implements Runnable{ private static int count = 10; @Override public void run() { while(count > 0) { fun(); } } public synchronized static void fun() { System.out.println(Thread.currentThread().getName() + "开始执行"); System.out.println("count还剩" + count); System.out.println(Thread.currentThread().getName() + "执行结束"); System.out.println(); count--; } } public class Test{ public static void main(String[] args) { MyThread myThread = new MyThread(); new Thread(myThread).start(); new Thread(myThread).start(); new Thread(myThread).start(); } }
Verwandte Artikel:
Beispielcode-Sharing der Java-Synchronisationssperre (synchronisiert)
Ähnliche Videos:
Umfassende Analyse von Java-Annotationen
Das obige ist der detaillierte Inhalt vonJava: Detaillierte Erläuterung der Objektsperre „synchronisiert' und der globalen Sperre. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!