随笔-95  评论-31  文章-10  trackbacks-0
 1public class MyStack {
 2    private int[] a;
 3    private int count = 0;
 4    public final int MAX_SIZE;
 5
 6    public MyStack(int size) {
 7        MAX_SIZE = size;
 8        a = new int[size];
 9        count = 0;
10    }

11
12    public synchronized void push() {
13         while(count==MAX_SIZE){//这里用while而不是if因为当被唤醒时,该线程处于锁池等待获取锁,这个时候可能会有别的该线改变数组的大小。所以唤醒时继续检查数组是否已满。
14             try {
15                this.wait(); //释放掉当前的对象锁,在等待池等待
16            }
 catch (InterruptedException e) {
17                e.printStackTrace();
18            }

19         }

20         a[count++]=count;
21         System.out.println(Thread.currentThread().getName()+"压入数据:"+count);
22         this.notify();  //唤醒生产者消费者线程
23    }

24
25    public synchronized int pop() {
26             while(count ==0){
27                 try {
28                    this.wait();
29                }
 catch (InterruptedException e) {
30                    e.printStackTrace();
31                }

32             }

33             this.notify();
34             System.out.println(Thread.currentThread().getName()+"弹出数据:"+count);
35             return a[--count];
36     }

37}

38/**
39 *生产者
40 **/

41public class Producer extends Thread {
42
43    private MyStack stack;
44    
45    public Producer(MyStack stack){
46        this.stack = stack;
47    }

48    @Override
49    public void run() {
50        while (true{
51            stack.push();
52            try {
53                Thread.sleep(200);
54            }
 catch (InterruptedException e) {
55                e.printStackTrace();
56            }

57        }

58    }

59}

60/**
61 *消费者
62 **/

63public class Consumer extends Thread{
64             
65    private MyStack stack;
66    
67    public Consumer(MyStack stack){
68        this.stack = stack;
69    }

70    
71    @Override
72    public void run() {
73        while(true){
74            stack.pop();
75            try {
76                Thread.sleep(300);
77            }
 catch (InterruptedException e) {
78                e.printStackTrace();
79            }

80        }

81    }

82}

线程状态图
posted on 2010-08-19 10:19 朔望魔刃 阅读(209) 评论(0)  编辑  收藏 所属分类: java

只有注册用户登录后才能发表评论。


网站导航: