【Java 基础篇】Java 多线程详解

news2025/2/26 14:05:47

在这里插入图片描述

多线程是 Java 编程中的一个重要概念，它允许程序同时执行多个任务，提高了程序的性能和响应能力。本篇博客将深入探讨 Java 多线程，从基础概念到实际应用，适用于 Java 初学者和希望深入了解多线程的开发人员。

什么是多线程？

在开始之前，让我们来了解一下什么是线程。线程是程序执行的最小单位，它是进程的一部分，可以独立执行代码。多线程是指在同一个程序中同时运行多个线程。每个线程都有自己的执行路径，可以独立执行任务。

多线程的好处在于可以充分利用多核处理器的性能，提高程序的并发性，实现更高的吞吐量和响应速度。Java 提供了丰富的多线程支持，使得多线程编程变得更加容易。

创建线程

在 Java 中，有两种主要的创建线程的方式：

1. 继承 Thread 类

可以创建一个继承自 Thread 类的子类，并重写 run 方法来定义线程的任务。然后通过创建子类的实例来启动线程。

class MyThread extends Thread {
    public void run() {
        // 线程执行的任务
    }
}

// 创建并启动线程
MyThread thread = new MyThread();
thread.start();

2. 实现 Runnable 接口

可以实现 Runnable 接口，然后通过创建 Thread 类的实例并传递 Runnable 对象来启动线程。

class MyRunnable implements Runnable {
    public void run() {
        // 线程执行的任务
    }
}

// 创建 Runnable 对象
MyRunnable myRunnable = new MyRunnable();

// 创建并启动线程
Thread thread = new Thread(myRunnable);
thread.start();

线程的生命周期

线程在其生命周期内经历多个状态，包括新建、就绪、运行、阻塞和终止等状态。了解线程的生命周期有助于更好地管理和调试多线程程序。

  1. 新建状态（New）：线程已创建，但尚未启动执行。
  2. 就绪状态（Ready）：线程已准备好运行，等待系统分配 CPU 时间片。
  3. 运行状态（Running）：线程正在 CPU 上执行。
  4. 阻塞状态（Blocked）：线程因等待某些事件（如 I/O 操作或锁资源）而被暂停。
  5. 终止状态（Terminated）：线程执行完毕或因某种原因被终止。

线程同步与互斥

多线程编程面临一个重要问题，即多个线程同时访问共享资源可能导致数据不一致性和竞态条件。为了解决这些问题，Java 提供了同步机制和锁来确保线程安全。

同步块

使用 synchronized 关键字创建同步块，确保只有一个线程可以访问同步块内的代码。

public synchronized void synchronizedMethod() {
    // 同步块内的代码
}

锁

Java 中的锁用于协调多个线程对共享资源的访问。常见的锁包括 ReentrantLock 和 synchronized。

ReentrantLock lock = new ReentrantLock();

lock.lock(); // 获取锁
try {
    // 访问共享资源
} finally {
    lock.unlock(); // 释放锁
}

线程通信

线程之间的通信是多线程编程的关键部分。Java 提供了多种机制来实现线程通信，包括 wait()、notify()、notifyAll() 等方法。

class SharedResource {
    private boolean flag = false;

    public synchronized void produce() throws InterruptedException {
        while (flag) {
            wait(); // 等待消费者消费
        }
        // 生产数据
        flag = true;
        notify(); // 唤醒消费者
    }

    public synchronized void consume() throws InterruptedException {
        while (!flag) {
            wait(); // 等待生产者生产
        }
        // 消费数据
        flag = false;
        notify(); // 唤醒生产者
    }
}

线程池

线程池是一种管理和复用线程的机制，可以有效降低线程创建和销毁的开销。Java 提供了 Executor 框架来创建和管理线程池。

ExecutorService executor = Executors.newFixedThreadPool(5); // 创建固定大小的线程池
executor.submit(new MyRunnable()); // 提交任务给线程池
executor.shutdown(); // 关闭线程池

异常处理

多线程编程可能导致各种异常，如 InterruptedException、IllegalThreadStateException 等。合适的异常处理对于程序的稳定性至关重要。

try {
    // 可能抛出异常的代码
} catch (Exception e) {
    // 处理异常
} finally {
    // 最终执行的代码
}

线程安全性与性能

在多线程编程中，线程安全性和性能之间存在权衡关系。过多的同步和锁可能导致性能下降，因此需要根据具体情况进行权衡和优化。

多线程的更多操作方法

除了上述介绍的基本概念和常见操作，Java 多线程还涉及到一些更高级的使用方法和技巧，以下将进一步探讨这些方面。

1. 守护线程（Daemon Threads）

守护线程是一种在后台运行的线程，它的生命周期取决于其他非守护线程是否运行结束。当所有非守护线程结束时，JVM 会自动终止守护线程，而不管它们是否执行完毕。要将线程设置为守护线程，可以使用 setDaemon(true) 方法。

Thread daemonThread = new Thread(new Runnable() {
    public void run() {
        while (true) {
            // 后台任务
        }
    }
});
daemonThread.setDaemon(true);
daemonThread.start();

2. 线程优先级

Java 中的线程可以设置优先级，优先级较高的线程在竞争 CPU 时间片时更有可能获得执行机会。线程的优先级范围从1到10，默认为5。可以使用 setPriority() 方法设置线程的优先级。

Thread highPriorityThread = new Thread(new Runnable() {
    public void run() {
        // 优先级较高的任务
    }
});
highPriorityThread.setPriority(Thread.MAX_PRIORITY);

Thread lowPriorityThread = new Thread(new Runnable() {
    public void run() {
        // 优先级较低的任务
    }
});
lowPriorityThread.setPriority(Thread.MIN_PRIORITY);

注意：线程优先级的精确行为在不同的操作系统上可能有所不同，不应过度依赖线程优先级。

3. 线程组（Thread Groups）

线程组是一种组织和管理线程的机制，它允许将多个线程分组并对它们进行统一管理。可以使用 ThreadGroup 类来创建和管理线程组。

ThreadGroup group = new ThreadGroup("MyThreadGroup");

Thread thread1 = new Thread(group, new Runnable() {
    public void run() {
        // 线程1的任务
    }
});

4. 线程局部变量（Thread-Local Variables）

线程局部变量是一种在每个线程中都有自己独立副本的变量，互不影响。可以使用 ThreadLocal 类来创建线程局部变量。

ThreadLocal<Integer> threadLocal = ThreadLocal.withInitial(() -> 0);

// 在线程中设置和获取局部变量
threadLocal.set(42);
int value = threadLocal.get();

线程局部变量常用于在多线程环境下存储线程特有的信息，如用户会话、数据库连接等。

5. Callable 和 Future

除了实现 Runnable 接口外，还可以使用 Callable 接口来表示一个可调用的任务，并且可以返回结果。通过 Future 对象，可以获取异步任务的执行结果。

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
import java.util.concurrent.FutureTask;

public class MyCallable implements Callable<String> {
    public String call() {
        // 执行任务
        return "Task completed";
    }
}

public static void main(String[] args) throws InterruptedException, ExecutionException {
    Callable<String> callable = new MyCallable();
    FutureTask<String> futureTask = new FutureTask<>(callable);

    Thread thread = new Thread(futureTask);
    thread.start();

    String result = futureTask.get(); // 获取任务结果
    System.out.println(result);
}

Callable 和 Future 是 Java 并发编程中非常有用的工具，可用于处理需要返回结果的多线程任务。

6. 并发集合（Concurrent Collections）

Java 提供了一些线程安全的集合类，如 ConcurrentHashMap、ConcurrentLinkedQueue 等，这些集合类可以在多线程环境下安全地进行读写操作。

ConcurrentMap<String, Integer> map = new ConcurrentHashMap<>();
map.put("key1", 1);
map.put("key2", 2);

ConcurrentLinkedQueue<Integer> queue = new ConcurrentLinkedQueue<>();
queue.offer(42);

这些集合类可以减少在多线程环境下使用显式锁的需求，提高了程序的并发性能。

7. 并行编程框架

Java 提供了并行编程框架，如 Fork/Join 框架，可以简化并行任务的拆分和执行。这对于处理大规模并行任务非常有用。

import java.util.concurrent.RecursiveTask;
import java.util.concurrent.ForkJoinPool;

public class MyTask extends RecursiveTask<Integer> {
    protected Integer compute() {
        // 执行任务
    }
}

public static void main(String[] args) {
    ForkJoinPool pool = new ForkJoinPool();
    MyTask task = new MyTask();
    int result = pool.invoke(task);
}

注意事项

当编写多线程应用程序时，需要注意以下一些重要的事项，以确保程序的正确性和性能：

  1. 线程安全性（Thread Safety）： 多个线程可能同时访问共享数据，确保共享数据的安全性至关重要。使用同步机制，如 synchronized 块或 Lock 接口，来保护共享资源的访问。

  2. 死锁（Deadlock）： 死锁是指两个或多个线程相互等待对方释放资源的情况，从而导致程序无法继续执行。要小心避免死锁，使用适当的同步策略和资源分配算法。

  3. 竞态条件（Race Condition）： 竞态条件发生在多个线程试图同时修改共享数据时，导致不确定的结果。使用同步机制和原子操作来避免竞态条件。

  4. 性能考虑： 多线程应用程序的性能可能受到线程创建和销毁的开销，以及线程间的竞争条件的影响。使用线程池等技术来管理线程的生命周期，以提高性能。

  5. 线程间通信： 多个线程可能需要相互通信和协调工作。使用 wait()、notify()、notifyAll() 等方法来实现线程间的有效通信。

  6. 资源管理： 确保在使用完资源后正确地释放它们，以避免资源泄漏。对于文件、数据库连接等资源，使用 try-with-resources 或手动释放资源。

  7. 异常处理： 要小心处理线程中的异常。线程异常未捕获可能导致整个应用程序崩溃。确保在线程中使用 try-catch 块来捕获并处理异常。

  8. 线程终止： 确保线程在不再需要时正确地终止。避免使用 stop() 方法，而是使用标志位或其他方式来通知线程退出。

  9. 性能调优： 随着线程数量的增加，线程切换和上下文切换的开销也会增加。要根据应用程序的需求和硬件配置来调整线程数量。

  10. 可测试性： 编写可测试的多线程代码可能会更具挑战性。使用模拟对象、单元测试和集成测试来验证多线程代码的正确性。

  11. 避免共享可变状态： 尽可能避免多个线程共享可变状态，而是使用不可变对象或线程本地存储来减少竞态条件。

  12. 线程池： 对于频繁创建和销毁线程的情况，考虑使用线程池来重用线程，以减少开销和提高性能。

  13. CPU 和 I/O 绑定： 确保线程的工作类型与其执行的任务相匹配。CPU 密集型任务可能需要更多的线程，而 I/O 密集型任务可能需要较少的线程。

  14. 线程命名： 为了更好地识别和调试线程，可以为线程设置有意义的名称。

  15. 监控和诊断： 使用工具和库来监控线程的状态、性能和健康情况。常用的工具包括 VisualVM、JConsole、线程转储分析等。

  16. 不要滥用多线程： 不是所有的问题都需要多线程来解决。在考虑使用多线程之前，先评估问题的性质和需求，确保多线程是合理的选择。

遵循这些注意事项可以帮助您编写更可靠、高性能的多线程应用程序，并降低出现问题的可能性。同时，多线程编程需要谨慎和经验，建议在实际应用中不断学习和优化。

总结

本篇博客详细介绍了 Java 多线程编程的基本概念、创建线程、线程生命周期、线程同步与互斥、线程通信、线程池、异常处理等方面的内容。多线程编程是 Java 开发中的重要主题，希望本文能帮助读者更好地理解和应用多线程技术。

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

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

相关文章

【JS】—垃圾回收机制

【JS】—垃圾回收机制

一、指令材料 1.定义 JavaScript&#xff08;JS&#xff09;的垃圾回收机制是一种自动管理内存的过程&#xff0c;它有助于释放不再使用的内存&#xff0c;以避免内存泄漏和提高程序的性能。 JavaScript的垃圾回收机制是一种自动管理内存的方式&#xff0c;以确保不再被引用的…
阅读更多...
【RocketMQ】路由中心NameServer

【RocketMQ】路由中心NameServer

【RocketMQ】路由中心NameServer 参考资料&#xff1a; RocketMQ Nameserver 背后的设计理念 RocketMQ之NameServer详解 深入剖析RocketMQ源码-NameServer —— vivo互联网技术 《RocketMQ技术内幕》 文章目录 【RocketMQ】路由中心NameServerNameServer架构设计NameServer工作…
阅读更多...
上海亚商投顾：沪指震荡调整 两市成交金额跌破6000亿

上海亚商投顾：沪指震荡调整 两市成交金额跌破6000亿

上海亚商投顾前言&#xff1a;无惧大盘涨跌&#xff0c;解密龙虎榜资金&#xff0c;跟踪一线游资和机构资金动向&#xff0c;识别短期热点和强势个股。 一.市场情绪 三大指数昨日集体调整&#xff0c;创业板指续创3年多以来新低。ST板块继续走强&#xff0c;*ST柏龙、ST恒久等…
阅读更多...
笔记2.2：网络应用基本原理

笔记2.2：网络应用基本原理

一. 网络应用的体系结构 &#xff08;1&#xff09;客户机/服务器结构&#xff08;Client-Server, C/S&#xff09; &#xff08;2&#xff09;点对点结构&#xff08;Peer-to-Peer&#xff0c;P2P&#xff09; &#xff08;3&#xff09;混合结构&#xff08;Hybrid&#x…
阅读更多...
leetcode646. 最长数对链(java)

leetcode646. 最长数对链(java)

最长数对链 题目描述贪心解法二 动态规划 dp 题目描述 难度 - 中等 leetcode646. 最长数对链(java) 给你一个由 n 个数对组成的数对数组 pairs &#xff0c;其中 pairs[i] [lefti, righti] 且 lefti < righti 。 现在&#xff0c;我们定义一种 跟随 关系&#xff0c;当且仅…
阅读更多...
数字散斑干涉测量仿真研究

数字散斑干涉测量仿真研究

一、引言 数字散斑干涉技术(digital speckle pattern interferometry&#xff0c;DSPI)是一种测量物体表面微小变形的测量技术&#xff0c;在生物医学检测、缺陷无损检测、精密制造、材料与结构力学参数评估等领域起着日益重要的作用&#xff0c;具有实时性、高精度、非接触、…
阅读更多...
npm、yarn、pnpm如何清除缓存？

npm、yarn、pnpm如何清除缓存？

前端工程化创建项目会经常使用各种安装包管理工具&#xff0c;安装各种前端依赖包。例如&#xff0c;npm、yarn、pnpm等。时间一长&#xff0c;各种安装包管理工具的在安装依赖时&#xff0c;留下的缓存文件就会变得很大&#xff0c;以至于影响系统的运行&#xff0c;因此必要时…
阅读更多...
kdxf speex

kdxf speex

speex import subprocess# 定义FFmpeg命令 ffmpeg_command [ffmpeg,#-f, dshow,-i, rd:\tug\iat_mp3_16k.mp3,-acodec, speex,-ar, 16000,-ab, 16000,-ac, 1,output.spx ] spxcmdspxTest -enc 16000 7 1280 D:\\tug\iat_pcm_16k.pcm 1.speex #ffmpeg -f dshow -i audio"…
阅读更多...
易优cms安装插件时显示空白一片处理方法

易优cms安装插件时显示空白一片处理方法

检查网站权限是否自己改过&#xff0c;看下图操作
阅读更多...
camera驱动层和硬件层简介

camera驱动层和硬件层简介

目录 Camera Driver 1. V4L2 框架简介 1&#xff09;关键结构体 2&#xff09;模块初始化 3&#xff09;处理用户空间请求 2. 高通KMD框架详解 1&#xff09;概览 2&#xff09;核心模块解析 3&#xff09;模块初始化 4&#xff09;处理UMD CSL请求 Camera Hardware…
阅读更多...
孤网双机并联逆变器下垂控制策略MATLAB仿真模型

孤网双机并联逆变器下垂控制策略MATLAB仿真模型

微❤关注“电气仔推送”获得资料 主体模块&#xff1a; 建议使用MATLAB2021b及以上版本打开&#xff01; 功率计算模块、下垂控制模块、电压电流双环控制模块 系统输出有功功率: 系统输出无功功率&#xff1a; 系统频率变化曲线: 参考文献&#xff1a; 微电网并网运行模式下…
阅读更多...
智慧燃气管网监控预警系统探析

智慧燃气管网监控预警系统探析

关键词&#xff1a;智慧燃气、智能管网、智慧燃气系统、智能燃气、燃气监控、数据挖掘 “智慧城市”是我国当前城市发展的新理念&#xff0c;“智慧城市”离不开天然气等清洁能源的普及和发展&#xff0c;在这一理念的指引下&#xff0c;我国城市的燃气使用普及率和使用范围都…
阅读更多...
2023-09-20 Teaching Note for Class 1

2023-09-20 Teaching Note for Class 1

文章目录 1. Sign-in Result2. Content of Course3. History of Computer4. Free Topic 1. Sign-in Result Let’s take a look at the sign-in result Everybody is here. 2. Content of Course the course consists of eight modules 3. History of Computer 4. Free To…
阅读更多...
求生之路2服务器搭建插件安装及详细的游戏参数配置教程windows

求生之路2服务器搭建插件安装及详细的游戏参数配置教程windows

求生之路2服务器搭建插件安装及详细的游戏参数配置教程windows 大家好我是艾西&#xff0c;最近研究了下 l4d2&#xff08;求生之路2&#xff09;这款游戏的搭建以及架设过程。今天就给喜欢l4d2这款游戏的小伙伴们分享下怎么搭建架设一个自己的服务器。毕竟自己当服主是热爱游…
阅读更多...
基于matlab实现的光折射反射（不同界面）程序

基于matlab实现的光折射反射（不同界面）程序

完整程序: %平面电磁波在不同介质界面上入射、反射、折射仿真 %ReadMe!!!在下述说明的用户输入区内输入入射角和两介质折射率&#xff0c; %输出反射折射示意图与反射折射系数随入射角变化的曲线 %—————————————————————————————————————…
阅读更多...
我想设计一套游戏的奖励系统，有什么值得注意的？

我想设计一套游戏的奖励系统，有什么值得注意的？

游戏上&#xff1a; 游戏成就系统的价值 游戏中的成就可以延长游戏时间&#xff0c;让玩家不仅仅是将游戏通关&#xff0c;而是必须完成游戏内所有挑战及发现秘密&#xff0c;这些成就可以与游戏本身的目标一致&#xff0c;也可以独立于游戏的主要或次要目标之外&#xff0c;…
阅读更多...
flink集群与资源@k8s源码分析-资源III 声明式资源管理

flink集群与资源@k8s源码分析-资源III 声明式资源管理

1 资源 资源分析分3部分，资源请求，资源提供，声明式资源管理，本文是第三部分声明式资源管理 2 检查资源需求/检查资源声明 检查资源需求/检查资源声明是flink声明式资源管理的核心方法 上面的资源场景分为两类，提出资源需求和提供资源， 检查资源请求/检查资源声明是交…
阅读更多...
Unity HDRP 录制透明通道序列帧

Unity HDRP 录制透明通道序列帧

一、插件 使用插件为Unity Recorder&#xff0c;可在PackageManager搜索Recorder安装 然后打开插件面板 二、Image Sequence 添加Image Sequence&#xff0c;摄像机选择主摄即可&#xff0c;图片格式选PNG&#xff0c;并勾选Include Alpha 此时点击 START RECORDING 即可…
阅读更多...
Linux常用命令 - 用户管理命令

Linux常用命令 - 用户管理命令

用户管理命令 useradd 功能&#xff1a;添加用户。 选项功能-d指定用户主目录-m创建用户的主目录-g指定用户的用户组-s指定用户的shell-D显示useradd命令当前的默认值 不同的linux系统默认选项不一样&#xff0c;比如Ubuntu系统useradd命令默认只创建用户&#xff0c;不会创…
阅读更多...
Spring Boot虚拟线程的性能还不如Webflux？

Spring Boot虚拟线程的性能还不如Webflux？

早上看到一篇关于Spring Boot虚拟线程和Webflux性能对比的文章&#xff0c;觉得还不错。内容较长&#xff0c;抓重点给大家介绍一下这篇文章的核心内容&#xff0c;方便大家快速阅读。 测试场景 作者采用了一个尽可能贴近现实操作的场景&#xff1a; 从授权头信息中提取JWT验证…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023