Java Multithreading „Warten/Benachrichtigungsmechanismus'

Klassisches Paradigma:

Die wartende Partei folgt den folgenden Prinzipien:

1. Erhalten Sie die Sperre des Objekts.
2. Wenn die Bedingung nicht erfüllt ist, rufen Sie die wait()-Methode des Objekts auf und überprüfen Sie die Bedingung trotzdem, nachdem Sie benachrichtigt wurden.
3. Wenn die Bedingungen erfüllt sind, wird die entsprechende logische Aufgabe ausgeführt.
Der Pseudocode lautet wie folgt:

synchronized(对象) { 
        while(条件不满足) { 
            对象.wait(); 
        } 
        完成任务逻辑 
     }

Die benachrichtigende Partei folgt den folgenden Grundsätzen:
1. Erhalten Sie die Sperre des Objekts.
2. Ändern Sie die Bedingungen.
3. Benachrichtigen Sie alle Threads, die auf das Objekt warten.
Der Pseudocode lautet wie folgt:

• synchronized(对象) { 
  
          改变对象 
  
          对象.notifyAll(); 
  
      }

Beispielcode:

import java.text.SimpleDateFormat;import java.util.Date;/**
 * 线程等待/通知机制
 * Created by peng on 2018/7/22.
 */public class WaitNotify {

    private static boolean flag = true;    private static Object lock = new Object();    public static void main(String[] args) {
        Thread waitThread = new Thread(new Wait(), "WaitThread");
        waitThread.start();
        SleepUtils.second(1);

        Thread notifyThread = new Thread(new Notify(), "NotifyThread");
        notifyThread.start();
    }    private static class Wait implements Runnable {
        @Override
        public void run() {            // 加锁，拥有lock的Monitor
            synchronized (lock) {                // 当条件不满足时，继续wait，同时释放了lock的锁
                while (flag) {                    
                try {
                        System.out.println(Thread.currentThread() + " flag is true. wait @ "
                                + new SimpleDateFormat("HH:mm:ss").format(new Date()));
                        lock.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }                // 条件满足时，完成工作
                System.out.println(Thread.currentThread() + " flag is false. running @ "
                        + new SimpleDateFormat("HH:mm:ss").format(new Date()));
            }
        }
    }    
    private static class Notify implements Runnable {
        @Override
        public void run() {            // 加锁，拥有lock的Monitor
            synchronized (lock) {
                System.out.println(Thread.currentThread() + " hold lock. notify @ "
                        + new SimpleDateFormat("HH:mm:ss").format(new Date()));
                lock.notifyAll();
                flag = false;
                SleepUtils.second(5);
            }            // 再次加锁
            synchronized (lock) {
                System.out.println(Thread.currentThread() + " hold lock again. sleep @ "
                        + new SimpleDateFormat("HH:mm:ss").format(new Date()));
                SleepUtils.second(5);
            }
        }
    }
}

Das obige ist der detaillierte Inhalt vonJava Multithreading „Warten/Benachrichtigungsmechanismus'. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!