隨筆-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 朔望魔刃 閱讀(236) 評論(0)  編輯  收藏  所屬分類: java 
          

          







          
	    
    




          








          

				

          







    







          
        
	




主站蜘蛛池模板：
衡东县|
会同县|
简阳市|
文昌市|
灌南县|
六枝特区|
邻水|
巴东县|
侯马市|
贺兰县|
黄陵县|
双桥区|
永顺县|
休宁县|
侯马市|
东安县|
凌海市|
加查县|
永春县|
通道|
西华县|
库伦旗|
宁海县|
永吉县|
辽阳市|
阿鲁科尔沁旗|
安国市|
册亨县|
乐东|
达拉特旗|
政和县|
德庆县|
收藏|
民丰县|
台东县|
噶尔县|
峨眉山市|
商城县|
新建县|
静安区|
新津县|