码迷,mamicode.com
首页 > 编程语言 > 详细

JAVA实现阻塞队列

时间:2018-07-17 19:29:22      阅读:155      评论:0      收藏:0      [点我收藏+]

标签:pack   port   ace   ==   void   util   not   new   ati   

package 多线程并发;

import java.util.Stack;

/**
 * Created by z84102272 on 2018/7/17.
 */
public class BlockQueueImpl {
    private final static Object pushLock = new Object();  //push的锁
    private final static Object popLock = new Object();  //pop的锁
    private Stack<Object> stack;    //存储数据

    public BlockQueueImpl(){
        stack = new Stack<>();
    }

    /**
     * push锁
     */
    private void pushLock(){
        synchronized (pushLock){
            try{
                pushLock.wait();
            }catch (Exception e){
                e.printStackTrace();
            }
        }
    }

    /**
     * 释放push锁
     */
    private void pushUnlock(){
        pushLock.notify();
    }

    private void popLock(){
        try {
            popLock.wait();
        }catch (Exception e){
            e.printStackTrace();
        }
    }

    private void popUnlock(){
        popLock.notify();
    }

    public synchronized void push(Object o){
        int MAX_SIZE = 3;
        if (stack.size() >= MAX_SIZE){
            pushLock();
        }
        stack.push(o);
        popUnlock();
    }
    
    public Object pop(){
        if (stack.size()==0){
            popLock();
        }
        Object o  = stack.pop();
        pushUnlock();
        return o;
    }
    

}

  

JAVA实现阻塞队列

标签:pack   port   ace   ==   void   util   not   new   ati   

原文地址:https://www.cnblogs.com/zyfzyfzyf/p/9324778.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!