//接口中有兩個 一個是向隊列中寫push方法??一個是從隊列中讀

public interface StackInterface {public void push(int n);public int[] pop(); }

// 上邊接口的實現類。

public class SafeStack implements StackInterface?{private int top = 0;private int[] values = new int[10];private boolean dataAvailable = false;public void push(int n) {synchronized (this) {while (dataAvailable) {try {wait();} catch (InterruptedException e) {}}values[top] = n;System.out.println("壓入數字" + n + "步驟1完成");top++;dataAvailable = true;notifyAll();System.out.println("壓入數字完成");}}public int[] pop() {synchronized (this) {while (!dataAvailable) {try {wait();} catch (InterruptedException e) {}}System.out.println("彈出");top--;int[] test = {values[top],top};dataAvailable = false;//喚醒正在等待壓入數據的線程notifyAll();return test;}} }

//讀線程

public class PopThread implements Runnable{private StackInterface s;public PopThread(StackInterface s){this.s = s;}public void run(){while(true){System.out.println("-->"+s.pop()[0]+"<--");try{Thread.sleep(100);}catch(InterruptedException e){}}} }

//寫線程
?

public class PushThread implements Runnable{private StackInterface s;public PushThread(StackInterface s){this.s = s;}public void run(){int i = 0;while(true){java.util.Random r = new java.util.Random();i = r.nextInt(10);s.push(i);try{Thread.sleep(100);}catch(InterruptedException e){}}} }

?

總結

以上是生活随笔為你收集整理的线程A向队列Q中不停写入数据，线程B从列队Q中不停读取数据（只要Q中有数据）。的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。