我的编程空间,编程开发者的网络收藏夹
学习永远不晚

如何深入理解Java多线程与并发框中的并发辅助工具类

短信预约 -IT技能 免费直播动态提醒
省份

北京

  • 北京
  • 上海
  • 天津
  • 重庆
  • 河北
  • 山东
  • 辽宁
  • 黑龙江
  • 吉林
  • 甘肃
  • 青海
  • 河南
  • 江苏
  • 湖北
  • 湖南
  • 江西
  • 浙江
  • 广东
  • 云南
  • 福建
  • 海南
  • 山西
  • 四川
  • 陕西
  • 贵州
  • 安徽
  • 广西
  • 内蒙
  • 西藏
  • 新疆
  • 宁夏
  • 兵团
手机号立即预约

请填写图片验证码后获取短信验证码

看不清楚,换张图片

免费获取短信验证码

如何深入理解Java多线程与并发框中的并发辅助工具类

如何深入理解Java多线程与并发框中的并发辅助工具类,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。

一、Exchanger 交换器(两线程间的通信)

使用场景:用于 有且仅有两个线程 间的 数据传输,就就是线程间的 通信 。它是 生产者/消费者 d的 wait() / notify() 的最佳替代工具。 核心原理:方法 exchange()阻塞特性:此方法被调用后等待其他线程来取数据,如果没有其他线程取得数据,则一直 阻塞。

示例:交替打印奇偶数:

public class Print {    public static void main(String[] args) {    // 交换器    Exchanger<Integer> exchanger = new Exchanger<>();    // 起始打印数值    Integer startNumber = 1;    // 终止的数值    Integer endNumber= 100;    // 线程1    Thread t1 = new Thread(new Thread1(exchanger, startNumber, endNumber));    Thread t2 = new Thread(new Thread2(exchanger, startNumber, endNumber));    // 设置线程名称    t1.setName("thread-no-1");    t2.setName("thread-no-2");    // 启动线程    t1.start();    t2.start();}}class Thread1 implements Runnable {private Exchanger<Integer> exchanger;private Integer number;private final Integer endNumber;public Thread1(Exchanger<Integer> exchanger, Integer startNumber, Integer endNumber) {    this.exchanger = exchanger;    this.number = startNumber;    this.endNumber = endNumber;}@Override    public void run() {    while (number <= endNumber) {        if (number % 2 == 1) {            System.out.println("线程:" + Thread.currentThread().getName() + " : " + number);        }        try {            exchanger.exchange(number++);        }        catch (InterruptedException e) {            e.printStackTrace();        }    }}}class Thread2 implements Runnable {private Exchanger<Integer> exchanger;private Integer number;private final Integer endNumber;public Thread2(Exchanger<Integer> exchanger, Integer startNumber, Integer endNumber) {    this.exchanger = exchanger;    this.number = startNumber;    this.endNumber = endNumber;}@Override    public void run() {    while (number <= endNumber) {        if (number % 2 == 0) {            System.out.println("线程:" + Thread.currentThread().getName() + " : " + number);        }        try {            exchanger.exchange(number++);        }        catch (InterruptedException e) {            e.printStackTrace();        }    }}}

二、Semaphore 信号灯

核心原理: 通过发放设置最大 许可数,来限制线程的并发数。 默认是 非公平锁,效率高。

public Semaphore(int permits) {    sync = new NonfairSync(permits);}Semaphore semaphore = new Semaphore(5);try {    semaphore.acquire();    // 获取许可    // 逻辑}catch (InterruptedException e) {    e.printStackTrace();}finally {    semaphore.release();    // 释放许可}

三、CountDownLatch 倒计时闩(锁)

核心原理:线程以 组团 的方式进行任务。 count 作为 stat 状态。await() 方式将 阻塞当前线程,直到 count 为 0。

CountDownLatch countDownLatch = new CountDownLatch(5);countDownLatch.countDown();// count - 1// 预处理try {    countDownLatch.await();    // 阻塞当前线程    // 大家一起处理的时候,我才处理}catch (InterruptedException e) {    e.printStackTrace();}

Sync同步器

private static final class Sync extends AbstractQueuedSynchronizer {    private static final long serialVersionUID = 4982264981922014374L;    Sync(int count) {        setState(count);    }    int getCount() {        return getState();    }    protected int tryAcquireShared(int acquires) {        return (getState() == 0) ? 1 : -1;    }    protected Boolean tryReleaseShared(int releases) {        // 递减 count; 转换为零时发出信号        for (;;) {            int c = getState();            if (c == 0)                            return false;            int nextc = c-1;            if (compareAndSetState(c, nextc))                            return nextc == 0;        }    }}

四、CyclicBarrier 循环栅栏(循环锁)

核心原理: 基于 ReentrantLock 和 Condition。 CyclicBarrier 不仅具有 CountDownLatch 的功能,还有实现屏障等待的功能,也就是阶段性同步。

CyclicBarrier与CountDownLatch比较

  • CountDownLatch:一个线程(或者多个),等待另外N个线程完成某个事情之后才能执行;CyclicBarrier:N个线程相互等待,任何一个线程完成之前,所有的线程都必须等待。

  • CountDownLatch:一次性的;CyclicBarrier:可以重复使用。

  • CountDownLatch基于AQS;CyclicBarrier基于锁和Condition。本质上都是依赖于volatile和CAS实现的。

看完上述内容,你们掌握如何深入理解Java多线程与并发框中的并发辅助工具类的方法了吗?如果还想学到更多技能或想了解更多相关内容,欢迎关注编程网行业资讯频道,感谢各位的阅读!

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

如何深入理解Java多线程与并发框中的并发辅助工具类

下载Word文档到电脑,方便收藏和打印~

下载Word文档

猜你喜欢

如何深入理解Java多线程与并发框中的并发辅助工具类

如何深入理解Java多线程与并发框中的并发辅助工具类,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。一、Exchanger 交换器(两线程间的通信)使用场景:用于 有且仅有两个线
2023-06-05

如何深入理解Java多线程与并发框中的CAS

如何深入理解Java多线程与并发框中的CAS,很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。CAS实现原理CAS 是 CompareAndSwap 的缩写,意思是
2023-06-05

如何深入理解Java多线程与并发框中线程的状态

本篇文章给大家分享的是有关如何深入理解Java多线程与并发框中线程的状态,小编觉得挺实用的,因此分享给大家学习,希望大家阅读完这篇文章后可以有所收获,话不多说,跟着小编一起来看看吧。1. 新建状态(New)万事万物都不是凭空出现的,线程也一
2023-06-05

如何深入理解Java多线程与并发框中的volatile关键字

本篇文章为大家展示了如何深入理解Java多线程与并发框中的volatile关键字,内容简明扼要并且容易理解,绝对能使你眼前一亮,通过这篇文章的详细介绍希望你能有所收获。概念把对 volatile变量的单个读/写,看成是使用 同一个监视器锁
2023-06-05

如何深入理解Java多线程与并发框中线程和进程的区别

如何深入理解Java多线程与并发框中线程和进程的区别,很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。线程和进程的区别1. 资源调度单位在计算机中,进程是程序运行所
2023-06-05

如何深入理解Java多线程与并发框中的队列同步器AQS

如何深入理解Java多线程与并发框中的队列同步器AQS,针对这个问题,这篇文章详细介绍了相对应的分析和解答,希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。一、 AbstractOwnableSynchronizer 抽象的、可
2023-06-05

深入理解Java多线程与并发框(第⑪篇)——线程池参数

ThreadPoolExecutor线程池线程的创建和销毁都会消耗大量资源,就好像公司每天上午9点工作时就招进一批员工,晚上6点干完活就辞退一批员工,这都会销毁公司大量资源。所以合理利用 “池” 中固定、稳定的线程是非常有必要的。扩展关系T
2023-06-05

怎样深入理解Java多线程与并发框中的synchronized 关键字

怎样深入理解Java多线程与并发框中的synchronized 关键字,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。一、Class文件与对象对象头 32位JVM的对象头二、sy
2023-06-05

怎么深入理解Java多线程与并发框中的顺序一致性模型

怎么深入理解Java多线程与并发框中的顺序一致性模型,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。一、竞态条件(Race Condition)计算的正确性取决于 多个线程 执行
2023-06-05

如何理解 Java 多线程与并发库之间的关系?(java多线程与并发库的关系)

在Java编程中,多线程和并发库是两个重要的概念,它们之间存在着密切的关系。本文将深入探讨Java多线程与并发库的关系,帮助读者更好地理解和应用这两个概念。一、多线程的基本概念多线程是指在一个程序中同时运行多个线程,每个
如何理解 Java 多线程与并发库之间的关系?(java多线程与并发库的关系)
Java2024-12-19

java多线程中的并发工具类CountDownLatch,CyclicBarrier和Semaphore该怎么理解

本篇文章给大家分享的是有关java多线程中的并发工具类CountDownLatch,CyclicBarrier和Semaphore该怎么理解,小编觉得挺实用的,因此分享给大家学习,希望大家阅读完这篇文章后可以有所收获,话不多说,跟着小编一起
2023-06-22

如何深入理解Java多线程与并发框中重排序、屏障指令、as-if-serial规则

这篇文章将为大家详细讲解有关如何深入理解Java多线程与并发框中重排序、屏障指令、as-if-serial规则,文章内容质量较高,因此小编分享给大家做个参考,希望大家阅读完这篇文章后对相关知识有一定的了解。一、重排序前篇文章已经讲了Java
2023-06-05

如何理解Java 并发编程中的ForkJoin框架

如何理解Java 并发编程中的ForkJoin框架,针对这个问题,这篇文章详细介绍了相对应的分析和解答,希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。1、什么是ForkJoin框架ForkJoin框架是java的JUC包里提供
2023-06-25

深入理解Java多线程与并发框(第③篇)——Java内存模型与原子性、可见性、有序性

一、Java内存模型Java Memory Modle,简称 JMM,中文名称 Java内存模型,它是一个抽象的概念,用来描述或者规范访问内存变量的方式。因为各中计算机的操作系统和硬件不同,方式机制也可能不同,Java内存模型用于屏蔽(适配
2023-06-05

如何解读Java多线程与并发模型中的共享对象

本篇文章为大家展示了如何解读Java多线程与并发模型中的共享对象,内容简明扼要并且容易理解,绝对能使你眼前一亮,通过这篇文章的详细介绍希望你能有所收获。以下内容如无特殊说明均指代Java环境。共享对象使用Java编写线程安全的程序关键在于正
2023-06-02

Java 内存模型与死锁:深入理解并发编程中的死锁问题

本文深入探讨 Java 内存模型与死锁问题之间的关联,并以示例代码阐释死锁的成因和解决方法,旨在帮助读者深入理解并发编程中的死锁问题。
Java 内存模型与死锁:深入理解并发编程中的死锁问题
2024-02-04

Java多线程高并发中如何解决ArrayList与HashSet和HashMap不安全的问题

这篇文章主要为大家展示了“Java多线程高并发中如何解决ArrayList与HashSet和HashMap不安全的问题”,内容简而易懂,条理清晰,希望能够帮助大家解决疑惑,下面让小编带领大家一起研究并学习一下“Java多线程高并发中如何解决
2023-06-25

编程热搜

  • Python 学习之路 - Python
    一、安装Python34Windows在Python官网(https://www.python.org/downloads/)下载安装包并安装。Python的默认安装路径是:C:\Python34配置环境变量:【右键计算机】--》【属性】-
    Python 学习之路 - Python
  • chatgpt的中文全称是什么
    chatgpt的中文全称是生成型预训练变换模型。ChatGPT是什么ChatGPT是美国人工智能研究实验室OpenAI开发的一种全新聊天机器人模型,它能够通过学习和理解人类的语言来进行对话,还能根据聊天的上下文进行互动,并协助人类完成一系列
    chatgpt的中文全称是什么
  • C/C++中extern函数使用详解
  • C/C++可变参数的使用
    可变参数的使用方法远远不止以下几种,不过在C,C++中使用可变参数时要小心,在使用printf()等函数时传入的参数个数一定不能比前面的格式化字符串中的’%’符号个数少,否则会产生访问越界,运气不好的话还会导致程序崩溃
    C/C++可变参数的使用
  • css样式文件该放在哪里
  • php中数组下标必须是连续的吗
  • Python 3 教程
    Python 3 教程 Python 的 3.0 版本,常被称为 Python 3000,或简称 Py3k。相对于 Python 的早期版本,这是一个较大的升级。为了不带入过多的累赘,Python 3.0 在设计的时候没有考虑向下兼容。 Python
    Python 3 教程
  • Python pip包管理
    一、前言    在Python中, 安装第三方模块是通过 setuptools 这个工具完成的。 Python有两个封装了 setuptools的包管理工具: easy_install  和  pip , 目前官方推荐使用 pip。    
    Python pip包管理
  • ubuntu如何重新编译内核
  • 改善Java代码之慎用java动态编译

目录