Java 멀티스레딩 '대기/알림 메커니즘'

클래식 패러다임:

대기 파티는 다음 원칙을 따릅니다.

1. 물체의 자물쇠를 얻습니다.
2. 조건이 충족되지 않으면 객체의 wait() 메서드를 호출하고 알림을 받은 후에도 조건을 확인합니다.
3. 조건이 충족되면 해당 논리적 작업이 실행됩니다.
의사 코드는 다음과 같습니다.

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

통지 당사자는 다음 원칙을 따릅니다.
1. 개체의 잠금을 얻습니다.
2. 조건을 변경하세요.
3. 개체를 대기 중인 모든 스레드에 알립니다.
의사 코드는 다음과 같습니다:

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

샘플 코드:

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);
            }
        }
    }
}

위 내용은 Java 멀티스레딩 '대기/알림 메커니즘'의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!