Java学习笔记——35多线程02

线程同步

  • 线程同步
    • 卖票案例
      • 同步代码块
      • 同步方法块
    • 线程安全的类
      • StringBuffer
      • Vector
      • Hashtable
    • Lock锁

线程同步

卖票案例

public class SellTicket implements Runnable{private int tickets=10;@Overridepublic void run(){while (true){if(tickets>0){System.out.println(Thread.currentThread().getName()+":正在卖第"+tickets+"张票");tickets--;try {Thread.sleep(100);} catch (InterruptedException e) {throw new RuntimeException(e);}}}}
}
public class SellTicketDemo {public static void main(String[] args) {SellTicket st= new SellTicket();Thread t1=new Thread(st,"李昊");Thread t2=new Thread(st,"朱长坤");Thread t3=new Thread(st,"杨天伦");t1.start();t2.start();t3.start();}
}

相同的票出现了多次
出现了负数票
原因是线程执行的随机性导致的

同步代码块

锁多条语句操作共享数据,可以使用同步代码块实现

格式

	syschronized(任意对象){多条语句操作共享数据的代码}
public class SellTicket implements Runnable{private int tickets=10;private Object obj=new Object();@Overridepublic void run(){while (true){synchronized(obj){if(tickets>0){System.out.println(Thread.currentThread().getName()+":正在卖第"+tickets+"张票");tickets--;try {Thread.sleep(100);} catch (InterruptedException e) {throw new RuntimeException(e);}}}}}
}

同步的好处和弊端

  • 好处:解决了多线程的数据安全问题
  • 弊端:当线程很多时,因为每个线程都会去判断同步上的锁,很耗费资源,会降低运行速率
  • 同步方法块

    • 同步方法:就是把synchronized关键字加到方法上

    格式

    	修饰符 synchronized 返回值类型 方法名(方法参数){}
    
    public class SellTicket implements Runnable{private int tickets=10;private int x=0;@Overridepublic void run(){while (true){if(x%2==0){synchronized(this){if(tickets>0){System.out.println(Thread.currentThread().getName()+":正在卖第"+tickets+"张AV");tickets--;try {Thread.sleep(100);} catch (InterruptedException e) {throw new RuntimeException(e);}}}}else{sellTicket();}x++;}}private synchronized void sellTicket(){if(tickets>0){System.out.println(Thread.currentThread().getName()+":正在卖第"+tickets+"张AV");tickets--;try {Thread.sleep(100);} catch (InterruptedException e) {throw new RuntimeException(e);}}}
    }
    

    同步方法的锁对象是this

    • 同步j静态方法:就是把synchronized关键字加到静态方法上
      同步静态方法的锁对象是 类名.class
    public class SellTicket implements Runnable{private static int tickets=10;private int x=0;@Overridepublic void run(){while (true){if(x%2==0){synchronized(SellTicket.class){if(tickets>0){System.out.println(Thread.currentThread().getName()+":正在卖第"+tickets+"张AV");tickets--;try {Thread.sleep(100);} catch (InterruptedException e) {throw new RuntimeException(e);}}}}else{sellTicket();}x++;}}private static synchronized void sellTicket(){if(tickets>0){System.out.println(Thread.currentThread().getName()+":正在卖第"+tickets+"张AV");tickets--;try {Thread.sleep(100);} catch (InterruptedException e) {throw new RuntimeException(e);}}}
    }

    线程安全的类

    StringBuffer

    • 线程安全 ,可变的字符序列
    • 从版本JDK5开始,被StringBuilder替代。通常应该使用StringBuilder(非线程安全的)类,因为它支持所有相同的操作,并且更快,因为它不执行同步

    Vector

    从Java 2平台v1.2开始,该类改进了List接口,使其成为JavaCollections Framework的成员。与新的集合实现不同,Vector被同步。如果不需要线程安全的实现,建议使用ArrayList代替Vector

    Hashtable

    • 该类实现了一个哈希表,它将键映射到值。任何非null对象都可以用作键或者值
    • 从Java 2平台v1.2开始,该类进行了改进,实现了Map接口,使其成为JavaCollections Framework的成员。与新的集合实现不同,Hashtable被同步。如果不需要线程安全的实现,建议使用HashMap代替Hashtable

    **Collections.synchronizedList()**可返回线程安全的ArrayList
    同理map也可以Collections.synchronizedMap()

    Lock锁

    为了更清晰地表达如何加锁和释放锁,JDK5后提供了一个新的锁对象Lock

    Lock提供了比使用synchronized方法和语句更为广泛的锁定操作
    Lock中获得锁和释放锁的方法:

    • void lock():获得锁
    • void unlock():释放锁

    Lock接口不能直接实例化,这里采用它的实现类ReentrantLock来实例化

    构造方法:ReentrantLock():创建一个ReentrantLock的实例

    public class SellTicket implements Runnable{private int tickets=20;private Lock lock=new ReentrantLock();@Overridepublic void run(){while (true){try{lock.lock();if (tickets>0){try {Thread.sleep(100);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println(Thread.currentThread().getName()+"正在卖第"+tickets+"张av");tickets--;} }finally {lock.unlock(); }}}
    }

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

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

相关文章

【网络编程】IO多路复用

IO多路复用是一种高效的I/O处理方式,它允许单个进程能够同时监视多个文件描述符(sockets、文件等),并在其中任何一个文件描述符准备好进行I/O操作时进行处理。它的核心在于使用少量的线程或进程来管理多个I/O操作,以提…

RK3568平台开发系列讲解(音视频篇)H264 的编码结构

🚀返回专栏总目录 文章目录 一、H264 的编码结构1.1、帧类型1.2、GOP1.3、Slice沉淀、分享、成长,让自己和他人都能有所收获!😄 📢视频编码的码流结构其实就是指视频经过编码之后得到的二进制数据是怎么组织的,换句话说,就是编码后的码流我们怎么将一帧帧编码后的图像…

数据结构学习系列之顺序表的两种删除方式

方式1:在顺序表的末端删除所存储的数据元素,代码如下:示例代码: int delete_seq_list_1(list_t *seq_list){if(NULL seq_list){printf("入参为NULL\n");return -1;}if(0 seq_list->count){printf("顺序表为空…

数据结构学习系列之顺序表的两种插入方式

方式1:在顺序表末端插入数据元素,代码如下:示例代码: int insert_seq_list_1(list_t *seq_list,int data){if(NULL seq_list){printf("入参为NULL\n");return -1;}if(N seq_list->count){printf("顺序表已满…

通过rabbitmq生成延时消息,并生成rabbitmq镜像

通过rabbitmq生成延时消息队列,并生成rabbitmq镜像 整体描述1. 使用场景2. 目前问题3. 前期准备 具体步骤1. 拉取镜像2. 运行镜像3. 安装插件4. 代码支持4.1 config文件4.2 消费监听4.2 消息生产 5. 功能测试 镜像操作1. 镜像制作2. 镜像导入 总结 整体描述 1. 使用…

Stable Diffusion WebUI中COMMANDLINE_ARGS参数配置说明

Windows用户: 在webui-user.bat文件的set COMMANDLINE_ARGS=后面配置 Linux用户: 在webui-user.sh文件的export COMMANDLINE_ARGS=""引号中配置 COMMANDLINE_ARGS详细参数配置说明 配置(Configuration)-h, –help无错误显示此帮助消息并退出–config配置配置/稳…

蠕虫病毒流量分析案例

背景 某供排水集团的网络管理员对其网络的健康状况持认可态度,表示网络运行正常,没有发现异常行为。然而,由于网络环境变得越来越复杂,仅凭借传统的网络经验已经不能全面了解网络情况。因此,我们为供排水集团安装了Ne…

Codeforces Round 895 (Div. 3)

A. Two Vessels 求出目标水位,然后计算倒水的次数向上取整即可 void solve(){db a, b, c; cin >> a >> b >> c;print(int(ceil((max(a, b) - (abs(b a) / 2)) / c))); } B. The Corridor or There and Back Again 对于每个可能被激活的陷阱&…

使用Docker部署Gitlab的记录

docker版本 使用docker -v查看 Docker version 1.13.1, build 7d71120/1.13.1运行容器镜像 映射本机的9980端口为Docker内部的80端口 映射本机的9922端口为Docker内部的22端口 使用root用户启动 映射本机目录/mnt/sda/gitlab/log为Docker内部的/var/log/gitlab 映射本机目录…

4 | Java Spark实现 WordCount

简单的 Java Spark 实现 WordCount 的教程,它将教您如何使用 Apache Spark 来统计文本文件中每个单词的出现次数。 首先,确保您已经安装了 Apache Spark 并设置了运行环境。您需要准备一个包含文本内容的文本文件,以便对其进行 WordCount 分析。 代码 package com.bigdat…

我的创作纪念日-2023

突然看到CSDN有这么一个发文模版(后文都是按照模版填空了),那就写一些吧。 机缘 具体有什么机缘呢?简单就是说,在CSDN上得到了一些帮助,因此也想写一些文章以期帮助别人。为什么不在自己的网站写呢&#…

Golang复习

golang的特点 Golang 针对并发进行了优化,并且在规模上运行良好 自动垃圾收集明显比 Java 或 Python 更有效,因为它与程序同时执行 golang数据类型 基本数据类型(值类型) 布尔类型 数字类型 整型 根据有符号分为:…

[NLP]LLM---FineTune自己的Llama2模型

一 数据集准备 Let’s talk a bit about the parameters we can tune here. First, we want to load a llama-2-7b-hf model and train it on the mlabonne/guanaco-llama2-1k (1,000 samples), which will produce our fine-tuned model llama-2-7b-miniguanaco. If you’re …

axios 请求和响应拦截器

1. 创建实例 使用 axios.create() 使用自定义配置创建一个 axios 实例。 const $http axios.create({timeout: 1000,headers: {Content-Type: application/json,} })2. 拦截器 在请求或响应被 then 或者 catch 处理前拦截他们,拦截分为请求拦截和响应拦截。 //…

微信小程序电影票订票小程序软件设计与实现

摘 要 我们的生活水平正在不断的提高,然而提高的一个重要的侧面表现就是更加注重我们的娱乐生活。电影是我们都喜欢的一种娱乐方式,各式各样的电影给我们带来的喜悦也是大不相同的。带来快乐的同时也因为其复杂、繁琐的流程让电影爱好者们变得烦躁起来。…

以太坊虚拟机

1.概述 以太坊虚拟机 EVM 是智能合约的运行环境。它不仅是沙盒封装的,而且是完全隔离的,也就是说在 EVM 中运行代码是无法访问网络、文件系统和其他进程的。甚至智能合约之间的访问也是受限的。 2.账户 以太坊中有两类账户(它们共用同一个…

人大金仓分析型数据库备份和恢复(三)

目录 备份或恢复过滤内容 过滤叶子分区 使用gprestore过滤 备份或恢复过滤内容 gpbackup备份指定数据库中的所有schema和表,除非您使用schema级别或表级别过滤器选项排除或包含单个schema或表对象。 schema级别选项是--include-schema或--exclude-schema命令行选…

​@Cacheable 注解​

1. 功能说明 Cacheable 注解在方法上,表示该方法的返回结果是可以缓存的。也就是说,该方法的返回结果会放在缓存中,以便于以后使用相同的参数调用该方法时,会返回缓存中的值,而不会实际执行该方法。 注意,这…

华为云API对话机器人CBS的魅力—实现简单的对话操作

云服务、API、SDK,调试,查看,我都行 阅读短文您可以学习到:人工智能AI智能的问答管理、全面的对话管理、高效训练部署 1.IntelliJ IDEA 之API插件介绍 API插件支持 VS Code IDE、IntelliJ IDEA等平台、以及华为云自研 CodeArts …

Unity 2018发布在iOS 16.3偶尔出现画面不动的问题

1)Unity 2018发布在iOS 16.3偶尔出现画面不动的问题 2)IL2CPP在Xcode下增量编译问题 3)帧同步实现PuppetMaster布娃娃系统的问题 这是第351篇UWA技术知识分享的推送,精选了UWA社区的热门话题,涵盖了UWA问答、社区帖子等…