Monitor모니터

모니터 = 공유 데이터
       + 진입 잠금 (Mutex)
       + 조건 변수 (Condition Variable) 집합
       + 내부 프로시저들

class BoundedBuffer {
    private int[] buf = new int[10];
    private int count = 0, in = 0, out = 0;

    public synchronized void put(int val) throws InterruptedException {
        while (count == buf.length)
            wait();          // 잠금 해제 + 대기
        buf[in] = val;
        in = (in + 1) % buf.length;
        count++;
        notifyAll();         // 대기 중인 스레드 깨우기
    }

    public synchronized int get() throws InterruptedException {
        while (count == 0)
            wait();
        int val = buf[out];
        out = (out + 1) % buf.length;
        count--;
        notifyAll();
        return val;
    }
}

import threading

lock = threading.Lock()
not_empty = threading.Condition(lock)
buffer = []

def producer():
    with not_empty:
        buffer.append(1)
        not_empty.notify()  # 대기 중인 소비자 깨움

def consumer():
    with not_empty:
        while not buffer:
            not_empty.wait()  # 빈 경우 대기 (잠금 임시 해제)
        return buffer.pop()