7.4 Java 스레드: notify () 및 wait () 예

본고는 자바를 보여 주는 두 개의 코드 예시를 포함한다.그들은 매우 전형적인 용법을 대표한다.그들을 이해하면 notify () 와wait () 를 더 잘 알 수 있습니다.

1. 배경 지식

4

synchronized 키워드는 상호 배척 액세스에 사용됩니다

4

한 방법이 동기화되기 위해synchronized 키워드를 성명에 간단하게 추가합니다.그러면 같은 대상에서 두 가지 동기화 방법의 호출이 서로 엇갈릴 수 없다

4

동기화 문장은 내부 자물쇠를 제공하는 대상을 지정해야 한다.synchronized(this)를 사용할 때는 다른 대상을 동기화하는 방법의 호출을 피해야 합니다

4

wait()는 호출된 라인에 대해 모니터를 포기하고 휴면 상태에 들어갈 때까지 다른 라인이 같은 모니터에 들어갈 때와 notify()를 호출하도록 알려준다

4

notify () 가 같은 대상에서 첫 번째wait () 를 호출하는 라인을 깨웁니다

2. notify()와wait() - 예1

public class ThreadA {
    public static void main(String[] args){
        ThreadB b = new ThreadB();
        b.start();
 
        synchronized(b){
            try{
                System.out.println("Waiting for b to complete...");
                b.wait();
            }catch(InterruptedException e){
                e.printStackTrace();
            }
 
            System.out.println("Total is: " + b.total);
        }
    }
}
 
class ThreadB extends Thread{
    int total;
    @Override
    public void run(){
        synchronized(this){
            for(int i=0; i<100 ; i++){
                total += i;
            }
            notify();
        }
    }
}

위의 예에서 하나의 대상 b가 동기화되었다.main 라인이 출력되기 전에 b 라인이 계산을 끝냅니다.출력:

Waiting for b to complete...
Total is: 4950

만약 b 라인이 아래와 같이 동기화되지 않았다면:

public class ThreadA {
    public static void main(String[] args) {
        ThreadB b = new ThreadB();
        b.start();
 
        System.out.println("Total is: " + b.total);
 
    }
}
 
class ThreadB extends Thread {
    int total;
 
    @Override
    public void run() {
        for (int i = 0; i < 100; i++) {
            total += i;
        }
    }
}

결과는 0 또는 10, 또는 다른 것일 수 있습니다.sum가 사용되기 전에 계산이 완료되지 않았기 때문입니다.

3.notify()와wait() - 예2

두 번째 예는 더욱 복잡하다. 아래의 주석을 보아라.

import java.util.Vector;
 
class Producer extends Thread {
 
    static final int MAXQUEUE = 5;
    private Vector messages = new Vector();
 
    @Override
    public void run() {
        try {
            while (true) {
                putMessage();
                //sleep(5000);
            }
        } catch (InterruptedException e) {
        }
    }
 
    private synchronized void putMessage() throws InterruptedException {
        while (messages.size() == MAXQUEUE) {
            wait();
        }
        messages.addElement(new java.util.Date().toString());
        System.out.println("put message");
        notify();
        //Later, when the necessary event happens, the thread that is running it calls notify() from a block synchronized on the same object.
    }
 
    // Called by Consumer
    public synchronized String getMessage() throws InterruptedException {
        notify();
        while (messages.size() == 0) {
            wait();//By executing wait() from a synchronized block, a thread gives up its hold on the lock and goes to sleep.
        }
        String message = (String) messages.firstElement();
        messages.removeElement(message);
        return message;
    }
}
 
class Consumer extends Thread {
 
    Producer producer;
 
    Consumer(Producer p) {
        producer = p;
    }
 
    @Override
    public void run() {
        try {
            while (true) {
                String message = producer.getMessage();
                System.out.println("Got message: " + message);
                //sleep(200);
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
 
    public static void main(String args[]) {
        Producer producer = new Producer();
        producer.start();
        new Consumer(producer).start();
    }
}

가능한 출력 시퀀스:

Got message: Fri Dec 02 21:37:21 EST 2011
put message
put message
put message
put message
put message
Got message: Fri Dec 02 21:37:21 EST 2011
Got message: Fri Dec 02 21:37:21 EST 2011
Got message: Fri Dec 02 21:37:21 EST 2011
Got message: Fri Dec 02 21:37:21 EST 2011
Got message: Fri Dec 02 21:37:21 EST 2011
put message
put message
put message
put message
put message
Got message: Fri Dec 02 21:37:21 EST 2011
Got message: Fri Dec 02 21:37:21 EST 2011
Got message: Fri Dec 02 21:37:21 EST 2011