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,一经查实,立即删除!

相关文章

HarmonyOS | 状态管理(七) | AppStorage(应用级UI状态存储)

系列文章目录 1.HarmonyOS | 状态管理(一) | State装饰器 2.HarmonyOS | 状态管理(二) | Prop装饰器 3.HarmonyOS | 状态管理(三) | Link装饰器 4.HarmonyOS | 状态管理(四) | Provide和Consume装饰器 5.HarmonyOS | 状态管理(五) | Observed装饰器和ObjectLink装饰器 6.Harmo…

【精选】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 …

Python 读取环境变量时,环境变量值修改后一直读不到最新的解决

原因 在使用Open AI开发应用时&#xff0c;API Key为了安全&#xff0c;会保存在操作系统环境变量中&#xff08;Windows&#xff09;。 在Windows中添加一个环境变量值&#xff1a; OPENAI_API_KEYYOUR_API_KEY。 今天这个API KEY被禁了&#xff0c;使用不了了&#xff0c;就…

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

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

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

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

Unity3D 使用 Lerp 进行连续运动

有很多关于在 Unity 中使用 lerp 方法移动对象的帖子和视频,但很少有人指出主要问题。 在开始之前,请阅读这篇文章以了解 Lerp 方法:How to Lerp like a pro | Chico Unity3D 正如您在上面的文章中读到的,lerp 方法遵循一个简单的概念。设置开始和结束位置以及进度百分比。…

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

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

opengles 背面剔除介绍(十二)

文章目录 前言一、OpenGL ES 剔除功能简介二、Opengl ES 剔除功能相关的API1.使能剔除功能2. 配置面剔除模式3. 设置剔除面的顺序4. 禁用剔除功能总结参考资料前言 本文主要介绍 opengles3.0 中的背面剔除相关知识,对于绘制3d 图形, 经常会用到它,并且它能提升渲染效率 软硬…

微信小程序配置

微信小程序的下拉刷新配置主要在页面的配置文件 app.json 中进行。 在 app.json 中&#xff0c;可以使用 enablePullDownRefresh 字段来配置是否支持下拉刷新&#xff0c;该字段的值为布尔类型。 示例代码如下&#xff1a; {"pages": ["pages/index/index&qu…

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创建一条固定…

vmware网络负载均衡方式

基于 IP 哈希的路由&#xff1a; 原理&#xff1a; 基于虚拟机的源和目标 IP 地址以及 TCP/UDP 端口号计算哈希值&#xff0c;并使用该哈希值确定出口网络适配器。这样可以确保同一对源和目标的网络流量始终被路由到相同的网络适配器。应用场景&#xff1a; 适用于大量使用虚拟…

学习JAVA的第六天(基础)

目录 集合 集合和数组的对比 ArrayList成员方法 ArrayList成员方法代码展示 练习 集合的遍历01之字符串 集合的遍历02之数字 集合的遍历03之学生对象 集合 集合和数组的对比 从长度维度来看 数组长度固定 集合长度可变从存储类型维度来看 数组可以存放基本数据类型和…

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 …