생산자 코드에 notifyAll()을 추가해서 풀에서 대기중인 소비자 쓰레드에게 통보하여 다시 소비를 시작하게 한다.
class Store {
public int bread; // 생산자, 소비자가 공유할 데이터
public static void main(String[] args) {
Store store = new Store();
new Producer(store).start();
new Consumer(store).start();
}
}
class Producer extends Thread {
Store store;
Producer(Store store){
this.store = store;
}
public void run() {
while(true) {
synchronized(store) {
if(store.bread<20) {
store.bread++;
System.out.println("생산==>"+store.bread);
try{
Thread.sleep(400);
}catch(InterruptedException ie){}
}else {
store.notifyAll();
}
} // synchronized 끝
}
}
}
class Consumer extends Thread {
Store store;
Consumer(Store store) {
this.store = store;
}
public void run() {
while(true) {
synchronized(store) {
while(store.bread<=10) {
try{
store.wait(); // 통지가 전달될 때까지 Wait Pool에서 대기하게 한다.
}catch(InterruptedException ie){}
}
store.bread--;
System.out.println("소비==>"+store.bread);
try{
Thread.sleep(500);
}catch(InterruptedException ie){}
} // synchronized 끝
}
}
}