AI 助理
备案控制台
开发者社区 安全 文章 正文

java 并发多线程显式锁概念简介 什么是显式锁 多线程下篇（一）

2019-03-06 1358
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： java 并发多线程显式锁概念简介 什么是显式锁 多线程下篇（一） 目前对于同步，仅仅介绍了一个关键字synchronized，可以用于保证线程同步的原子性、可见性、有序性 对于synchronized关键字，对于静态方法默认是以该类的class对象作为锁，对于实例方法默认是当前对象this，对于.

java 并发多线程显式锁概念简介 什么是显式锁 多线程下篇（一）

目前对于同步，仅仅介绍了一个关键字synchronized，可以用于保证线程同步的原子性、可见性、有序性
对于synchronized关键字，对于静态方法默认是以该类的class对象作为锁，对于实例方法默认是当前对象this，对于同步代码块，需要指定锁对象
对于整个同步方法或者代码块，不再需要显式的进行加锁，默认这一整个范围都是在锁范围内
可以理解为，隐含的在代码开始和结尾处，进行了隐式的加锁和解锁
所以synchronized又被称为隐式锁
对于synchronized关键字的隐式锁，不需要显式的加锁和释放，即使出现了问题，仍旧能够对锁进行释放
synchronized是一种阻塞式的，在前面也提到过，对于synchronized修饰的同步，如果无法进入监视器则是BLOCKED状态，无疑，性能方面可想而知
而且，这种隐式锁，在同一个代码片段内只有一个监视器，灵活性不够
 
为了优化synchronized的一些不便，Java又提出来了显式锁的概念Lock
顾名思义，显式，是相对隐式来说的，也就是对于加锁和解锁，需要明确的给出，而不会自动的进行处理

示例回顾

回忆下是之前《多线程协作wait、notify、notifyAll方法简介理解使用 》一文中使用的例子
ps:下面的例子是优化过的，其中if判断换成了while 循环检测，notify换成了notifyAll
复制代码 
package test1;
import java.util.LinkedList;
/**
* 消息队列MessageQueue 测试
*/
public class T14 {
public static void main(String[] args) {
final RefactorMessageQueue mq = new RefactorMessageQueue(5);
System.out.println("***************task begin***************");
//创建生产者线程并启动
for (int i = 0; i < 20; i++) {
new Thread(() -> {
while (true) {
mq.set(new Message());
}
}, "producer"+i).start();
}
//创建消费者线程并启动
new Thread(() -> {
while (true) {
mq.get();
}
}, "consumer").start();
}
}
/**
* 消息队列
*/
class RefactorMessageQueue {
/**
* 队列最大值
*/
private final int max;
/*
* 锁
* */
private final byte[] lock = new byte[1];
/**
* final确保发布安全
*/
final LinkedList<Message> messageQueue = new LinkedList<>();
/**
* 构造函数默认队列大小为10
*/
public RefactorMessageQueue() {
max = 10;
}
/**
* 构造函数设置队列大小
*/
public RefactorMessageQueue(int x) {
max = x;
}
public void set(Message message) {
synchronized (lock) {
//如果已经大于队列个数，队列满，进入等待
while (messageQueue.size() > max) {
try {
System.out.println(Thread.currentThread().getName() + " : queue is full ,waiting...");
lock.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
//如果队列未满，生产消息，随后通知lock上的等待线程
//每一次的消息生产，都会通知消费者
System.out.println(Thread.currentThread().getName() + " : add a message");
messageQueue.addLast(message);
lock.notifyAll();
}
}
public void get() {
synchronized (lock) {
//如果队列为空，进入等待，无法获取消息
while (messageQueue.isEmpty()) {
try {
System.out.println(Thread.currentThread().getName() + " : queue is empty ,waiting...");
lock.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
//队列非空时，读取消息，随后通知lock上的等待线程
//每一次的消息读取，都会通知生产者
System.out.println(Thread.currentThread().getName() + " : get a message");
messageQueue.removeFirst();
lock.notifyAll();
}
}
}
复制代码
分析下这个示例中的一些概念
使用了synchronized用作同步，锁对象为  private final byte[] lock = new byte[1];
有多个生产者和一个消费者，为了进行通信使用了监视器（也就是锁对象）的wait和notifyAll方法进行通信
ps：前文也说过为何要用notifyAll而不是notify
简单说两个点：
  • synchronized关键字
  • 监视器方法
借助于这两个点，可以完成多线程之间的协作与通信（多个生产者一个消费者）
监视器方法的调用需要在监视器内，也就是同步方法内
而且上面的例子中的监视器都是同一个就是锁对象，wait是当前线程在监视器上wait，notifyAll方法则是唤醒所有在此监视器上等待的线程
很显然，其实生产者应该唤醒生产者，消费者应该唤醒消费者
可是，多线程协作使用的是同一个队列，所以需要使用同一把锁
又因为监视器方法必须在同步方法内而且也必须是持有监视器才能调用相应的监视器方法，所以只能使用同一个监视器了
也就是只能将这些线程组织在同一个监视器中，就不好做到“其实生产者应该唤醒生产者，消费者应该唤醒消费者”

显式锁逻辑

再回过头看显式锁，他是如何做到各方面灵活的呢？
从上面的分析来看主要就是因为隐式锁与监视器之间的比较强的关联关系
synchronized修饰的代码片段使用的是同一把锁，同步方法内的监视器方法也只能调用这个锁的，也就是说在使用上来看，用什么锁，就要用这个锁的监视器，强关联
问题的一种解题思路就是解耦，显式锁就是这种思路 
Lock就好比是synchronized关键字，只不过你需要显式的进行加锁和解锁
惯用套路如下
复制代码 
Lock l = ...;
l.lock();
try {
// access the resource protected by this lock
} finally {
l.unlock();
}
复制代码
本来使用synchronized隐式的加锁和解锁，换成了Lock的lock和unlock方法调用
那么监视器呢？
与锁关联的监视器又是什么，又如何调用监视器的方法呢？
Lock提供了Condition newCondition();方法
返回类型为Condition，被称之为条件变量，可以认为是锁关联的监视器
借助于Condition，就可以达到原来监视器方法调用的效果，Condition方法列表如下，看得出来，是不是很像wait和notify、notifyAll？目标是一致的
image_5c7dcac8_2722
所以可以说，显式锁的逻辑就是借助于Lock接口以及Condition接口，实现了对synchronized关键字以及锁对应的监视器的另外的一种实现
从而提供了更大的灵活性
还是之前的示例，尝试试用一下显式锁
复制代码 
package test2;
import java.util.LinkedList;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class T26 {
public static void main(String[] args) {
final RefactorMessageQueue mq = new RefactorMessageQueue(5);
System.out.println("***************task begin***************");
//创建生产者线程并启动
for (int i = 0; i < 20; i++) {
new Thread(() -> {
while (true) {
mq.set(new Message());
}
}, "producer" + i).start();
}
//创建消费者线程并启动
new Thread(() -> {
while (true) {
mq.get();
}
}, "consumer").start();
}
/**
* 消息队列中存储的消息
*/
static class Message {
}
/**
* 消息队列
*/
static class RefactorMessageQueue {
/**
* 队列最大值
*/
private final int max;
/*
* 锁
* */
private final Lock lock = new ReentrantLock();
/**
* 条件变量
*/
private final Condition condition = lock.newCondition();
/**
* final确保发布安全
*/
final LinkedList<Message> messageQueue = new LinkedList<>();
/**
* 构造函数默认队列大小为10
*/
public RefactorMessageQueue() {
max = 10;
}
/**
* 构造函数设置队列大小
*/
public RefactorMessageQueue(int x) {
max = x;
}
public void set(Message message) {
lock.lock();
try {
//如果已经大于队列个数，队列满，进入等待
while (messageQueue.size() > max) {
try {
System.out.println(Thread.currentThread().getName() + " : queue is full ,waiting...");
condition.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
//如果队列未满，生产消息，随后通知lock上的等待线程
//每一次的消息生产，都会通知消费者
System.out.println(Thread.currentThread().getName() + " : add a message");
messageQueue.addLast(message);
condition.signalAll();
} finally {
}
lock.unlock();
}
public void get() {
lock.lock();
try {
//如果队列为空，进入等待，无法获取消息
while (messageQueue.isEmpty()) {
try {
System.out.println(Thread.currentThread().getName() + " : queue is empty ,waiting...");
condition.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
//队列非空时，读取消息，随后通知lock上的等待线程
//每一次的消息读取，都会通知生产者
System.out.println(Thread.currentThread().getName() + " : get a message");
messageQueue.removeFirst();
condition.signalAll();
} finally {
lock.unlock();
}
}
}
}
复制代码
改变的核心逻辑就是锁和条件变量
复制代码 
/*
* 锁
* */
private final Lock lock = new ReentrantLock();
/**
* 条件变量
*/
private final Condition condition = lock.newCondition();
复制代码
  • 使用lock.lock();以及lock.unlock(); 替代了synchronized（lock）
  • 使用condition的await和signalAll方法替代了lock.wait()和   lock.notifyAll
看起来与使用synchronized关键字好像差不多，这没什么毛病
显式锁的设计本来就是为了弥补隐式锁的，虽说不是说作为一种替代品，但是功能逻辑的相似性是必然的
注意到，使用条件变量，与隐式锁中都是只有一个监视器，所有的线程仍旧都是被唤醒
前面提到过，其实生产者应该唤醒消费者，消费者才应该唤醒生产者
是不是可以两个变量？
对于生产者来说，只要非满即可，如果满了等待，非满生产然后唤醒消费者
对于消费者来说，只要非空即可，如果空了等待，非空消费然后唤醒生产者
 
可以定义两个条件变量，如下所示完整代码
其实只是定义了两个监视器
复制代码 
package test2;
import java.util.LinkedList;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class T27 {
  public static void main(String[] args) {
    final RefactorMessageQueue mq = new RefactorMessageQueue(5);
    System.out.println("***************task begin***************");
    //创建生产者线程并启动
    for (int i = 0; i < 20; i++) {
      new Thread(() -> {
        while (true) {
          mq.set(new Message());
        }
      }, "producer" + i).start();
    }
    //创建消费者线程并启动
    new Thread(() -> {
      while (true) {
        mq.get();
      }
    }, "consumer").start();
  }
  /**
  * 消息队列中存储的消息
  */
  static class Message {
  }
  /**
  * 消息队列
  */
  static class RefactorMessageQueue {
    /**
    * 队列最大值
    */
    private final int max;
    /*
    * 锁
    * */
    private final Lock lock = new ReentrantLock();
    /**
    * 条件变量，用于消费者，非空即可消费
    */
    private final Condition notEmptyCondition = lock.newCondition();
    /**
    * 条件变量，用于生产者，非满即可生产
    */
    private final Condition notFullCondition = lock.newCondition();
    /**
    * final确保发布安全
    */
    final LinkedList<Message> messageQueue = new LinkedList<>();
    /**
    * 构造函数默认队列大小为10
    */
    public RefactorMessageQueue() {
      max = 10;
    }
    /**
    * 构造函数设置队列大小
    */
    public RefactorMessageQueue(int x) {
      max = x;
    }
    public void set(Message message) {
      lock.lock();
      try {
        //如果已经大于队列个数，队列满，进入等待
        while (messageQueue.size() > max) {
          try {
            System.out.println(Thread.currentThread().getName() + " : queue is full ,waiting...");
            //如果满了，生产者在“非满”这个条件上等待
            notFullCondition.await();
          } catch (InterruptedException e) {
            e.printStackTrace();
          }
        }
        //如果队列未满，生产消息，随后通知lock上的等待线程
        //每一次的消息生产，都会通知消费者
        System.out.println(Thread.currentThread().getName() + " : add a message");
        messageQueue.addLast(message);
        //生产后，增加了消息，非空条件满足，需要唤醒消费者
        notEmptyCondition.signalAll();
      } finally {
      }
      lock.unlock();
    }
    public void get() {
      lock.lock();
      try {
        //如果队列为空，进入等待，无法获取消息
        while (messageQueue.isEmpty()) {
          try {
            System.out.println(Thread.currentThread().getName() + " : queue is empty ,waiting...");
            //如果空了，消费者需要在“非空”条件上等待
            notEmptyCondition.await();
          } catch (InterruptedException e) {
            e.printStackTrace();
          }
        }
        //队列非空时，读取消息，随后通知lock上的等待线程
        //每一次的消息读取，都会通知生产者
        System.out.println(Thread.currentThread().getName() + " : get a message");
        messageQueue.removeFirst();
        //消费后，减少了消息，所以非满条件满足，需要唤醒生产者
        notFullCondition.signalAll();
      } finally {
        lock.unlock();
      }
    }
  }
}
复制代码

总结

通过上面的示例，应该可以理解显式锁的思路
他与隐式锁并没有像名称上看起来这么对立（一个隐 一个显），他们的核心仍旧是为了解决线程的同步与线程间的通信协作
线程同步与通信的在Java中的底层核心概念为锁和监视器
不管是synchronized还是Lock，不管是Object提供的通信方法还是Condition中的方法，都还是围绕着锁和监视器的概念展开的
如同平时写代码，同样的功能，可能会有多种实现方式，显式锁和隐式锁也是类似的，他们的实现有着很多的不同，也都有各种利弊
所以才会有隐式锁和显式锁，在程序中很难找到“放之四海而皆准”的实现代码，所以才会有各种各样的解决方案
尽管早期synchronized关键字性能比较低，但是随着版本的升级，性能也有了很大的改善
所以官方也是建议如果场景满足，还是尽可能使用synchronized关键字而不是显式锁
显式锁是为了解决隐式锁而不好解决的一些场景而存在的，尽管本文并没有体现出来他们之间的差异（本文恰恰相反，对相同点进行了介绍）
但是显式锁有很多隐式锁不存在的优点，后续慢慢介绍，通过本文希望理解，显式锁也只是线程同步与协作通信的一种实现途径而已
文章标签：
云消息队列 MQ
Java
消息中间件
安全
存储
关键词：
Java线程
Java多线程
Java锁
Java概念
Java多线程线程
相关实践学习
消息队列RocketMQ版：基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能，涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列：消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验：基于MNS，0基础轻松构建 Web Client 本节课带您一起基于MNS，0基础轻松构建 Web Client
幸运券发放
目录
相关文章
叫个什么名字
|
2天前
|
存储 安全 Java
Java多线程编程的艺术：从基础到实践####
本文深入探讨了Java多线程编程的核心概念、应用场景及其实现方式，旨在帮助开发者理解并掌握多线程编程的基本技能。文章首先概述了多线程的重要性和常见挑战，随后详细介绍了Java中创建和管理线程的两种主要方式：继承Thread类与实现Runnable接口。通过实例代码，本文展示了如何正确启动、运行及同步线程，以及如何处理线程间的通信与协作问题。最后，文章总结了多线程编程的最佳实践，为读者在实际项目中应用多线程技术提供了宝贵的参考。 ####
叫个什么名字
15 5
众所周知
|
2天前
|
Java
JAVA多线程通信：为何wait()与notify()如此重要？
在Java多线程编程中，`wait()` 和 `notify()/notifyAll()` 方法是实现线程间通信的核心机制。它们通过基于锁的方式，使线程在条件不满足时进入休眠状态，并在条件满足时被唤醒，从而确保数据一致性和同步。相比其他通信方式，如忙等待，这些方法更高效灵活。 示例代码展示了如何在生产者-消费者模型中使用这些方法实现线程间的协调和同步。
众所周知
9 3
2G冲浪词条
|
23小时前
|
安全 Java
Java多线程集合类
本文介绍了Java中线程安全的问题及解决方案。通过示例代码展示了使用`CopyOnWriteArrayList`、`CopyOnWriteArraySet`和`ConcurrentHashMap`来解决多线程环境下集合操作的线程安全问题。这些类通过不同的机制确保了线程安全，提高了并发性能。
2G冲浪词条
6 1
请看我回答~
|
2天前
|
Java UED
Java中的多线程编程基础与实践
【10月更文挑战第35天】在Java的世界中，多线程是提升应用性能和响应性的利器。本文将深入浅出地介绍如何在Java中创建和管理线程，以及如何利用同步机制确保数据一致性。我们将从简单的“Hello, World!”线程示例出发，逐步探索线程池的高效使用，并讨论常见的多线程问题。无论你是Java新手还是希望深化理解，这篇文章都将为你打开多线程的大门。
请看我回答~
11 1
东方睿赢
|
3月前
|
存储 监控 Java
Java多线程优化：提高线程池性能的技巧与实践
Java多线程优化：提高线程池性能的技巧与实践
东方睿赢
110 1
碳基肥宅
|
6月前
|
设计模式 监控 Java
Java多线程基础-11：工厂模式及代码案例之线程池（一）
本文介绍了Java并发框架中的线程池工具，特别是`java.util.concurrent`包中的`Executors`和`ThreadPoolExecutor`类。线程池通过预先创建并管理一组线程，可以提高多线程任务的效率和响应速度，减少线程创建和销毁的开销。
碳基肥宅
188 2
Hacynn
|
6月前
|
Java 数据库
【Java多线程】对线程池的理解并模拟实现线程池
【Java多线程】对线程池的理解并模拟实现线程池
Hacynn
58 1
yinying293
|
3月前
|
安全 算法 Java
17 Java多线程（线程创建+线程状态+线程安全+死锁+线程池+Lock接口+线程安全集合）（下）
17 Java多线程（线程创建+线程状态+线程安全+死锁+线程池+Lock接口+线程安全集合）
yinying293
75 6
yinying293
|
3月前
|
存储 安全 Java
17 Java多线程（线程创建+线程状态+线程安全+死锁+线程池+Lock接口+线程安全集合）（中）
17 Java多线程（线程创建+线程状态+线程安全+死锁+线程池+Lock接口+线程安全集合）
yinying293
83 5
yinying293
|
3月前
|
存储 安全 Java
17 Java多线程（线程创建+线程状态+线程安全+死锁+线程池+Lock接口+线程安全集合）（上）
17 Java多线程（线程创建+线程状态+线程安全+死锁+线程池+Lock接口+线程安全集合）
yinying293
80 3

热门文章

最新文章

  • 1
    springboot event线程池总结
  • 2
    多线程开发（二）
  • 3
    踏破铁鞋无觅处，从AsyncTask学Android线程池
  • 4
    一个简单的C#多线程间同步的例子
  • 5
    使用UncaughtExceptionHandler重启线程
  • 6
    为什么redis是单线程的以及为什么这么快？
  • 7
    Android--线程详解
  • 8
    多线程程序设计学习（4）guarded suspension模式
  • 9
    Python多线程编程之多线程加锁
  • 10
    Linux多线程5-5_线程与fork
  • 1
    Java 并发编程中的锁优化策略
    33
  • 2
    刷题两个月，从入门到字节跳动offer丨GitHub标星16k+，美团Java面试题
    62
  • 3
    《MySQL 入门教程》第 05 篇 账户和权限，Java高并发编程详解深入理解pdf
    52
  • 4
    Java的前景如何，好不好自学？，万字Java技术类校招面试题汇总
    53
  • 5
    es集群安装，邮储银行java面试
    77
  • 6
    数据结构~缓存淘汰算法--LRU算法（Java的俩种实现方式，万字解析
    93
  • 7
    十五，java高级程序员面试宝典
    72
  • 8
    【redis源码学习】持久化机制，java程序员面试算法宝典pdf
    75
  • 9
    Java程序员必备的21个核心技术，你都掌握了哪些？，深入浅出Java开发
    107
  • 10
    【Java知识点详解 10】为何要配置环境变量，35岁老年程序员的绝地翻身之路
    64

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • Spring Cloud Alibaba - 重新定义 Java Cloud-Native
  • The Reactive Cloud Native Arch
  • JAVA开发手册1.5.0

    • 相关实验场景

    更多
  • 基于ECS搭建Java Web开发环境
  • 使用Aliyun Java Intializr进行项目开发
  • 搭建Java Web开发环境
  • 部署基于Dragonwell的Java运行环境
  • 阿里云平台上进行Java程序的编译与运行
  • RocketMQ中使用Java客户端发送消息和消费的应用
    • 下一篇
    无影云桌面