Welche Möglichkeiten gibt es für die Zusammenarbeit von Java-Threads?

Warum müssen Threads zusammenarbeiten, um eine bestimmte Arbeit abzuschließen? Beispiel: Ein Thread ändert den Wert eines Objekts und ein anderer Thread erkennt die Änderung und führt dann den entsprechenden Vorgang aus mit einem Thread, und die endgültige Ausführung ist ein weiterer Thread. Durch dieses Modell werden Produzenten und Konsumenten getrennt und so die Isolierung von „Was“ und „Wie“ erreicht. Die einfache Möglichkeit besteht darin, den Verbraucherthread kontinuierlich in einer Schleife laufen zu lassen, um zu prüfen, ob die Variablen den Erwartungen entsprechen, nicht erfüllte Bedingungen in der While-Schleife festzulegen und die While-Schleife zu verlassen, wenn die Bedingungen erfüllt sind, wodurch die Arbeit des Verbrauchers abgeschlossen wird. Bei dieser Art der Zusammenarbeit zwischen Threads gibt es zwei Probleme:

(1) Es ist schwierig, die Aktualität sicherzustellen.

(2) Es ist schwierig, den Overhead zu reduzieren. Wenn die Ruhezeit verkürzt wird, beispielsweise 1 Millisekunde lang schläft, können Verbraucher Änderungen in den Bedingungen schneller erkennen, es werden jedoch möglicherweise mehr Prozessorressourcen beansprucht, was zu unnötiger Verschwendung führt.

Einführung

Die beiden häufigsten Methoden der Thread-Zusammenarbeit in Java: Verwendung von Object.wait(), Object.notify() und Verwendung von Condition

Methode 1

Die Methoden „wait“, „notify“ und „notifyAll“ in Object sind definiert als folgt:

public final native void notify(); public final native void wait(long timeout) throws InterruptedException;

• wait(), notify() und notifyAll() lokale Methoden, und es handelt sich um eine endgültige Methode, die nicht überschrieben werden kann
Ein Objekt aufrufen Die notify()-Methode kann einen Thread aufwecken, der auf den Monitor dieses Objekts wartet. Wenn mehrere Threads auf den Monitor dieses Objekts warten, kann nur einer der Threads aufgeweckt werden
Durch Aufrufen der notifyAll()-Methode können alle Threads aktiviert werden, die auf den Monitor dieses Objekts warten Das Objekt verfügt über einen Monitor (d. h. eine Sperre).
Rufen Sie die wait()-Methode eines Objekts auf, den aktuellen Thread. Sie müssen den Monitor (d. h. eine Sperre) dieses Objekts besitzen, daher muss der Aufruf der wait()-Methode in a erfolgen synchronisierter Block oder synchronisierte Methode

• Bedingung erschien nur in Java 1.5. Sie wird verwendet, um die herkömmlichen Funktionen „wait()“ und „notify()“ von Object zu ersetzen. Um eine Zusammenarbeit zwischen Threads zu erreichen, ist die Verwendung im Vergleich zur Verwendung von „wait()“ und „notify()“ von Object sicherer und effizienter Die Methoden „await()“ und „signal()“ von Condition1 ermöglichen die Zusammenarbeit zwischen Threads. Bedingung ist im Grunde eine Schnittstelle Eine Bedingung ist lock.newCondition()

• Rufen Sie die Methoden „await()“ und „signal()“ von Condition auf. Beide sind innerhalb des Sperrschutzes erforderlich, das heißt, sie müssen zwischen lock.lock() und verwendet werden lock.unlock

• Beispiel

  public class Test {
      public static Object object = new Object();
      public static void main(String[] args) {
          Thread1 thread1 = new Thread1();
          Thread2 thread2 = new Thread2();
          thread1.start();
          try {
              Thread.sleep(200);
          } catch (InterruptedException e) {
              e.printStackTrace();
          }
          thread2.start();
      }
      static class Thread1 extends Thread{
          @Override
          public void run() {
              synchronized (object) {
                  try {
                      object.wait();
                  } catch (InterruptedException e) {
                  }
                  System.out.println("线程"+Thread.currentThread().getName()+"获取到了锁");
              }
          }
      }
      static class Thread2 extends Thread{
          @Override
          public void run() {
              synchronized (object) {
                  object.notify();
                  System.out.println("线程"+Thread.currentThread().getName()+"调用了object.notify()");
              }
              System.out.println("线程"+Thread.currentThread().getName()+"释放了锁");
          }
      }
  }

Das obige ist der detaillierte Inhalt vonWelche Möglichkeiten gibt es für die Zusammenarbeit von Java-Threads?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!