Java多线程算法总结

1. 标题三个线程同时运行,依次打印ABC,一共打印10次

算法代码如下:

public class ThreadTest {private Object oa = new Object();private Object ob = new Object();private Object oc = new Object();private static final String TAG = "ThreadTest";private Runnable a = new Runnable() {@Overridepublic void run() {int count  = 10;while (count > 0) {synchronized (oc) {  //首先需要等待上个线程执行打印后,才能执行自己线程的打印任务。因此要获取到上个对象锁,这里是oc,并且执行oc.wait()方法//这样一旦在C线程中,oc执行了notify()方法后,才能按顺序让A线程继续执行synchronized (oa) { // 为了唤醒下一个B线程,执行oa.notify()方法,那么就需要对oa加锁Log.i(TAG, "A");count --;oa.notify();}try {oc.wait();} catch (InterruptedException e) {e.printStackTrace();}}}}};private Runnable b = new Runnable() {@Overridepublic void run() {int count  = 10;while (count > 0) {synchronized (oa) {synchronized (ob) {Log.i(TAG, "B");count --;ob.notify();}try {oa.wait();} catch (InterruptedException e) {e.printStackTrace();}}}}};private Runnable c = new Runnable() {@Overridepublic void run() {int count  = 10;while (count > 0) {synchronized (ob) {synchronized (oc) {Log.i(TAG, "C");count --;oc.notify();}try {ob.wait();} catch (InterruptedException e) {e.printStackTrace();}}}}};public void startThread() {Thread at = new Thread(a);Thread bt = new Thread(b);Thread ct = new Thread(c);try {at.start();Thread.sleep(100);  //保证第一次循环是ABC的顺序bt.start();Thread.sleep(100);ct.start();} catch (InterruptedException e) {e.printStackTrace();}}}

也可以把重复的Runnable抽象成一个,如下:

    private static class PrintRunnable implements Runnable {Object prev;Object current;String name;PrintRunnable(String name, Object prev, Object current) {this.name = name;this.prev = prev;this.current = current;}@Overridepublic void run() {int count = 10;while (count > 0) {synchronized (prev) {synchronized (current) {Log.i(TAG, name);count --;current.notify();}try {prev.wait();} catch (InterruptedException e) {e.printStackTrace();}}}}}public void startThread2() {Thread ta = new Thread(new PrintRunnable("A", oc, oa));Thread tb = new Thread(new PrintRunnable("B", oa, ob));Thread tc = new Thread(new PrintRunnable("C", ob, oc));try {ta.start();Thread.sleep(100);tb.start();Thread.sleep(100);tc.start();} catch (InterruptedException e) {e.printStackTrace();}}

wait()会释放对象锁;notify()是起到唤醒等待对象锁的线程的作用,并不会马上释放锁,但是一旦同步代码块执行完毕后,就会释放对象锁。

2.生产者-消费者问题

代码如下:

 /*** 生产者消费者问题*/private static final int MAX_COUNT = 10;List<String> product = new LinkedList<>();// 生产者private Runnable build = new Runnable() {@Overridepublic void run() {while (true) {synchronized (product) {while (product.size() >= MAX_COUNT) {// 如果商品已经达到最大存储量,则暂时不生产try {Log.i(TAG, Thread.currentThread().getName() + " 仓库已满");product.wait();} catch (InterruptedException e) {e.printStackTrace();}}product.add("商品");Log.i(TAG, Thread.currentThread().getName() + " 生产一个商品,当前商品存储量:" + product.size());product.notifyAll(); // 唤醒等待商品的消费者}try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}}}};// 消费者private Runnable consume = new Runnable() {@Overridepublic void run() {while (true) {synchronized (product) {while (product.isEmpty()) {try {Log.i(TAG, Thread.currentThread().getName() + " 仓库已空");product.wait(); // 没有商品消费,等待生产} catch (InterruptedException e) {e.printStackTrace();}}product.remove(0);Log.i(TAG, Thread.currentThread().getName() + " 消费一个商品,当前商品存储量:" + product.size());product.notifyAll(); // 通知等待生产的生产者}try {Thread.sleep(4000);} catch (InterruptedException e) {e.printStackTrace();}}}};public void startThread3() {Thread buildThread1 = new Thread(build);Thread buildThread2 = new Thread(build);Thread consumeThread1 = new Thread(consume);Thread consumeThread2 = new Thread(consume);Thread consumeThread3 = new Thread(consume);buildThread1.start();consumeThread1.start();buildThread2.start();consumeThread2.start();consumeThread3.start();}

打印如下:
在这里插入图片描述

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

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

相关文章

【精选】Java项目介绍和界面搭建——拼图小游戏 中

&#x1f36c; 博主介绍&#x1f468;‍&#x1f393; 博主介绍&#xff1a;大家好&#xff0c;我是 hacker-routing &#xff0c;很高兴认识大家~ ✨主攻领域&#xff1a;【渗透领域】【应急响应】 【Java】 【VulnHub靶场复现】【面试分析】 &#x1f389;点赞➕评论➕收藏 …

LeetCode 刷题 [C++] 第148题.排序链表

题目描述 给你链表的头结点 head &#xff0c;请将其按 升序 排列并返回 排序后的链表 。 题目分析 根据题意&#xff0c;可以使用归并排序来对链表进行排序。归并排序是基于分治的思想&#xff0c;比较容易实现的就是自顶向下的递归方式来实现。 先找出链表的中点&#x…

游泳耳机哪个牌子质量好?4大高口碑产品推荐入手

游泳耳机作为一种专业的水上音频装备&#xff0c;能够使游泳者在游泳过程中享受音乐的同时保持安全和舒适。随着科技的发展&#xff0c;市面上涌现出许多品牌和型号的游泳耳机&#xff0c;但是其中哪个牌子的质量更好呢&#xff1f;下面这篇文章将为大家介绍四大热门口碑产品&a…

2-23 switch、JVM内存模型、垃圾回收机制、this、static、变量的分类

文章目录 switch 实现成绩评级JVM内存模型概念栈的特点堆的特点 垃圾回收机制通用的分代垃圾回收机制三种清理算法垃圾回收过程垃圾回收常见的两种检测引用算法内存泄露常见原因 this的用法创建对象的四步 static 静态特点 变量的分类和作用域import switch 实现成绩评级 switc…

单点故障解决方案之Smart Link与Monitor Link

-SmartLink技术&#xff0c;创建Smart Link 组。在该组中&#xff0c;加入两个端口。其中1个端口是主端口&#xff0c;也称之为Master端口。另外1个端口是备份端口:也称之为 Slave 端口。 -Monitor Link 组也称之为“监控链路组&#xff0c;由上行端口和下行端口共同组成。下行…

SDR架构 (二) 为什么很多SDR频谱中间有尖峰?

相信大家第一次打开gnuradio看听广播、看频谱的时候&#xff0c;会注意到一个奇怪的现象&#xff0c;明明在频谱中间不该有信号&#xff0c;但是实际看到了一个尖峰。这个尖峰不含带任何信息&#xff0c;并且不管调节到哪个中心频率&#xff0c;这个尖峰都会存在。 这种情况出…

达梦数据库把日志数据按天统计不同状态的数据,实现字段行转列与根据id分组

1、这是日志表记录的数据&#xff0c;现在需要统计出每个app_id各个警告类型alarm_type的总数 2、先实现行转列&#xff0c;把三个alarm_type值转成列字段 SQL select app_id,count(CASE WHEN alarm_typeconcurrency THEN 1 ELSE null END) AS currentCount,count(CASE WHEN …

期货开户保证金保障市场正常运转

期货保证金是什么&#xff1f;在期货市场上&#xff0c;采取保证金交易制度&#xff0c;投资者只需按期货合约的价值&#xff0c;交一定比率少量资金即可参与期货合约买卖交易&#xff0c;这种资金就是期货保证金。期货保证金&#xff08;以下简称保证金〕按性质与作用的不同。…

Docker 第十九章 : 阿里云个人镜像仓使用

Docker 第十九章 : 阿里云个人镜像仓使用 本章知识点: 如何创建镜像库,如何设置密码,如何登录与退出个人镜像仓,如何本地打镜像,如何将本地镜像推送到个人镜像库。 背景 在项目YapiDocker部署中,因读取mongo:latest 版本不一致,导致后续执行步骤的异常。遇到此场景…

在UniApp中引入大于40kb字体包的记录

因为项目UI需要特殊字体&#xff0c;所以给了一个80kb字体包&#xff0c;但是在正常的使用导入时候发现不生效 这是我的导入过程 1.把下载好的文件放入static/font目录中 2.在app.vue中引用 font-face { font-family: zitiming; src: url(/static/font/YouSheBiaoTiHei-2.t…

Matlab进阶绘图第41期—双三角网格曲面图

在《Matlab论文插图绘制模板第67期—三角网格图(Trimesh)》中&#xff0c;我分享过三角网格曲面图的绘制模板。 然而&#xff0c;有的时候&#xff0c;需要在一张图上绘制两个及以上的三角网格曲面图&#xff0c;且每个三角网格曲面图使用不同的配色方案。 在Matlab中&#x…

使用Axure RP并配置IIS服务结合内网穿透实现公网访问本地HTML原型页面

文章目录 前言1.在AxureRP中生成HTML文件2.配置IIS服务3.添加防火墙安全策略4.使用cpolar内网穿透实现公网访问4.1 登录cpolar web ui管理界面4.2 启动website隧道4.3 获取公网URL地址4.4. 公网远程访问内网web站点4.5 配置固定二级子域名公网访问内网web站点4.5.1创建一条固定…

NC65 零预算控制规则 数据库表关系

NC65 零预算控制规则 数据库表关系 SELECT t1.createdby, t1.objname, t2.ctrlname, t2.pk_parent, t3.billtype, t3.nameidx, t3.pk_obj FROM tb_rule_formula t1 left join tb_ctrlformula t2 on t1.pk_obj t2.pk_parent left join tb_ctrlscheme t3 on t3.pk_ctrlformula …

如果大数据中多头借贷风险严重怎么办呢?

在大数据报告中&#xff0c;多头借贷风险、逾期风险、联系人风险、司法风险等是大数据评分评级的重要组成部分&#xff0c;大数据多头借贷风险也是很多银行和金融平台比较看重的&#xff0c;那如果大数据中多头借贷风险严重怎么办呢?本文详细为大家讲讲。 大数据多头风险是什么…

[JavaWeb玩耍日记]Mybatis快速入门与增删改查

目录 模块一&#xff1a;快速入门 1.创建数据库&#xff0c;插入数据 2.创建maven模块后&#xff0c;需要导入的依赖有哪些&#xff1f; 3.想要输出查询到的数据(包括日志打印)&#xff0c;需要创建哪些文件&#xff1f; 4.如何放置UserMapper接口与User类&#xff1f; 5.…

林浩然与杨凌芸的Scala奇遇记:从Java王国到函数式编程乐园

林浩然与杨凌芸的Scala奇遇记&#xff1a;从Java王国到函数式编程乐园 在那个代码编织而成的世界里&#xff0c;我们的主人公林浩然和杨凌芸&#xff0c;两位Java领域的编程高手&#xff0c;正在寻找新的挑战。他们曾一起探索过Java丛林中的Lambda表达式的奥秘&#xff0c;也曾…

配置资源管理Secret

目录 一、什么是Secret? 二、secret的三种类型 三、pod适用secret的三种方式 四、secret实例 1、创建secret 2、使用Secret方式 一、什么是Secret? Secret 是用来保存密码、token、密钥等敏感数据的 k8s 资源&#xff0c;目的是为了更方便的控制使用数据&#xff0c;并…

GDB动态调试学习-2-【断点】

文章目录 在程序地址上打断点在程序入口处打断点获取程序入口地址 在命名空间设置断点命名空间给命名空间的函数下断电 在文件行号上打断点保存已经设置的断点设置临时断点设置条件断点command指令 忽略断点 在程序地址上打断点 当调试汇编程序&#xff0c;或者没有调试信息的…

【扩散模型第三篇】Classifier Guidance 和 Classifier Free Guidance(CFG)

参考&#xff1a; [1] 张振虎博客 [2] https://www.bilibili.com/video/BV1s8411i7cU/?spm_id_from333.788&vd_source9e9b4b6471a6e98c3e756ce7f41eb134 [3] https://zhuanlan.zhihu.com/p/660518657 [4] https://zhuanlan.zhihu.com/p/640631667 进食顺序 1 前言2 Classi…

【c++】stack和queue模拟实现

> 作者简介&#xff1a;დ旧言~&#xff0c;目前大二&#xff0c;现在学习Java&#xff0c;c&#xff0c;c&#xff0c;Python等 > 座右铭&#xff1a;松树千年终是朽&#xff0c;槿花一日自为荣。 > 目标&#xff1a;能手撕stack和queue模拟 > 毒鸡汤&#xff1a;…