Java多线程编程与并发控制策略

Java多线程编程与并发控制策略

大家好,我是免费搭建查券返利机器人省钱赚佣金就用微赚淘客系统3.0的小编,也是冬天不穿秋裤,天冷也要风度的程序猿!今天,我想和大家分享一下Java多线程编程与并发控制策略的相关知识,希望对大家有所帮助。

一、Java多线程编程基础

1.1 线程的创建与启动

在Java中,线程可以通过继承Thread类或实现Runnable接口来创建和启动。

// 继承Thread类
class MyThread extends Thread {public void run() {System.out.println("Thread is running");}
}// 实现Runnable接口
class MyRunnable implements Runnable {public void run() {System.out.println("Runnable is running");}
}public class Main {public static void main(String[] args) {MyThread thread1 = new MyThread();thread1.start();Thread thread2 = new Thread(new MyRunnable());thread2.start();}
}
1.2 线程的生命周期

线程在Java中的生命周期包括以下几个阶段:

  1. 新建(New):线程对象被创建,但尚未调用start()方法。
  2. 就绪(Runnable)start()方法被调用,线程进入就绪状态,等待CPU调度。
  3. 运行(Running):线程获得CPU资源,开始执行run()方法。
  4. 阻塞(Blocked):线程因某些原因(如等待I/O操作)进入阻塞状态。
  5. 终止(Terminated):线程执行完run()方法或因异常退出。

二、并发控制策略

2.1 同步(Synchronized)

Synchronized关键字用于保证多个线程访问共享资源时的互斥性,防止数据不一致问题。

class Counter {private int count = 0;public synchronized void increment() {count++;}public synchronized int getCount() {return count;}
}public class Main {public static void main(String[] args) {Counter counter = new Counter();Thread t1 = new Thread(() -> {for (int i = 0; i < 1000; i++) {counter.increment();}});Thread t2 = new Thread(() -> {for (int i = 0; i < 1000; i++) {counter.increment();}});t1.start();t2.start();try {t1.join();t2.join();} catch (InterruptedException e) {e.printStackTrace();}System.out.println("Count: " + counter.getCount());}
}
2.2 显式锁(Explicit Lock)

ReentrantLock是Java中的显式锁,提供了比Synchronized更灵活的锁机制。

import java.util.concurrent.locks.ReentrantLock;class Counter {private int count = 0;private final ReentrantLock lock = new ReentrantLock();public void increment() {lock.lock();try {count++;} finally {lock.unlock();}}public int getCount() {lock.lock();try {return count;} finally {lock.unlock();}}
}
2.3 信号量(Semaphore)

Semaphore用于控制同时访问某个特定资源的线程数量。

import java.util.concurrent.Semaphore;class Resource {private final Semaphore semaphore = new Semaphore(3);public void use() {try {semaphore.acquire();System.out.println("Resource in use by " + Thread.currentThread().getName());Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();} finally {semaphore.release();}}
}public class Main {public static void main(String[] args) {Resource resource = new Resource();for (int i = 0; i < 10; i++) {new Thread(resource::use).start();}}
}
2.4 读写锁(ReadWriteLock)

ReadWriteLock允许多个读操作同时进行,但写操作独占。

import java.util.concurrent.locks.ReentrantReadWriteLock;class SharedData {private int data = 0;private final ReentrantReadWriteLock rwLock = new ReentrantReadWriteLock();public void write(int value) {rwLock.writeLock().lock();try {data = value;} finally {rwLock.writeLock().unlock();}}public int read() {rwLock.readLock().lock();try {return data;} finally {rwLock.readLock().unlock();}}
}

三、并发工具类

3.1 CountDownLatch

CountDownLatch用于让一个或多个线程等待其他线程完成操作。

import java.util.concurrent.CountDownLatch;public class Main {public static void main(String[] args) {CountDownLatch latch = new CountDownLatch(3);for (int i = 0; i < 3; i++) {new Thread(() -> {System.out.println(Thread.currentThread().getName() + " is working");latch.countDown();}).start();}try {latch.await();} catch (InterruptedException e) {e.printStackTrace();}System.out.println("All threads have finished");}
}
3.2 CyclicBarrier

CyclicBarrier用于让一组线程等待至某个状态,然后同时执行。

import java.util.concurrent.CyclicBarrier;public class Main {public static void main(String[] args) {CyclicBarrier barrier = new CyclicBarrier(3, () -> System.out.println("All threads have reached the barrier"));for (int i = 0; i < 3; i++) {new Thread(() -> {System.out.println(Thread.currentThread().getName() + " is working");try {barrier.await();} catch (Exception e) {e.printStackTrace();}}).start();}}
}

总结

Java多线程编程与并发控制是一个复杂而重要的领域。在实际开发中,我们需要根据具体需求选择合适的并发控制策略,确保程序的正确性和性能。通过学习和掌握这些技巧,我们可以更好地应对多线程编程中的各种挑战,为用户提供高效、可靠的应用程序。

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

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

相关文章

Tableau数据可视化与仪表盘搭建

Tableau的主要目的 数据赋能和数据探索。 数据赋能&#xff1a; 1.分析师可以将数据看板发布到线上给其他部门使用 2.自动更新看板 3.自由下载数据 4.线上修改图表 5.邮件发送数据 6.设置数据预警 数据探索&#xff1a; 1.支持亿级数据的连接和处理 2.自由地对字段进行各种…

目前哪个充电宝品牌比较好?四款优质充电宝分享

在电量成为现代生活不可或缺的生产资源的时代&#xff0c;选择一款优质的充电宝无疑是保证移动设备持续运作的关键。面对市场上众多品牌和型号的充电宝&#xff0c;消费者在选择时可能会感到困惑和迷茫。本文将为您揭示哪些品牌真正代表了耐用性和质量的典范&#xff0c;让自己…

gbase8s获取表的serial字段下一个insert序列值

serial字段&#xff0c;有个函数可以获取到最后插入的序列值&#xff0c;但是好像只能获取到当前会话最后一次插入的序列值&#xff0c;不论是SELECT dbinfo(sqlca.sqlerrd1) FROM dual;&#xff0c;还是select dbinfo(bigserial) from dual;&#xff0c;或者select dbinfo(ser…

Perl语言入门:掌握Perl的基本语法

Perl 是一种高级、通用的、解释型、动态编程语言&#xff0c;最初设计用于文本处理&#xff0c;但随着时间的发展&#xff0c;它的应用已经扩展到许多其他领域。Perl 以其强大的文本处理能力、灵活性和丰富的库而受到程序员的喜爱。本文将详细介绍 Perl 的基本语法&#xff0c;…

Overleaf用法

调整题目和正文之间的间距 调整题目和正文之间的间距\hyphenation{op-tical net-works semi-conduc-tor}\title{Report-20/06/2024} \date{\bigskip\today} 在这里添加间距 \begin{document}\maketitle% \author{Name Surname 1, Name Surname 2} \vspace{3cm} 用vspace控制间…

如果申请小程序地理位置接口权限之前刷到这一篇就好了

小程序地理位置接口有什么功能&#xff1f; 通常情况下&#xff0c;我们在开发小程序时&#xff0c;可能会用到获取用户地理位置信息的功能。小程序开发者开放平台的新规定指出&#xff0c;如果没有申请开通微信小程序地理位置接口&#xff08;getLocation&#xff09;&#xf…

4.XSS-反射型(get)利用:获取cookie

GET反射型XSS利用&#xff1a;获取cookie 修改一下配置文件\pikachu\pkxss\xcookie\cookie.php 我这里将对应的IP地址修改为本地pikachu的主站IP地址&#xff0c;这样给用户造成一种正常视觉上的欺骗&#xff0c;容易上当。重定向到pikachu主页面 基于IP搭建的pkxss平台(入侵…

Python中的多线程实现与GIL(全局解释器锁)的影响

Python中的多线程实现与GIL&#xff08;全局解释器锁&#xff09;的影响 在Python编程中&#xff0c;多线程是一种常见的并发编程技术&#xff0c;它允许程序同时执行多个任务。然而&#xff0c;Python的全局解释器锁&#xff08;GIL&#xff09;对多线程的性能和并发性有着显…

合并有序链表

合并有序链表 图解代码如下 图解 虽然很复杂&#xff0c;但能够很好的理解怎么使用链表&#xff0c;以及对链表的指针类理解 代码如下 Node* merge_list_two_pointer(List& list1, List& list2) {Node* new_head1 list1.head;Node* new_head2 list2.head;Node* s…

激光气体热值分析仪在线干法取样预处理装置制备方法

激光气体热值分析仪在线干法取样预处理装置制备方法 一、项目提出前状况: 在冶金企业产生大量的燃气副产品,主要有高炉煤气、转炉煤气、焦炉煤气,这些二次能源的高效利用是企业降本增效的重要途径。燃气热值是燃气最主要的质量指标,热值准确检测对燃气科学配比和有效利用…

认识微服务

单体架构 单体架构&#xff1a;将业务的所有功能集中在一个项目中开发&#xff0c;打成一个包部署。 优点&#xff1a; 架构简单部署成本低缺点&#xff1a; 团队协作成本高系统发布效率低系统可用性差 总结&#xff1a; 单体架构适合开发功能相对简单&#xff0c;规模较小…

【从0实现React18】 (二) JSX 的转换 jsx到底是什么?React是如何把jsx转换为ReactElement?

react项目结构 React(宿主环境的公用方法)React-reconciler(协调器的实现&#xff0c;宿主环境无关)各种宿主环境的包shared(公用辅助方法&#xff0c;宿主环境无关) 当前实现的JSX转换属于 react****包 初始化react包 先创建react package并初始化 更新package.json文件&a…

秋招的复习随想

文章目录 第一版第二版第三版 第一版 研二准备秋招了&#xff0c;真想对研一的我说&#xff01; 课这个东西&#xff0c;还看不出来老师到底是想不想教吗&#xff1f;大部分都是浪费时间&#xff0c;下课让你交论文&#xff0c;实际论文都不会看&#xff0c;都是助教改的。然后…

微服务——重复消费(幂等解决方案)

目录 一、唯一ID机制二、幂等性设计三、状态检查机制四、利用缓存和消息队列五、分布式锁总结 在微服务中&#xff0c;防止重复消费的核心思想是通过设计使得操作一次与多次产生相同的效果&#xff0c;并为每次操作生成唯一的ID。这样&#xff0c;即使在消息被重复发送的情况下…

K8S - 实现statefulset 有状态service的灰度发布

什么是灰度发布 Canary Release 参考 理解 什么是 滚动更新&#xff0c;蓝绿部署&#xff0c;灰度发布 以及它们的区别 配置partition in updateStrategy/rollingUpdate 这次我为修改了 statefulset 的1个yaml file statefulsets/stateful-nginx-without-pvc.yaml: --- apiVe…

Android - 跳转到应用商店进行应用打分功能实现

2.将过滤出的这些应用商店展示给用户&#xff0c;如果没有安装任何相关应用商店则提示用户“暂无安装相关应用商店”。 3.用户点击了某应用商店之后&#xff0c;则跳转到该应用商店的APP详情页。 4.下面列出了比较核心的代码&#xff0c;可进行参考。 /** 过滤出已经安装的包…

工业用焦炉集气管压力控制状态远程预警方法

工业用焦炉集气管压力控制状态远程预警方法 一、项目提出前状况: 焦化厂焦炉集气管压力是炼焦生产过程中重要的工艺参数(其控制目标80~120Pa),焦炉集气管压力的稳定是焦炉正常生产的重要保证。集气管压力过高会造成焦炉炉体冒烟冒火,污染环境,对操作人员的人身安全构成…

不同交换机之间相同VLAN间主机通信

1、搭建网络拓扑 搭建拓扑&#xff0c;分配IP地址&#xff0c;划分vlan&#xff0c;分配端口 2、配置交换机 //进入全局配置模式 Switch>enable Switch#config terminal Enter configuration commands, one per line. End with CNTL/Z. Switch(config)#hostname SW1 …

ubuntu 20.04 访问csdn报错 Secure connection failed

打扰了&#xff0c;csdn服务器的问题&#xff0c;和源没关系&#xff0c;后面又重新测试了一下。刚好那一刻网站连上了。 暂时没有好办法&#xff0c;等待一段时间就连上了&#xff0c;改host似乎也不太行。 问题原因&#xff1a; 我一边更新源 sudo apt update & apt up…

35.netty模拟redis客户端向redis服务端写数据

redis命令:set name zhangsan *3 $3 set $4 name $8 zhangsan *3 表示有三个元素 $3表示 set 命令的长度,3个字节 $4 表示name的长度,4个字节 $8 表示zhangsan的长度,8个字节 package com.xkj.nian;import io.netty.bootstrap.Bootstrap; import io.netty.buffer.ByteB…