Java基础教程——线程通信

线程通信:等待、唤醒

Object方法这些方法在拥有资源时才能调用
notify唤醒某个线程。唤醒后不是立马执行,而是等CPU分配
wait等待,释放锁,不占用CPU资源
notifyAll唤醒全部等待的线程

重点:资源的有效利用

1648799-20190714002305216-1825455207.png

生产一个,消费一个;再生产一个,再消费一个

以热干面为例(生产者消费者问题):

class 热干面 {int isOK = 0;
}
class 生产者 implements Runnable {热干面 m;public 生产者(热干面 m) {this.m = m;}public void 做面() {try {synchronized (m) {if (m.isOK > Desk.BUFFER_MAX) {System.out.println("+等需要做了再做");m.wait();System.out.println("+开始做");}m.isOK++;System.out.println("+做面" + m.isOK);m.notify();}} catch (Exception e) {e.printStackTrace();}}public void run() {while (true) {try {Thread.sleep(Desk.做面时间);} catch (InterruptedException e) {e.printStackTrace();}做面(); // 生产面}}
}
class 消费者 implements Runnable {热干面 m;public 消费者(热干面 m) {this.m = m;}public void 吃面() {try {synchronized (m) {// # 锁住面对象if (m.isOK <= 0) {System.out.println("------等面");m.wait();// 等待,释放锁System.out.println("------有面了");}System.out.println("------吃面:" + m.isOK);m.isOK--;m.notify();// 唤醒另一个线程,但是,俩线程等CPU执行权}} catch (Exception e) {e.printStackTrace();}}public void run() {while (true) {try {Thread.sleep(Desk.吃面时间);} catch (InterruptedException e) {e.printStackTrace();}吃面();}}
}
class Desk {// 为了管理对象、模拟现实场景,可以不要public static final int 做面时间 = 100;public static final int 吃面时间 = 100;public static final int BUFFER_MAX = 1;热干面 msg = new 热干面();生产者 m = new 生产者(msg);消费者 c = new 消费者(msg);Thread t1 = new Thread(m); // 生产者线程Thread t2 = new Thread(c); // 消费者线程public void fn() {t1.start();t2.start();}
}
public class 生产者消费者问题 {public static void main(String[] args) {Desk d = new Desk();d.fn();}
}

转载于:https://www.cnblogs.com/tigerlion/p/11182799.html

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

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

相关文章

python requests cookies请求_python+requests实现接口测试 - cookies的使用

在很多时候&#xff0c;发送请求后&#xff0c;服务端会对发送请求方进行身份识别&#xff0c;如果请求中缺少识别信息或存在错误的识别信息&#xff0c;会造成识别失败。 如一些需要用户登录以后才能访问的页面。import requestsmyaddress_urlhttp://xxx.com/api/v1/myaddress…

kafka命令及启动

默认内网访问&#xff0c;要在外网访问的话&#xff0c;需要在修改config/server.properties中的配置 将listeners和advertised.listeners的值用主机名进行替换&#xff0c;在外用使用java进行生产者或消费者连接的时候&#xff0c;不填写具体的IP&#xff0c;填写安装kafka的主…

编程判断元素归类_编程练习-判断是否为易混淆数

题目来源&#xff1a;LeetCode给定一个数字 N&#xff0c;当它满足以下条件的时候返回 true&#xff1a;把原数字旋转180以后得到新的数字。如 0, 1, 6, 8, 9 旋转 180 以后&#xff0c;得到了新的数字 0, 1, 9, 8, 6 。2, 3, 4, 5, 7 旋转 180 后,得到的不是数字。易混淆数字 …

vue引入51la流量监控

main.js router.afterEach( ( to, from, next ) > {setTimeout(()>{var _hmt _hmt || [];(function() {//每次执行前&#xff0c;先移除上次插入的代码document.getElementById(51_la) && document.getElementById(51_la).remove();var hm document.createEle…

斯蒂夫乔布斯传 读后感

斯蒂夫乔布斯传 读后感 失败和命运&#xff0c;成长和感受刺激着乔布斯成长。他和普通人一样。但是&#xff0c;不一样的环境&#xff0c;不一样的职位&#xff0c;不一样的体验给了他不一样的生命。所以,慢慢成长吧。当你的经历足够支撑你的命运时&#xff0c;你会站到你想要的…

cad画直角命令_炸了,CAD fro命令配合tk命令,极轴追踪无敌!

文尾左下角阅读原文看视频教程好课推荐&#xff1a;零基础CAD&#xff1a;点我CAD室内&#xff1a;点我 周站长CAD&#xff1a;点我CAD机械&#xff1a;点我 Bim教程&#xff1a;点我CAD建筑&#xff1a;点我CAD三维&#xff1a;点我全屋定制&#xff1a;点我 ps教程&#xff1…

linux frp 内网穿透 nginx反向代理

wget https://github.com/fatedier/frp/releases/download/v0.20.0/frp_0.20.0_linux_amd64.tar.gz frps.ini 服务端 有外网IP服务器 frpc.ini 客户端 局域网服务器 服务端: vi frps.ini [common] bind_port 8700 token asdasdasdasdasdasdasd vi start_frp_server.s…

[转载]Tensorflow 的reduce_sum()函数的axis,keep_dim这些参数到底是什么意思?

转载链接&#xff1a;https://www.zhihu.com/question/51325408/answer/125426642来源&#xff1a;知乎 这个问题无外乎有三个难点&#xff1a; 什么是sum什么是reduce什么是维度(indices, 现在均改为了axis和numpy等包一致)sum很简单&#xff0c;就是求和&#xff0c;那么问题…

多多进宝推广团队_多多进宝推广形式及推手寻找、佣金结算方式是怎样的?

多多进宝是拼多多下的一款推广工具&#xff0c;主要是针对于想要提高自己店铺产品的销量以及获取更多流量的拼多多商家来展开的&#xff01;但是&#xff0c;目前为止还有很多拼多多商家对多多进宝的一个运用不太了解&#xff0c;以至于有一些拼多多商家在使用多多进宝时有很大…

rtsp 通过 浏览器播放

安装docker ffmpeg https://blog.csdn.net/m1f2c3/article/details/93624289 docker pull jrottenberg/ffmpeg docker run -it --entrypointbash jrottenberg/ffmpeg docker start ... 下载jsmpeg npm install -g ws npm install ws npm install http-server -g 进入j…

025 程序的循环结构

目录 一、概述二、遍历循环三、遍历循环的应用3.1 计数循环(N次)3.2 计数循环(特定次)3.3 字符串遍历循环3.4 列表遍历循环3.5 文件遍历循环四、无限循环五、循环控制保留字5.1 break 和 continue5.1.1 for5.1.2 while六、循环的高级用法6.1 循环的扩展6.1.1 for6.1.2 while七、…

灰度值怎么降级_微服务生态的灰度发布如何实现?

前言相信很多小伙伴们都听说过灰度发布&#xff0c;但是不一定知道如何实现&#xff1f;今天我们就介绍一下基本原理&#xff0c;以及提供代码实现给小伙伴们。灰度概念即原来的生产环境是1.0版本&#xff0c;那现在我们需要升级到2.0版本&#xff0c;但是我们需要验证2.0版本&…

wget抓取网站, 模拟手机端抓取

nohup wget --mirror -p --tries100 --convert-links -P . –user-agent"Mozilla/5.0 (iPad; U; CPU OS 3_2 like Mac OS X; en-us) AppleWebKit/531.21.10 (KHTML, like Gecko) Version/4.0.4 Mobile/7B334b Safari/531.21.10" http://网址 >1.log 2>&1 …

在电脑上显示未知发布者怎么办_笔记本电脑显示器花屏怎么办?电脑屏幕花屏的解决方法...

笔记本电脑显示器花屏怎么办&#xff1f;笔记本电脑屏幕花屏该如何解决呢&#xff1f;近日有用户反映在使用笔记本电脑时候&#xff0c;会出现花屏的问题&#xff0c;下面就给大家介绍具体解决方法。一&#xff1a;检查显示器与显卡的连线是否松动若显示屏花屏的话&#xff0c;…

php 网页转pdf

linux 安装 wkhtmltopdf 下载地址 https://wkhtmltopdf.org/downloads.html 服务器是centos7 wget https://github.com/wkhtmltopdf/packaging/releases/download/0.12.6-1/wkhtmltox-0.12.6-1.centos7.x86_64.rpm 下载有点慢 rpm -ivh wkhtmltox-0.12.6-1.centos7.x86_6…

deluser命令

deluser命令 2012年07月03日 ⁄ 系统管理 ⁄ 暂无评论 1.功能作用 从系统中删除一个用户或组 2.位置 /usr/sbin/deluser 3.格式用法 deluser [options] USER deluser USER GROUP 4.主要参数 --quiet | -q 不将进程信息发给 stdout --help | -h 帮助信息 …

mongodb 字段出现次数_MongoDB数据库

内容回顾Xpath选择器不要求记忆&#xff0c;只要混个眼熟即可基于openpyxl模块爬取豆瓣电影单页爬取多页爬取1.校验请求头里面是否有User-Agent参数 请求头里面加上即可2.限制IP规定时间内的访问次数 1.人为的加上时间延迟 在你的程序里面加上time.sleep()让你的程序间歇一段时…

相似三角形·中考

概述相似&#xff0c;主要是相似三角形&#xff0c;在中考中有举足轻重的地位&#xff0c;难度也较高&#xff0c;往往倒三题中至少有一题是圆和相似的结合相似常常和四边形、反比例函数、圆、二次函数等结合&#xff0c;十分灵活 比例性质 概念若$\displaystyle \frac{a}{b}\f…

php 对接 北向数据接口 socket

function encode($msgType, $timeStamp, $body) {return "\xFF\xFF".pack(CNn, $msgType, $timeStamp, strlen($body)).$body;}$connection->send(encode(1, time(), reqLoginAlarm;userxxx;keyxxx;typexxx)); 详情参考: 请教使用socket做为客户端和北向接口对接&…

编译后没有taget文件夹_maven资源文件的相关配置才会在编译后的target里面有

建Maven项目的时候&#xff0c;如果没有进行特殊的配置&#xff0c;Maven会按照标准的目录结构查找和处理各种类型文件。src/main/java和src/test/java这两个目录中的所有*.java文件会分别在comile和test-comiple阶段被编译&#xff0c;编译结果分别放到了target/classes和targ…