java中多线程的一些常见操作

Java 中的多线程是通过并发编程来提高应用程序的效率和响应速度。Java 提供了多个机制和类来支持多线程编程，包括继承 Thread 类、实现 Runnable 接口、使用线程池等。以下是 Java 中一些常见的多线程操作和应用场景。

1. 创建线程

1.1 通过继承 Thread 类创建线程

继承 Thread 类并重写 run 方法是创建线程的一种方式。run 方法包含线程的执行体。

public class MyThread extends Thread {@Overridepublic void run() {System.out.println("Thread is running: " + Thread.currentThread().getName());}public static void main(String[] args) {MyThread thread = new MyThread();thread.start();  // 启动线程}
}
  • start() 方法会启动线程并调用 run() 方法。
  • run() 方法不能直接调用，必须通过 start() 启动线程。
1.2 通过实现 Runnable 接口创建线程

Runnable 接口适合当你不想继承 Thread 类时使用。你只需要实现 run 方法，然后将其传递给 Thread 对象。

public class MyRunnable implements Runnable {@Overridepublic void run() {System.out.println("Thread is running: " + Thread.currentThread().getName());}public static void main(String[] args) {MyRunnable myRunnable = new MyRunnable();Thread thread = new Thread(myRunnable);thread.start();  // 启动线程}
}

2. 线程的生命周期

线程有几个常见的生命周期状态：

  • 新建（New）：线程对象被创建，但未调用 start() 方法。
  • 可运行（Runnable）：线程被启动，处于可运行状态，但可能被操作系统调度暂停。
  • 阻塞（Blocked）：线程正在等待某个资源。
  • 等待（Waiting）：线程正在等待其他线程执行某些操作。
  • 终止（Terminated）：线程执行完毕，生命周期结束。

3. 线程的同步

当多个线程访问共享资源时，为了避免数据不一致的问题，通常需要使用同步机制。

3.1 使用 synchronized 关键字

synchronized 关键字用于在方法或代码块上加锁，确保在同一时间内只有一个线程能够执行被同步的代码块。

示例：同步方法
public class Counter {private int count = 0;// 使用 synchronized 修饰方法，保证线程安全public synchronized void increment() {count++;}public int getCount() {return count;}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();  // 等待线程 t1 执行完毕t2.join();  // 等待线程 t2 执行完毕} catch (InterruptedException e) {e.printStackTrace();}System.out.println("Final count: " + counter.getCount());  // 输出: Final count: 2000}
}

在上面的例子中，increment 方法被 synchronized 修饰，这意味着同一时刻只有一个线程能够访问这个方法。

3.2 使用同步代码块

你也可以使用同步代码块来锁定指定的代码区域，从而减少锁的范围，提高效率。

public class Counter {private int count = 0;public void increment() {synchronized (this) {  // 锁定当前对象count++;}}public int getCount() {return count;}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();  // 等待线程 t1 执行完毕t2.join();  // 等待线程 t2 执行完毕} catch (InterruptedException e) {e.printStackTrace();}System.out.println("Final count: " + counter.getCount());  // 输出: Final count: 2000}
}

在上面的代码中，increment 方法内的同步代码块确保了每次只有一个线程能够进入该代码块，防止了竞态条件的出现。

4. 线程间通信

线程间通信是在多个线程之间交换信息的机制。Java 提供了 wait()、notify() 和 notifyAll() 方法来实现线程间的通信。

4.1 使用 wait() 和 notify() 进行线程通信
  • wait()：使当前线程进入等待状态，并释放锁，直到被其他线程通知。
  • notify()：通知一个正在等待的线程，使其从等待状态中醒来，继续执行。
  • notifyAll()：通知所有正在等待的线程，所有线程都会尝试重新获取锁。
示例：生产者-消费者问题
class Storage {private int product = 0;private final int capacity = 10;// 生产者生产产品public synchronized void produce() throws InterruptedException {while (product >= capacity) {wait();  // 如果库存已满，生产者等待}product++;System.out.println("Produced, product count: " + product);notifyAll();  // 通知消费者线程}// 消费者消费产品public synchronized void consume() throws InterruptedException {while (product <= 0) {wait();  // 如果库存为空，消费者等待}product--;System.out.println("Consumed, product count: " + product);notifyAll();  // 通知生产者线程}
}public class ProducerConsumer {public static void main(String[] args) {Storage storage = new Storage();// 生产者线程Thread producer = new Thread(() -> {try {for (int i = 0; i < 20; i++) {storage.produce();Thread.sleep(100);  // 模拟生产时间}} catch (InterruptedException e) {e.printStackTrace();}});// 消费者线程Thread consumer = new Thread(() -> {try {for (int i = 0; i < 20; i++) {storage.consume();Thread.sleep(150);  // 模拟消费时间}} catch (InterruptedException e) {e.printStackTrace();}});producer.start();consumer.start();}
}

在这个例子中，我们模拟了生产者和消费者的线程通信机制。生产者线程不断生产产品，而消费者线程不断消费产品。当产品库存满时，生产者等待；当产品库存为空时，消费者等待。

5. 线程池（Executor Service）

线程池是 Java 提供的一个高效的多线程管理工具，它可以避免创建过多的线程，减少系统资源的消耗。Java 中的线程池是通过 ExecutorService 接口来管理的。

5.1 创建线程池

线程池的创建通常使用 Executors 工厂类，它提供了几种常用的线程池：

  • newFixedThreadPool(int n)：创建一个固定大小的线程池。
示例：使用 ExecutorService 执行任务
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class ThreadPoolExample {public static void main(String[] args) {// 创建一个固定大小的线程池，池中有 3 个线程ExecutorService executorService = Executors.newFixedThreadPool(3);// 提交多个任务给线程池for (int i = 0; i < 5; i++) {executorService.submit(() -> {System.out.println("Task executed by: " + Thread.currentThread().getName());try {Thread.sleep(1000);  // 模拟任务执行} catch (InterruptedException e) {e.printStackTrace();}});}// 关闭线程池executorService.shutdown();  // 提交完任务后调用 shutdown 来关闭线程池}
}

6. 线程的优先级

Java 允许设置线程的优先级，从而影响线程的调度顺序。线程的优先级是一个整数值，范围从 1 到 10，其中 1 为最低优先级，10 为最高优先级。

示例：设置线程优先级
public class ThreadPriority {public static void main(String[] args) {Thread highPriorityThread = new Thread(() -> {System.out.println("High priority thread is running.");});Thread lowPriorityThread = new Thread(() -> {System.out.println("Low priority thread is running.");});highPriorityThread.setPriority(Thread.MAX_PRIORITY);  // 设置高优先级lowPriorityThread.setPriority(Thread.MIN_PRIORITY);  // 设置低优先级highPriorityThread.start();lowPriorityThread.start();}
}

注意，虽然 Java 提供了线程优先级的设置，但线程调度是由操作系统管理的，不同的操作系统可能会根据自己的调度算法来决定线程的实际执行顺序。

7. 中断线程

线程的中断通常用于停止线程的执行或通知线程需要停止。通过调用线程的 interrupt() 方法可以设置线程的中断标志，而线程可以通过 isInterrupted() 方法来检查自己是否被中断。需要注意的是，interrupt() 并不会立即终止线程，它只是设置线程的中断状态，具体的中断行为需要在线程代码中自行判断并处理。

示例：中断线程
public class InterruptExample {public static void main(String[] args) throws InterruptedException {Thread longRunningThread = new Thread(() -> {try {for (int i = 0; i < 10; i++) {if (Thread.interrupted()) {System.out.println("Thread is interrupted, stopping...");return;  // 响应中断，终止线程}System.out.println("Running... " + i);Thread.sleep(1000);  // 模拟长时间任务}} catch (InterruptedException e) {System.out.println("Thread was interrupted during sleep.");}});longRunningThread.start();// 等待 3 秒后中断线程Thread.sleep(3000);longRunningThread.interrupt();  // 发出中断信号}
}

8. 线程的 join() 方法

join() 方法用于等待一个线程完成。当调用 join() 方法时，当前线程会阻塞，直到目标线程执行完毕为止。它常用于确保某些任务执行完之后再执行其他任务。

示例：使用 join() 等待线程完成
public class JoinExample {public static void main(String[] args) throws InterruptedException {Thread thread1 = new Thread(() -> {try {Thread.sleep(2000);  // 模拟任务执行System.out.println("Thread 1 finished");} catch (InterruptedException e) {e.printStackTrace();}});Thread thread2 = new Thread(() -> {try {Thread.sleep(1000);  // 模拟任务执行System.out.println("Thread 2 finished");} catch (InterruptedException e) {e.printStackTrace();}});thread1.start();thread2.start();// 等待 thread1 和 thread2 完成后再继续执行thread1.join();thread2.join();System.out.println("All threads finished");}
}

在这个例子中，main 线程会等待 thread1 和 thread2 执行完毕后再继续执行。

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

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

相关文章

使用 Docker 搭建 Hadoop 集群

使用 Docker 搭建 Hadoop 集群

1.1. 启用 WSL 与虚拟机平台 1.1.1. 启用功能 启用 WSL并使用 Moba 连接-CSDN博客 1.2 安装 Docker Desktop 最新版本链接&#xff1a;Docker Desktop: The #1 Containerization Tool for Developers | Docker 指定版本链接&#xff1a;Docker Desktop release notes | Do…
阅读更多...
【每日学点鸿蒙知识】广告ID、NFC手机充值、CSS支持语法、PC与模拟器交互、SO热更新等

【每日学点鸿蒙知识】广告ID、NFC手机充值、CSS支持语法、PC与模拟器交互、SO热更新等

1、HamonyOS 样机获取成功返回Oaid为00000000-0000-0000-0000-000000000000&#xff1f; 请求授权时需要触发动态授权弹窗,看一下是不是没有触发授权弹窗。 可以参考以下代码以及文档&#xff1a; // ets import identifier from ohos.identifier.oaid; import hilog from oh…
阅读更多...
【YOLO 项目实战】（12）红外/可见光多模态目标检测

【YOLO 项目实战】（12）红外/可见光多模态目标检测

欢迎关注『youcans动手学模型』系列 本专栏内容和资源同步到 GitHub/youcans 【YOLO 项目实战】&#xff08;10&#xff09;YOLO8 环境配置与推理检测 【YOLO 项目实战】&#xff08;11&#xff09;YOLO8 数据集与模型训练 【YOLO 项目实战】&#xff08;12&#xff09;红外/可…
阅读更多...
logback日志框架源码分析

logback日志框架源码分析

目录 （一）入口：slf4j选择日志框架 （二）日志框架初始化 （1）logback的3种配置方式 a、BasicConfigurator默认配置 b、SPI方式配置的Configurator实现类 c、通过配置文件初始化 （2）xml配置文件初始化 （三）Logger的创建 （四）打印日志 本文源码基于：logback版…
阅读更多...
国产数据库OceanBase从入门到放弃教程

国产数据库OceanBase从入门到放弃教程

1. 介绍 是由蚂蚁集团&#xff08;Ant Group&#xff0c;原蚂蚁金服&#xff09;自主研发的分布式关系型数据库。它旨在解决海量数据存储和高并发访问的问题&#xff0c;特别适合金融级应用场景&#xff0c;如支付宝等对数据一致性、可靠性和性能有极高要求的服务。以下是关于…
阅读更多...
连接Milvus

连接Milvus

连接到Milvus 验证Milvus服务器正在侦听哪个本地端口。将容器名称替换为您自己的名称。 docker port milvus-standalone 19530/tcp docker port milvus-standalone 2379/tcp docker port milvus-standalone 192.168.1.242:9091/api/v1/health 使用浏览器访问连接地址htt…
阅读更多...
机器学习中的欠拟合

机器学习中的欠拟合

当模型不能够准确地表达输入与输出的关系时&#xff0c;就是欠拟合。它在训练集和未见过的数据都会产生高误差率。过度拟合则在训练集表现出低误差率&#xff0c;只有对未见过的数据表现出高误差率。 当模型太过于简单时&#xff0c;它需要更多的训练时间、更多的输入特征、更…
阅读更多...
安卓入门二 Kotlin基础

安卓入门二 Kotlin基础

Kotlin Kotlin的历史 Kotlin由Jet Brains公司开发设计&#xff0c;2011年公布第一版&#xff0c;2012年开源。 2016年发布1.0正式版&#xff0c;并且Jet Brains在IDEA加入对Kotlin的支持&#xff0c;安卓自此又有新的选择。 2019年谷歌宣布Kotlin成为安卓第一开发语言&#x…
阅读更多...
淺談Cocos2djs逆向

淺談Cocos2djs逆向

前言 簡單聊一下cocos2djs手遊的逆向&#xff0c;有任何相關想法歡迎和我討論^^ 一些概念 列出一些個人認為比較有用的概念&#xff1a; Cocos遊戲的兩大開發工具分別是CocosCreator和CocosStudio&#xff0c;區別是前者是cocos2djs專用的開發工具&#xff0c;後者則是coco…
阅读更多...
STM32驱动NRF24L01

STM32驱动NRF24L01

一、NRF24L01的相关介绍 1.2 引脚的介绍 关于SPI的引脚就不再说了&#xff0c;这里介绍其余的两个引脚&#xff1a; CE 模块控制引脚&#xff1a;芯片开启信号&#xff0c;激活RX或TX模式 IRQ 模块中断信号输出引脚&#xff1a;其低电平有效&#xff0c;也就是中断时变为低电平…
阅读更多...
【Python】 glob批处理模块的学习

【Python】 glob批处理模块的学习

1.什么是glob模块&#xff1f; 在 Python 中&#xff0c;glob模块是一个用于文件路径名的模式匹配的工具。它使用简单的通配符规则来匹配文件和目录的路径&#xff0c;这些通配符规则类似于在命令行中使用的文件搜索规则。这使得在处理文件系统中的多个文件或目录时非常方便&am…
阅读更多...
Android 系统 AlarmManager 系统层深度定制

Android 系统 AlarmManager 系统层深度定制

Android 系统 AlarmManager 系统层深度定制 目录 引言AlarmManager 概述AlarmManager 系统架构AlarmManager 核心代码解读AlarmManager 深度定制方法 修改 AlarmManagerService 修改定时任务调度策略增加定时任务类型定制内核层 修改定时触发精度增加定时触发类型优化定时任务…
阅读更多...
解决vue-i18n在非.vue文件中，在其他js文件中无法使用的问题

解决vue-i18n在非.vue文件中，在其他js文件中无法使用的问题

其实很简单&#xff0c;把i18n直接挂载到window上&#xff0c;全局可使用。下面请看详细。 一、安装 npm install vue-i18n9二、在vue的main.js中引入 import Vue from "vue" import VueI18n from vue-i18n Vue.use(VueI18n)//注入到所有的子组件&#xff0c;就是…
阅读更多...
线性代数期末复习 [基础篇]

线性代数期末复习 [基础篇]

关于第六点: AXB 在期末考试中一般A都是可逆的 我们可以先把A的逆求出来,X A − 1 B A^-1B A−1B,或者 (A,B) -> r (E, A − 1 B A^-1B A−1B) 如果A矩阵不可逆,转变为方程组求解问题,假设都是二维矩阵 A(x1,x2) (b1,b2) Ax1 b1,Ax2 b2 XAB 如果A可逆,直接XB A − 1 A^-…
阅读更多...
C++ —— 数据类型转换和数据类型的别名

C++ —— 数据类型转换和数据类型的别名

数据类型转换 引言自动类型转换强制类型转换数据类型的别名 引言 计算机进行运算时&#xff0c;要求各操作数的数据类型、大小和存储方式都要相同。&#xff08;例如&#xff1a;8字节的整数和8字节的浮点数&#xff0c;虽然占用内存大小一样&#xff0c;但是存储方式不同&…
阅读更多...
Kali 自动化换源脚本编写与使用

Kali 自动化换源脚本编写与使用

1. 背景与需求 在使用 Kali Linux 的过程中&#xff0c;软件源的配置对系统的更新与软件安装速度至关重要。 Kali 的默认官方源提供了安全且最新的软件包&#xff0c;但有时由于网络条件或地理位置的限制&#xff0c;使用官方源可能会出现速度较慢的问题。 为了解决这一问题&a…
阅读更多...
设计模式-创建型-工厂方法模式

设计模式-创建型-工厂方法模式

什么是工厂方法模式&#xff1f; 工厂方法模式&#xff08;Factory Method Pattern&#xff09;是 创建型设计模式之一&#xff0c;目的是通过定义一个用于创建对象的接口&#xff0c;让子类决定实例化哪个类。简而言之&#xff0c;工厂方法模式通过延迟对象的创建过程到子类来…
阅读更多...
【Unity3D】ECS入门学习（十二）IJob、IJobFor、IJobParallelFor

【Unity3D】ECS入门学习（十二）IJob、IJobFor、IJobParallelFor

IJob&#xff1a;开启单个线程进行计算&#xff0c;线程内不允许对同一个数据进行操作&#xff0c;也就是如果你想用多个IJob分别计算&#xff0c;将其结果存储到同一个NativeArray<int>数组是不允许的&#xff0c;所以不要这样做&#xff0c;如下例子就是反面教材&#…
阅读更多...
Spring 创建和管理 Bean 的原理，以及Spring 的单例模式是否线程安全？（有无状态Bean）

Spring 创建和管理 Bean 的原理，以及Spring 的单例模式是否线程安全？（有无状态Bean）

Spring 是一个轻量级的开源框架&#xff0c;广泛应用于 Java 企业级应用的开发。它提供了一个全面的、基于 IOC&#xff08;控制反转&#xff09;和 AOP&#xff08;面向切面编程&#xff09;的容器&#xff0c;可以帮助开发者更好地管理应用程序中的对象。 Spring 创建和管理…
阅读更多...
Docker容器镜像制作

Docker容器镜像制作

Docker镜像的基本概念 1. 什么是Docker镜像&#xff1f; Docker镜像是一种轻量级、可执行的软件包&#xff0c;包含运行某个应用所需的所有代码、库、依赖项和配置文件。它的形成是一种“打包”和“快照”过程&#xff0c;使得应用能够在不同环境中保持一致的功能表现。 2. …
阅读更多...
最新文章

Copyright @ 2022~2023