Lock&Condition

2019-08-26  本文已影响0人  圆滚滚_8e70
Lock lock = new ReentrantLock();
Conditon notFull = lock.newCondition();

从上面的代码,我们可以一眼就看出所谓的"条件",就是Lock的条件。你可以理解为Lock的成员变量(你可以姑且这么认为)。有了以上基础以后,我们再来看一下下面这段代码:

import java.util.Queue;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class MyBlockedQueue<T> {

    final Lock lock = new ReentrantLock();

    final Condition notFull = lock.newCondition();

    final Condition notEmpty = lock.newCondition();

    private Queue queue = new ArrayBlockingQueue(5);

    void enq(T e){
        lock.lock();
        try {
            while (queue.size() == 5){
                notFull.await();
            }
            // TODO: 2019/8/26 do something for enque
            notEmpty.signal();
        }catch (InterruptedException ex) {
            ex.printStackTrace();
        } finally {
            lock.unlock();
        }
    }

    void denq(){
        lock.lock();
        try {
            while (!queue.isEmpty()){
                notEmpty.await();
            }
            // TODO: 2019/8/26 do something for denque
            notFull.signal();
        }catch (InterruptedException ex){
            ex.printStackTrace();
        } finally {
            lock.unlock();
        }
    }
}

代码理解:
上面的代码定义了enq和denq俩个方法,这俩个方法是互斥的,所以声明了一个变量lock。lock是一个可重入锁(关于可重入锁,后续会讲到详细当内容)。lock锁有俩个条件(成员变量)notFull和notEmpty。
线程A执行enq方法时,先获取锁,然后判断队列是否是满的,如果是满的,则等待deq方法被执行;随后,当线程A执行denq()方法时,获取锁,然后发现队列并不是空的,可以执行deq业务逻辑,然后唤起其他等待notFull的线程。这个时候线程A的enq方法发现,queue.size()==5的条件不满足了,执行enq业务逻辑。
当其他线程想要同时执行该对象当enq方法时,因为获取不到锁,所以会产生线程阻塞。

上一篇 下一篇

猜你喜欢

热点阅读