[완료] 자바 스레드 공부하는 도중에 막힌 소스인데 좀 봐주세요

class Producer extends Thread 
{ 
    public void run() 
    { 
        for(int i=0; i<10; i++) 
        { 
            Buffer.put(i); 

            System.out.println("생산자 : 생산 " + i); 
            try 
            { 
                sleep((int)(Math.random() * 100)); 
            } 
            catch(Exception e) 
            { 
                e.printStackTrace(); 
            } 
        } 
    } 
} 

class Consumer extends Thread 
{ 
    public void run() 
    { 
        int value = 0; 
        for(int i=0; i<10; i++) 
        { 
            value = Buffer.get(); 

            System.out.println("소비자 : 소비 " + value); 
        } 
    } 
} 

class Buffer 
{ 
    static private int contents; 
    static private boolean available = false; 
    //flag 역할을 하는 available 변수의 초기 값을 false로 설정 
    //처음에는 생산자가 먼저 데이터를 가져다 놓아야 한다 

    static public synchronized int get() 
    { 
        if(available == false) 
        { 
            try 
            { 
                Buffer.class.wait(); 
            } 
            catch(Exception e) 
            { 
                e.printStackTrace(); 
            } 
        } 

        available = false; 
        Buffer.class.notifyAll(); 
        return contents; 
    } 

    static public synchronized void put(int value) 
    { 
        if(available == true) 
        { 
            try 
            { 
            	Buffer.class.wait();
            } 
            catch(Exception e) 
            { 
                e.printStackTrace(); 
            } 
        } 

        contents = value; 
        available = true; 
        Buffer.class.notifyAll(); 
    } 
} 

public class ProducerConsumer 
{ 
    public static void main(String args[]) 
    { 
        Producer p1 = new Producer(); 
        Consumer c1 = new Consumer(); 

        p1.start(); 
        c1.start(); 
    } 
} 

여기서 모니터에 사용되는 객체는 Buffer가 되야겠죠. 즉, 버퍼에는 하나의 쓰레드만 들어갈 수 있게요.

그러려면

static public synchronized ... (...)

메소드를 쓰신 부분은 맞고요. 이 경우 Buffer 클래스에대한 락이 걸리죠. 그리고 구체적으로는 Buffer.class 라는 '클래스 인스턴스'에 대한 락이 걸립니다. (여기서 abc.class 는 abc라는 클래스를 설명하는 java.lang.Class 라는 클래스에대한 인스턴스입니다.)

그리고 wait는 역시 버퍼라는 클래스 전체에 걸리는 것이니 Buffer.class.wait 이구요. 락을 풀때도 Buffer.class.notifyAll 입니다.

Thread.currentThread().notifyAll 은 현재 쓰레드에 대해서 notify 한다는 것인데, 잘 보시면 Producer와 Consumer는 '서로다른' 쓰레드이죠. 그리고 서로다른 쓰레드가 각자 자신에게 락을 걸고 자신의 락을 푼다면 서로 상대를 제어할 수 없죠.

'공유되는 자원'자체에 대해서 lock걸고 wait하고 notify 하는 것이 바른 방법입니다.