Java 멀티스레드 Wait() 및 Notify()

1. Wait()와 Notify, NotifyAll은 모두 Object의 방법이다
2. 다중 스레드 협업은 동일한 객체를 제어하는 Wait()와 Notify()를 통해 수행됩니다.
3. Wait () 방법을 호출할 때, 현재 스레드는 다른 스레드가 대상의 Notify () 방법을 호출할 때까지 막힌 상태로 들어간다

package Thread.Wait;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

class Car {
    private boolean waxOn = false;

    //  
    public synchronized void waxed() {
        waxOn = true;
        notifyAll();
    }

    //  
    public synchronized void buffed() {
        waxOn = false;
        notifyAll();
    }

    public synchronized void waitForWaxing() throws InterruptedException {
        while (waxOn == false)
            wait();
    }

    public synchronized void waitForBuffing() throws InterruptedException {
        while (waxOn == true)
            wait();
    }
}

class WaxOn implements Runnable {
    private Car car;

    public WaxOn(Car c) {
        car = c;
    }

    @Override
    public void run() {
        try {
            while (!Thread.interrupted()) {
                System.out.println("Wax On!");
                TimeUnit.MILLISECONDS.sleep(200);
                car.waxed();//     waxOn = true;notifyAll();
                car.waitForBuffing();//    while (waxOn == true) wait();
            }
        } catch (Exception e) {
            System.out.println("Exiting via interrupt");
        }
        System.out.println("Ending Wax On task");
    }
}

class WaxOff implements Runnable {
    private Car car;

    public WaxOff(Car c) {
        car = c;
    }

    @Override
    public void run() {
        try {
            while (!Thread.interrupted()) {
                car.waitForWaxing();//       while (waxOn == false) wait();
                System.out.println("Wax Off!");
                TimeUnit.MILLISECONDS.sleep(200);
                car.buffed();//      waxOn = false;    notifyAll();
            }
        } catch (Exception e) {
            System.out.println("Exiting via interrupt");
        }
        System.out.println("Ending Wax Off task");
    }
}

public class WaxOMatic {
    public static void main(String[] args) throws Exception {
        Car car = new Car();
        ExecutorService exec = Executors.newCachedThreadPool();
        exec.execute(new WaxOff(car));
        exec.execute(new WaxOn(car));
        TimeUnit.SECONDS.sleep(5);
        exec.shutdownNow();
    }
}

이 내용에 흥미가 있습니까?

현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:

Java 멀티스레드 스레드 동기화

이 Lock 자물쇠는 현식 생성, 잠금, 방출이 필요합니다.synchronized 키워드보다 현식 Lock 자물쇠는 사용이 번거롭고 사용 시 오류가 발생할 수 있지만 더욱 강력한 기능이 있습니다.locks 패키지에는...

텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.

CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.

Java 멀티스레드 Wait() 및 Notify()

좋은 웹페이지 즐겨찾기