阻塞队列

package unit;

import java.util.concurrent.ArrayBlockingQueue;

/**
 * 阻塞队列
 * @author 54304
 *
 */
public class BlockingQueue {
    private int queueSize = 10;
    private ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<Integer>(queueSize);
    int m = 0;
    int n = 0;
    int k = 0;
    public static void main(String[] args) throws InterruptedException  {
        BlockingQueue test = new BlockingQueue();
        Producer producer = test.new Producer();
        Consumer consumer = test.new Consumer();
        
        producer.start();
        consumer.start();
    }
     
    class Consumer extends Thread{
         
        @Override
        public void run() {
            consume();
        }
         
        private void consume() {
            while(true){
                try {
                    queue.take();
                    Thread.sleep(1000);
                    System.out.println("队列有： "+queue.size()+" 个 元素"+"  编号"+ ++m + " 减少"+ "   减少次数："+ ++n);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
     
    class Producer extends Thread{
         
        @Override
        public void run() {
            produce();
        }
         
        private void produce() {
            for(int i=0; i<10; i++){
                try {
                    queue.put(1);
                    Thread.sleep(1000);
                    System.out.println("队列有： "+queue.size()+" 个 元素"+"  编号"+ ++m + " 添加"+ "   添加次数："+ ++k);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}