Handwriting blocking queue: condition + lock

Don't talk much , Go straight to the code

public class BlockingQueue<T> {
    private final ArrayDeque<T> blockingQueue;    
    private int capacity;    // The maximum length allowed for the queue 
    private final Condition notFull;
    private final Condition notEmpty;
    Lock lock = new ReentrantLock();
    public BlockingQueue(int capacity) {
        notEmpty = lock.newCondition();
        notFull = lock.newCondition();
        this.capacity = capacity;
        blockingQueue = new ArrayDeque<>(capacity);
    }
    public void insert(T t){    // Method of inserting task 
        lock.lock();
        try {
            while (blockingQueue.size() == capacity){
                notFull.await();
                blockingQueue.add(t);
                notEmpty.signal();
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }finally{
            lock.unlock();
        }
    }
    public T remove() throws InterruptedException {    // Method of getting task 
        try {    
            while(blockingQueue.size() == 0){
                notEmpty.await();
            }
            T t = blockingQueue.remove();
            notFull.signal();
            return t;
        } finally{
            lock.unlock();
        }                                          
    }

}

Keep early hours , take care ; The king of early rising wishes you a thousand miles a day ！