编程实现：线程A向队列Q中不停写入数据，线程B从队列Q中不停读取数据（只要Q中有数据）。

接口中有两个一个是向队列中写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) // 1

{

try {

wait();

} catch (InterruptedException e) {

// 忽略 //2

}

}

values[top] = n;

System.out.println(“压入数字” + n + “步骤1完成”);

top++;

dataAvailable = true;

notifyAll();

System.out.println(“压入数字完成”);

}

}

public int[] pop() {

synchronized (this) {

while (!dataAvailable) // 3

{

try {

wait();

} catch (InterruptedException e) {

// 忽略 //4

}

}

System.out.print(“弹出”);

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){}

}

}

}







不一定对，如果不对，请见谅。
这个版主肯定会的啊，楼上哥们幽默了。。。

韩冬 发表于 2013-4-27 00:03
接口中有两个一个是向队列中写push方法 一个是从队列中读。

public interface StackInterface

呵呵... 给版主开个玩笑 .

1. //接口中有两个 一个是向队列中写push方法  一个是从队列中读
   
2. public interface StackInterface {
   
3.     public void push(int n);
   
4. 
   
5.     public int[] pop();
   
6. }
   
7. 
   
8. // 上边接口的实现类。
   
9. public class SafeStack implements StackInterface {
   
10.     private int top = 0;
    
11.     private int[] values = new int[10];
    
12.     private boolean dataAvailable = false;
    
13. 
    
14.     public void push(int n) {
    
15.         synchronized (this) {
    
16.             while (dataAvailable) {
    
17.                 try {
    
18.                     wait();
    
19.                 } catch (InterruptedException e) {
    
20. 
    
21.                 }
    
22.             }
    
23.             values[top] = n;
    
24.             System.out.println("压入数字" + n + "步骤1完成");
    
25.             top++;
    
26.             dataAvailable = true;
    
27.             notifyAll();
    
28.             System.out.println("压入数字完成");
    
29.         }
    
30.     }
    
31. 
    
32.     public int[] pop() {
    
33.         synchronized (this) {
    
34.             while (!dataAvailable) {
    
35.                 try {
    
36.                     wait();
    
37.                 } catch (InterruptedException e) {
    
38. 
    
39.                 }
    
40.             }
    
41.             System.out.println("弹出");
    
42.             top--;
    
43.             int[] test = {values[top],top};
    
44.             dataAvailable = false;
    
45.             //唤醒正在等待压入数据的线程
    
46.             notifyAll();
    
47.             return test;
    
48.         }
    
49.     }
    
50. }
    
51. //读线程
    
52. public class PopThread implements Runnable{
    
53.     private StackInterface s;
    
54.     public PopThread(StackInterface s){
    
55.         this.s = s;
    
56.     }
    
57.     public void run(){
    
58.         while(true){
    
59.             System.out.println("-->"+s.pop()[0]+"<--");
    
60.             try{Thread.sleep(100);
    
61.             }catch(InterruptedException e){
    
62.                
    
63.             }
    
64.         }
    
65.     }
    
66. }
    
67. //写线程
    
68. public class PushThread implements Runnable{
    
69.     private StackInterface s;
    
70.     public PushThread(StackInterface s){
    
71.         this.s = s;
    
72.     }
    
73.     public void run(){
    
74.         int i = 0;
    
75.         while(true){
    
76.             java.util.Random r = new java.util.Random();
    
77.             i = r.nextInt(10);
    
78.             s.push(i);
    
79.             try{
    
80.                 Thread.sleep(100);
    
81.             }catch(InterruptedException e){}
    
82.         }
    
83.     }
    
84. }
    

复制代码

详情请参阅http://blog.sina.com.cn/s/blog_a3d2346f0101564t.html

这哥们在玩火

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){}
        }
    }
}

孙百鑫 发表于 2013-4-27 00:10
这哥们在玩火

呵呵 ...

都这么给力呢

多谢楼上的哥们解答 我尝试下 ..谢谢

版主应该做做的，做出来了就不给他加分。

张熙韬 发表于 2013-4-27 09:23
哥们,你知不知道你这标题,额,弄的我有想做的冲动呢!
给力啊!
哈哈,最近事情比较多,比较繁琐,改日有空一定和 ...

哈哈，张版主是禽兽，这个可以会

陈雨 发表于 2013-4-27 09:32
版主应该做做的，做出来了就不给他加分。

这个建议好，直接没时间看帖了

楼主你好，如果问题你已经整明白了，就把帖子的类型改为“已解决”{:soso_e181:}

袁梦希 发表于 2013-4-27 10:44
楼主你好，如果问题你已经整明白了，就把帖子的类型改为“已解决” ...

已经修改了..不好意思 新手. 给各位版主添麻烦了

曹睿翔 发表于 2013-4-27 10:02
这个建议好，直接没时间看帖了

嘿嘿..让版主郁闷了 :lol

张熙韬 发表于 2013-4-27 09:23
哥们,你知不知道你这标题,额,弄的我有想做的冲动呢!
给力啊!
哈哈,最近事情比较多,比较繁琐,改日有空一定和 ...

呵呵  多谢给为版主....