Lock&Condition

  • WHO ?
    我是一个普通当程序员,目前正在学习java并发编程,为学习netty做准备。
  • WHAT & WHEN ?
    主题呢,和标题一样理解一下Java中当Lock & Condition
  • Why ?
    写这篇文章,主要是讲解一下Lock和Condition。同时呢,给一些和我一样在学习java并发编程当同学提供一些参考。我在学习Lock和Condition的时候,觉得很迷茫。看别人的博客什么的都能看的懂,但是自己写的时候就各种错误。
  • How ?
    直接步入正题:
    Lock顾名思义就是锁的意思。
    Condition翻译过来就是"条件"的意思。那么Condition是谁的条件呢?看一下Condition是怎么创建的就知道了。
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方法时,因为获取不到锁,所以会产生线程阻塞。

  • Q&A
    Q1:为什么使用await()signal(),不使用wait()notify()?
    A1:这里涉及到java sdk俩套并发设计。使用LockCondition的话只能配套使用await()signal();wait()notify()是配合synchronized使用。如果混用,那么你的程序会出各种问题。
    有其他问题,可以关注公众号‘麻油地’,留言,我会及时进行回复,解答。
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容