Java并发编程实战 第14章 构建自定义的同步工具

状态依赖性

定义:只有满足特定的状态才能继续执行某些操作(这些操作依赖于固定的状态,这些状态需要等待别的线程来满足)。

FutureTask,Semaphroe,BlockingQueue等,都是状态依赖性的类。

条件队列

条件对列:条件对列就是由于不满足继续的条件而被wait操作阻塞的线程队列。他们都在等待条件满足,然后被唤醒。

条件谓词:状态依赖性依赖的前提条件。如BlockingQueue中的isFull,isEmpty等。

条件等待中存在三个要素:加锁 + 条件谓词 + wait方法

wait方法和notify方法

我理解的wait方法:会释放锁+阻塞当前线程,放入条件对列,等待被唤醒,唤醒后,需要重新获得锁,获得锁之后继续执行wait那句代码所在的位置(即使wait在锁块的中间代码部分)。

notify(All)方法:只是唤醒条件队列中的线程。但是不释放锁。

使用wait notify方法的时候,一定要持有条件对列所属的锁。

使用轮询和休眠实现简单的状态依赖性阻塞

  1. while(true)
  2.         {
  3.             //这里不对循环上锁,不然这个锁就无法释放了,不对休眠上锁,休眠上锁,在休眠的时候别人也无法操作,永远都不可能有元素出去
  4.             synchronized (this)
  5.             {
  6.                 //如果队列不是满的,那么就放入元素
  7.                 if(!this.isFull())
  8.                 {
  9.                     this.doPut(v);
  10.                     return;
  11.                 }
  12.             }
  13.             //否则休眠,退出cpu占用
  14.             Thread.sleep(SLEEP_GRANULARITY);
  15.         }
  16.     }

使用条件队列来实现状态依赖性阻塞

 

  1. public synchronized void put(V v) throws InterruptedException
  2.    {
  3.        while(this.isFull())
  4.        {
  5.            //这里挂起程序,会释放锁
  6.            this.wait();
  7.        }
  8.        //如果队列不为满的,那么程序被唤醒之后从新获取锁
  9.        this.doPut(v);
  10.        //执行结束,唤醒其他队列
  11.        this.notifyAll();
  12.    }

注意上面要使用while。

对于监视器来说,wait操作产生的线程,都放在这个监视器唯一的条件队列里。

如果使用Lock,可以使用condition来产生不同的条件对列。

注意上面的 this.notifyAll();代码,将会唤醒这个监视器条件队列里所有等待的线程。其实这里只用唤醒因为empty阻塞的线程,而不用唤醒因为full阻塞的线程。

如果使用 this.notify(),只会随机唤醒一个,如果唤醒的是因为full堵塞的线程,那么就可能没有正常唤醒。影响性能,甚至造成活跃性的危险。

这种情况下,可以使用Lock和Condition来改造。

  1. protected final Lock lock = new ReentrantLock();
  2. private final Condition notFull = lock.newCondition();
  3. private final Condition notEmpty = lock.newCondition();
  4.  public void put(T x) throws InterruptedException {
  5.         lock.lock();
  6.         try {
  7.             while (count == items.length)
  8.                 notFull.await();
  9.             items[tail] = x;
  10.             if (++tail == items.length)
  11.                 tail = 0;
  12.             ++count;
  13.             notEmpty.signal();
  14.         } finally {
  15.             lock.unlock();
  16.         }
  17.     }

注意:这里不是signalAll。

阀门类

使用闭锁CountDownLatch,传入1的时候可以作为阀门开关。前提是在其他线程的第一步先执行开关的await。使用开关的countDown方法就可以打开开关。

但是这种阀门,只能打开,不能关闭。

使用wait和notifyAll来实现可重新关闭的阀门。

Condition

注意,由于Condition对象继承自Object,它也有wait,notify,notifyAll方法,其实它对应方法名字应该是await,signal,signalAll。

 

转载于:https://www.cnblogs.com/xiaolang8762400/p/7074721.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/455367.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

webserver接口_SpringBoot内置源码解析WebServer初始化过程

WebServer 初始化过程在上一节中 Spring Boot 初始化了 WebServer 对应的工厂类。同时,我们也知道对应 Web容器的WebServer实现类有:TomcatWebServer、JettyWebServer和UndertowWebServer。这节重点讲解这些 WebServer 是如何被初始化,又如何启动的。Web…

提升应用程序弹性:保障工作负载正常运行

通过集群化、复制、快照、微服务和应用程序设计来提高企业工作负载的应用程序弹性和可用性。 应用程序的弹性和可用性是现代企业工作负载的关键属性。应用程序需要在硬件故障发生后,扛过服务故障(例如负载平衡器和域名系统错误)保持工作状态,并且可以忍受…

JDBC笔记01-JDBC,Connection,Statement,ResultSet,PreparedStatement,Properties

学习目标 理解JDBC原理 掌握Connection接口的使用 掌握Statement接口的使用 掌握ResultSet接口的使用 掌握PreparedStatement接口的使用 掌握Properties类与配置文件的使用 JDBC 概念 JDBC (Java DataBase Connectivity) Java数据库连接技术的简称,提供连接各种常…

NVDKC6416平台H.264算法优化

本文转载自:http://blog.csdn.net/embedesign/archive/2009/09/15/4556486.aspx,版权归原作者,编辑:小乙哥 多媒体通信终端设备具有广泛的应用前景,可以应用于视频会议、可视电话、PDA、数字电视等各个领域&#xff0…

拦截器及 Spring MVC 整合

一、实验介绍 1.1 实验内容 本节课程主要利用 Spring MVC 框架实现拦截器以及 Spring MVC 框架的整合。 1.2 实验知识点 Spring MVC 框架拦截器1.3 实验环境 JDK1.8Eclipse JavaEE二、实验步骤 2.1 拦截器实现 在项目 hrms 的目录 src/main/java 下新建包 com.shiyanlou.interc…

高德地图轨迹回放_高德地图上线了一个新功能….

文、路人甲TM德地图这两天刚上线了一个叫做「家人地图」的功能,所谓家人地图顾名思义,就是你可以通过高德地图组建一个家人圈,在这个圈子里面你可以看到你的家人在什么位置,当你的家人到达什么位置的时候自动发送通知或者警告&…

You have new mail in /var/spool/mail/root消除提示的方法

有时在进入系统的时候经常提示You have new mail in /var/spool/mail/root 你觉得烦人---解决方法: 修改系统配置文件/etc/profile,告诉系统不要去检查邮箱. 具体操作:命令行输入:echo "unset MAILCHECK" >> /etc…

c3p0-config.xml文件简单说明与备忘

<?xml version"1.0" encoding"UTF-8"?> <c3p0-config><named-config name"mysql"><!-- 配置数据库用户名 --><property name"user">root</property><!-- 配置数据库密码 --><property…

python 消息队列 get是从队首还是队尾取东西_从零开始Python对redis作为消息队列的使用...

一、Redis 服务1、安装yum install redis2、 python安装支持模块/opt/python2.7.13/bin/pip install redis3、 和redis的简单直接交互In [1]: import redisIn [2]: rc redis.Redis(host192.168.8.237,port6379,decode_responsesTrue)In [5]: rc.set(imoocc,jeson)Out[5]: True…

‘’和“”

单引号引的数据是char类型的 双引号引的数据是String类型的 单引号只能引一个字符 而双引号可以引0个及以上 字符&#xff08;Character&#xff09;是指人类语言的最小的表义符号&#xff0c;字符是指计算机中使用的字母、数字和符号&#xff0c;包括1、2、3、A、B、C、#、&am…

Spring整合Quartz定时任务 在集群、分布式系统中的应用(Mysql数据库环境)

转载&#xff1a;http://www.cnblogs.com/jiafuwei/p/6145280.html 单个Quartz实例能给予你很好的Job调度能力&#xff0c;但它不能满足典型的企业需求&#xff0c;如可伸缩性、高可靠性满足。假如你需要故障转移的能力并能运行日益增多的 Job&#xff0c;Quartz集群势必成为你…

JDBC笔记02-数据库连接池 Spring JDBC

今日内容 数据库连接池Spring JDBC : JDBC Template 数据库连接池 概念: 其实就是一个容器(集合),存放数据库连接的容器 当系统初始化好后,容器被创建,容器中会申请一些连接对象,当用户来访问数据库时,从容器中获取连接对象,用户访问完之后,会将连接对象归还给容器 好处:…

20温控f1什么意思_欧姆龙温控器是什么 欧姆龙温控器介绍【图文】

欧姆龙温控器&#xff0c;乍一眼看上去真的很难理解这到底是一个什么产品&#xff0c;或者是一个有什么用处的温控器&#xff0c;对于这个比较浅显的问题&#xff0c;不知道大家会有什么样地感受&#xff0c;是不是正在一头雾水的等着我进行解答呢?经过我比较浅显的分析&#…

bootstrap 解决弹出窗口(modal) 常见问题

无法使用键盘esc关闭窗口方法&#xff1a; 首先在modal容器的div中增加属性tabindex"-1"&#xff0c;其次设置键盘ESC属性keyboard为true&#xff1b; 方法1&#xff1a;使用js打开窗口时 $(“#modal”).modal({keyboard:true}) 方法2&#xff1a;使用H5属性在modal窗…

zabbix3.2学习笔记(二):服务端安装

2019独角兽企业重金招聘Python工程师标准>>> 一般小公司大多将zabbix web端和zabbix server部署在同一台主机上&#xff0c;其实二者是可以分开的&#xff0c;web GUI配置连接到对应的数据库就行&#xff0c;让zabbix server和MySQL数据库在同一台主机上便于数据快速…

H.264解码器中CAVLC码表查找算法的分析与优化

0 引言 近年来&#xff0c;随着信息技术飞速发展和互联网的日益普及&#xff0c;尤其是以视频为信息主要来源的多媒体领域越来越受到人们的关注。H&#xff0e;264是ITU-T的视频编码专家组(VCEG)和ISO&#xff0f;IEC的活动图像编码专家组(MPEG)的联合视频组(Joint Video Te…

python求加速度_如何利用Python 为自然语言处理加速度

自去年发布 Python 的指代消解包(coreference resolution package)之后&#xff0c;很多用户开始用它来构建许多应用程序&#xff0c;而这些应用与我们最初的对话应用完全不同。利用 spaCy 和一点点 Cython 给 NLP 加速。自去年发布 Python 的指代消解包(coreference resolutio…

druid.properties文件的配置

# druid.properties文件的配置 driverClassNamecom.mysql.jdbc.Driver urljdbc:mysql://127.0.0.1:3306/plan usernameroot password # 初始化连接数量 initialSize5 # 最大连接数 maxActive10 # 最大超时时间 maxWait3000

jquery+easyui开发、培训文档

目 录 1.... Accordion&#xff08;可折叠标签&#xff09;....................................................................................... 2 1.1 实例.............................................................................................…

HAProxy用法详解 全网最详细中文文档

一、HAProxy简介&#xff08;1&#xff09;HAProxy 是一款提供高可用性、负载均衡以及基于TCP&#xff08;第四层&#xff09;和HTTP&#xff08;第七层&#xff09;应用的代理软件&#xff0c;支持虚拟主机&#xff0c;它是免费、快速并且可靠的一种解决方案。 HAProxy特别适用…