代碼:
package com.sdkd.hms;import javax.naming.Context;import java.util.ArrayList;import java.util.Stack;/** * Created by hms on 2017/2/15. */public class WakeOrSleep { public static final int N = 10; public static int count = 0; public static Stack<Integer> stack = new Stack(); public static void main(String[] args) { PRoducer producer = new Producer(); Consumer consumer = new Consumer(); producer.start(); consumer.start(); }}class Producer extends Thread{ @Override public void run() { while (true) { int item = (int)(Math.random() * 100); if(WakeOrSleep.count == WakeOrSleep.N) { System.out.println("緩沖區已經滿了,等待消費者喚醒"); try { synchronized (WakeOrSleep.stack) { WakeOrSleep.stack.wait(); } } catch (InterruptedException e) { e.printStackTrace(); } } WakeOrSleep.stack.push(item); System.out.println("緩沖區添加了數據項 " + item); WakeOrSleep.count += 1; if(WakeOrSleep.count == 1){ synchronized (WakeOrSleep.stack) { WakeOrSleep.stack.notify(); } } } }}class Consumer extends Thread{ @Override public void run() { while (true) { if(WakeOrSleep.count == 0){ try { System.out.println("緩沖區已空,等待生產者喚醒"); synchronized (WakeOrSleep.stack) { WakeOrSleep.stack.wait(); } } catch (InterruptedException e) { e.printStackTrace(); } } int item = WakeOrSleep.stack.pop(); WakeOrSleep.count -= 1; if(WakeOrSleep.count == WakeOrSleep.N - 1) { synchronized (WakeOrSleep.stack) { WakeOrSleep.stack.notify(); } } System.out.println("緩沖區中消費了 " + item); } }}/**緩沖區已空,等待生產者喚醒緩沖區添加了數據項 45緩沖區中消費了 45緩沖區已空,等待生產者喚醒緩沖區添加了數據項 47緩沖區中消費了 47緩沖區已空,等待生產者喚醒緩沖區添加了數據項 84緩沖區添加了數據項 59緩沖區添加了數據項 81...*/新聞熱點
疑難解答