IT실전교육,탑크리에듀교육센터: [JAVA THREAD,자바스레드교육,쓰레드wait]자바쓰레드 wait, notify, synchronized

2013년 12월 29일 일요일

[JAVA THREAD,자바스레드교육,쓰레드wait]자바쓰레드 wait, notify, synchronized

[JAVA THREAD,자바스레드교육,쓰레드wait]자바쓰레드 wait, notify, synchronized예제

class SharedData
{
private boolean isNew = false;
private int data;

    public synchronized void put(int data)
    {
        try {
            while( isNew )   // new data?
                wait();      // unlocked
        } catch(InterruptedException e ) {}
        this.data = data;
        isNew = true;
        notifyAll();
    }

    public synchronized int get()
    {
        try {
            while( !isNew )   // already got?
                wait();       // unlocked
        } catch(InterruptedException e ) {}
        isNew = false;
        notifyAll();          // waiting threads cannot wake up
        return data;          //    until this method exits
    }
}

class Writer extends Thread
{
private SharedData shared;
private int data;

    public Writer(SharedData shared, int data) {
        this.shared = shared;
        this.data = data;
    }
    public void run() {
        shared.put(data);
        shared.put(data+1);
    }
}

class Reader extends Thread
{
SharedData shared;

    public Reader(SharedData shared) {
        this.shared = shared;
    }
    public void run() {
        while(true)
            System.out.println( getName() + " got " + shared.get() );
    }
}

class Wait
{
    public static void main(String[] args)
    {
        SharedData shared = new SharedData();
        Reader r1 = new Reader(shared);
        Reader r2 = new Reader(shared);
        Writer w1 = new Writer(shared, 10);
        Writer w2 = new Writer(shared, 20);

        r1.start();
        r2.start();
        w1.start();
        w2.start();
    }
}

[출처] 오라클자바커뮤니티 - http://www.oraclejavanew.kr/bbs/board.php?bo_table=LecJava&wr_id=658