深入解析Java多线程：源码级别的分析与实践

Java的多线程机制是其并发编程的核心，对于高性能和高并发应用的开发至关重要。

一、Java多线程的基础

1.1 创建线程的几种方式

在Java中，有几种创建线程的方式：

  1. 继承Thread类：

    class MyThread extends Thread {public void run() {System.out.println("MyThread is running");}
}public class Main {public static void main(String[] args) {MyThread thread = new MyThread();thread.start();}
}

  2. 实现Runnable接口：

    class MyRunnable implements Runnable {public void run() {System.out.println("MyRunnable is running");}
}public class Main {public static void main(String[] args) {Thread thread = new Thread(new MyRunnable());thread.start();}
}

  3. 使用Callable接口和FutureTask：

    import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;class MyCallable implements Callable<String> {public String call() throws Exception {return "MyCallable is running";}
}public class Main {public static void main(String[] args) throws ExecutionException, InterruptedException {FutureTask<String> futureTask = new FutureTask<>(new MyCallable());Thread thread = new Thread(futureTask);thread.start();System.out.println(futureTask.get());}
}

1.2 线程的生命周期

线程的生命周期主要包括以下几个阶段：

  • 新建（New）：创建线程对象但未调用start()方法。
  • 就绪（Runnable）：调用start()方法，线程进入就绪队列，等待CPU调度。
  • 运行（Running）：线程被CPU调度执行其run()方法。
  • 阻塞（Blocked）：线程因某种原因进入阻塞状态，如等待I/O操作完成。
  • 死亡（Terminated）：线程执行完run()方法或被异常中断。

二、Java线程安全问题

2.1 线程安全问题的根源

线程安全问题主要源于多个线程同时访问和修改共享资源，而这些访问和修改没有进行适当的同步，导致数据不一致。例如，下面的代码可能会出现线程安全问题：

public class Counter {private int count = 0;public void increment() {count++;}public int getCount() {return count;}
}public class Main {public static void main(String[] args) throws InterruptedException {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();t1.join();t2.join();System.out.println("Final count: " + counter.getCount());}
}

由于count++操作不是原子操作，多个线程可能会同时读取和更新count，导致最终结果不准确。

2.2 解决线程安全问题的方法

2.2.1 同步代码块
public class Counter {private int count = 0;public synchronized void increment() {count++;}public synchronized int getCount() {return count;}
}
2.2.2 使用ReentrantLock
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;public class Counter {private int count = 0;private Lock 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.2.3 使用Atomic变量
import java.util.concurrent.atomic.AtomicInteger;public class Counter {private AtomicInteger count = new AtomicInteger();public void increment() {count.getAndIncrement();}public int getCount() {return count.get();}
}

三、深入解析Java多线程的实现

3.1 synchronized关键字的底层实现

synchronized关键字用于实现同步，它可以应用于方法或代码块。其底层实现依赖于JVM中的对象监视器（Monitor），每个对象都有一个监视器与之关联。

当一个线程进入synchronized方法或代码块时，它必须获得该对象的监视器锁。其他线程如果试图进入同一个代码块，则会被阻塞，直到当前线程释放监视器锁。

3.2 ReentrantLock的实现

ReentrantLock是一个灵活的锁实现，比synchronized提供了更多的功能。它是基于AQS（AbstractQueuedSynchronizer）实现的，AQS通过FIFO队列管理获取锁的线程。

public 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();}}
}

在上面的代码中，lock.lock()获取锁，如果其他线程已经持有该锁，当前线程将被阻塞。lock.unlock()释放锁，使其他线程有机会获取锁。

四、深入了解Java线程池

4.1 线程池的核心配置

线程池是Java并发包中一个非常重要的工具。它通过重用线程来避免频繁创建和销毁线程的开销，提升系统性能。Java中的ExecutorService接口提供了对线程池的支持，而ThreadPoolExecutor类则是其具体实现。

ThreadPoolExecutor有以下几个核心配置：

  • corePoolSize：核心线程数，即使这些线程处于空闲状态，也不会被销毁。
  • maximumPoolSize：线程池中允许的最大线程数。
  • keepAliveTime：当线程数超过corePoolSize时，多余空闲线程的存活时间。
  • unit：keepAliveTime的时间单位。
  • workQueue：用于存放等待执行任务的队列。
  • threadFactory：用于创建新线程的工厂。
  • handler：当线程池和队列都满时，处理被拒绝任务的策略。
import java.util.concurrent.*;public class ThreadPoolExample {public static void main(String[] args) {ThreadPoolExecutor executor = new ThreadPoolExecutor(5,          // corePoolSize10,         // maximumPoolSize60,         // keepAliveTimeTimeUnit.SECONDS,new LinkedBlockingQueue<>(100),  // workQueueExecutors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy()  // handler);for (int i = 0; i < 200; i++) {executor.execute(() -> {System.out.println("Thread " + Thread.currentThread().getName() + " is running");});}executor.shutdown();}
}

4.2 线程池的应用场景

  1. CPU密集型任务：

    • 核心线程数应设置为CPU核心数。
    • 例子：图像处理、科学计算等。

  2. I/O密集型任务：

    • 核心线程数应设置为CPU核心数的2倍或更多。
    • 例子：文件读写、网络通信等。

  3. 混合型任务：

    • 需要根据具体任务类型进行调整，通常可以使用多线程任务拆分技术，如Fork/Join框架。

4.3 线程池的种类

Java的Executors类提供了一些工厂方法来创建常用的线程池：

  1. FixedThreadPool：固定大小的线程池，适用于需要限制并发线程数的场景。

    ExecutorService fixedThreadPool = Executors.newFixedThreadPool(10);

  2. CachedThreadPool：根据需要创建新线程的线程池，适用于短期异步任务多的场景。

    ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

  3. SingleThreadExecutor：单线程执行任务的线程池，适用于需要按顺序执行任务的场景。

    ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();

  4. ScheduledThreadPool：支持定时和周期性任务执行的线程池。

    ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);

4.4 线程池的拒绝策略

当线程池和工作队列都满时，需要对新任务进行处理，ThreadPoolExecutor提供了四种拒绝策略：

  1. AbortPolicy（默认）：抛出RejectedExecutionException异常。
  2. CallerRunsPolicy：由调用线程处理该任务。
  3. DiscardPolicy：直接丢弃任务，不抛异常。
  4. DiscardOldestPolicy：丢弃最早的未处理任务，然后尝试重新提交任务。
ThreadPoolExecutor executor = new ThreadPoolExecutor(5,10,60,TimeUnit.SECONDS,new LinkedBlockingQueue<>(100),Executors.defaultThreadFactory(),new ThreadPoolExecutor.CallerRunsPolicy()
);

五、实战：如何在实际场景中更好地使用多线程

5.1 使用线程池提高性能

线程池通过重用线程来提高性能，避免了频繁创建和销毁线程的开销。Java提供了多种线程池实现，例如Executors类中的newFixedThreadPool、newCachedThreadPool等。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class ThreadPoolExample {public static void main(String[] args) {ExecutorService executor = Executors.newFixedThreadPool(10);for (int i = 0; i < 100; i++) {executor.submit(() -> {System.out.println("Thread " + Thread.currentThread().getName() + " is running");});}executor.shutdown();}
}

5.2 Fork/Join框架

Fork/Join框架用于处理可以递归拆分的任务，例如大规模数据处理。它基于工作窃取算法，能够充分利用多核处理器的优势。

import java.util.concurrent.RecursiveTask;
import java.util.concurrent.ForkJoinPool;public class ForkJoinExample extends RecursiveTask<Long> {private final long threshold = 10_000;private final long start;private final long end;public ForkJoinExample(long start, long end) {this.start = start;this.end = end;}@Overrideprotected Long compute() {if (end - start <= threshold) {long sum = 0;for (long i = start; i <= end; i++) {sum += i;}return sum;} else {long mid = (start + end) / 2;ForkJoinExample leftTask = new ForkJoinExample(start, mid);ForkJoinExample rightTask = new ForkJoinExample(mid + 1, end);leftTask.fork();rightTask.fork();return leftTask.join() + rightTask.join();}}public static void main(String[] args) {ForkJoinPool pool = new ForkJoinPool();ForkJoinExample task = new ForkJoinExample(1, 1_000_000);long result = pool.invoke(task);System.out.println("Sum: " + result);}
}

结语

Java多线程编程不仅涉及基本的线程创建与管理，更需要深入理解底层实现和线程安全机制。在实际开发中，合理使用多线程技术可以显著提升应用性能，但不当的使用也可能导致复杂的并发问题。通过对线程池、synchronized、ReentrantLock以及Fork/Join框架的掌握和实践，能够有效地解决这些问题，构建高效可靠的并发程序。

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

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

相关文章

LangChain框架介绍

LangChain框架介绍

LangChain 的核心组件 模型 I/O 封装 LLMs&#xff1a;大语言模型Chat Models&#xff1a;一般基于 LLMs&#xff0c;但按对话结构重新封装PromptTemple&#xff1a;提示词模板OutputParser&#xff1a;解析输出 数据连接封装 Document Loaders&#xff1a;各种格式文件的加载…
阅读更多...
指纹考勤系统

指纹考勤系统

目录 1.课题研究目的和内容 1.1 课题研究目的 1.2 课题研究内容 2.系统总体方案设计及功能模块介绍 2.1总体方案设计 2.2 ATK-301模块介绍 2.3 TFTLCD显示功能模块介绍 2.4 蜂鸣器报警功能模块介绍 2.5 时钟模块介绍 3.系统硬件设计与实现 3.1 系统硬件电…
阅读更多...
控制应优先

控制应优先

先从大体上的去找规律&#xff0c;然后才是数字归纳&#xff08;更为详细的&#xff09;&#xff0c;同时控制关系应该优先&#xff08;这里是天数和位置&#xff09;。是否涉及所有对象不是广泛&#xff0c;如果是具体的数值就不是广泛。
阅读更多...
指针的认识（传值调用和传地址调用）

指针的认识（传值调用和传地址调用）

学习指针的目的是使用指针解决问题&#xff0c;那什么问题&#xff0c;非指针不可呢&#xff1f; 当要求写个函数来交换两个变量的值时&#xff0c;我们稍加思索&#xff0c;可以写成如下函数&#xff1a; void Swap1(int x, int y) {int tmp x;x y;y tmp; } 那么我们来进…
阅读更多...
Linux学习笔记8

Linux学习笔记8

介绍man命令 在Linux中&#xff0c;man命令用于查看系统手册页&#xff08;manual pages&#xff09;。系统手册页是关于各种Linux命令、函数库以及系统调用的详尽文档&#xff0c;能够提供关于命令的使用方法、参数说明、示例以及其他相关信息 可以利用man xxx的命令去查找某…
阅读更多...
QT之动态加载树节点（QTreeWidget）

QT之动态加载树节点（QTreeWidget）

之前写过一篇动态加载ComboBox&#xff0c;可参见下面这篇文章 QT之动态加载下拉框&#xff08;QComboBox&#xff09; 同理QTreeWidget也可以实现动态加载&#xff0c;在一些异步加载数据&#xff0c;并且数据加载比较耗时&#xff0c;非常实用。 效果 原理分析 要实现此类效…
阅读更多...
docker镜像转移,mac Linux

docker镜像转移,mac Linux

起因是镜像在互联网&#xff0c;而公司内网没有网络&#xff0c;需要跨平台转移&#xff0c;且系统不一样&#xff0c;一个Arm,一个linux。正常进行后&#xff0c;报错系统编译问题&#xff0c;特将处理过程总结一下 在 mac在pull镜像的时候需要设置参数&#xff0c;确保下载的…
阅读更多...
数字展示具有广阔发展空间 市场规模保持增长态势

数字展示具有广阔发展空间 市场规模保持增长态势

数字展示具有广阔发展空间 市场规模保持增长态势 数字展示是指以数字图像为核心&#xff0c;将触摸屏、红外线感应器、三维数字图像等相结合的高层次展示行业。与传统展示方式相比&#xff0c;数字展示能够突破时间、空间及形态的局限&#xff0c;将文字、图像等各种信息转化为…
阅读更多...
Qwen 微调LoRA之后合并模型，使用 webui 测试

Qwen 微调LoRA之后合并模型，使用 webui 测试

Qwen 微调LoRA之后合并模型 qwen_lora_merge.py &#xff1a; import os from peft import AutoPeftModelForCausalLM from transformers import AutoTokenizerdef save_model_and_tokenizer(path_to_adapter, new_model_directory):"""加载模型&#xff0c;合…
阅读更多...
vue 封装水球图

vue 封装水球图

1、 安装 echarts 与 echarts-liquidfill pnpm i echarts pnpm i echarts-liquidfill 2、组件中引入 import * as echarts from echarts import echarts-liquidfill 3、封装通用组件 <div class"waterball-chart"><div ref"chartContainer" s…
阅读更多...
天线对信号传输的效率影响

天线对信号传输的效率影响

天线设计和选择的标准主要包括带宽、极化、方向性、物理空间和增益等方面。这些标准直接影响信号传输的效率和质量。 带宽是指特定信号的频率范围&#xff0c;它决定了天线能够覆盖的频率范围&#xff0c;从而影响信号的传输效率。极化是指天线辐射的电场方向&#xff0c;不同的…
阅读更多...
使用 Vue 3 和 qrcode.js 开发二维码显示组件

使用 Vue 3 和 qrcode.js 开发二维码显示组件

二维码在现代应用中广泛使用&#xff0c;例如支付、身份验证、链接分享等。本文将介绍如何使用 Vue 3 和 qrcode.js 库来创建一个灵活的二维码显示组件&#xff0c;并展示如何在应用中使用它。 1. 安装必要的依赖 首先&#xff0c;我们需要安装 Vue 3 和 qrcode.js。如果你还…
阅读更多...
从C到C++，C++入门篇（1）

从C到C++，C++入门篇（1）

1.什么是C C是一种通用编程语言&#xff0c;由Bjarne Stroustrup在1980年代初开发&#xff0c;作为C语言的扩展。 C支持多种编程范式&#xff0c;包括过程式编程、数据抽象、面向对象编程和泛型编程等。 这种语言在操作系统、游戏开发、图形界面、嵌入式系统、分布式系统、网…
阅读更多...
变压器中的磁化和励磁电流波形

变压器中的磁化和励磁电流波形

导出变压器中的磁化电流和励磁电流的图形方法具有说明性&#xff0c;因为它们使我们能够同时可视化产生这些波形的元素&#xff0c;例如磁通波形和磁性材料的典型 BH 曲线。 所得波形表明它们不是正弦波&#xff0c;并且对于励磁电流而言&#xff0c;它也不对称。 使用傅里叶…
阅读更多...
vue2源码重写数组方法学习

vue2源码重写数组方法学习

在学习之前&#xff0c;我们需要问一个为什么&#xff0c;为什么vue2 源码要重写数组方法 响应式数据更新&#xff1a;通过重写数组方法&#xff0c;Vue 能够捕获对数组的变更操作&#xff08;如 push、pop、shift 等&#xff09;&#xff0c;并在数据发生变化时自动更新视图&a…
阅读更多...
Facebook代运营 | Facebook广告投放步骤及要点

Facebook代运营 | Facebook广告投放步骤及要点

Facebook体量大&#xff0c;素材的更新频率快&#xff0c;通过Facebook进行广告投放的用户也越来越多&#xff0c;Facebook坐拥大量用户&#xff0c;同时有着非常科学的用户画像构建系统和推送机制&#xff0c;对于很多广告涉足的伙伴来说&#xff0c;更加的友好。 1. 创建广告…
阅读更多...
Opentracing 代码Demo

Opentracing 代码Demo

背景 OpenTracing 是一个提供标准化分布式追踪功能的API和工具。它的主要作用包括： 跨系统边界追踪请求流程：OpenTracing 允许开发者跟踪一个请求从开始到结束在整个分布式系统中的所有经过的点（包括异构系统），帮助理解系统中的请求流程和服务间的相互依赖。 性能分析和瓶…
阅读更多...
ubuntu系统 kubeadm方式搭建k8s集群

ubuntu系统 kubeadm方式搭建k8s集群

服务器环境与要求&#xff1a; 三台服务器 k8s-master01 192.168.26.130 操作系统&#xff1a; Ubuntu20.04 k8s-woker01 192.168.26.140 操作系统&#xff1a; Ubuntu20.04 k8s-woker02 192.168.26.150 操作系统&#xff1a; Ubuntu20.04 最低配置&#xff1a;2…
阅读更多...
斯坦福 AI 团队被曝抄袭中国大模型开源成果；Zoom 创始人谈视频会议未来丨 RTE 开发者日报 Vol.218

斯坦福 AI 团队被曝抄袭中国大模型开源成果；Zoom 创始人谈视频会议未来丨 RTE 开发者日报 Vol.218

开发者朋友们大家好&#xff1a; 这里是 「RTE 开发者日报」 &#xff0c;每天和大家一起看新闻、聊八卦。我们的社区编辑团队会整理分享 RTE&#xff08;Real-Time Engagement&#xff09; 领域内「有话题的新闻」、「有态度的观点」、「有意思的数据」、「有思考的文章」、「…
阅读更多...
gradio出现httpcore.ReadTimeout: timed out问题

gradio出现httpcore.ReadTimeout: timed out问题

解决办法 pip install https://gradio-builds.s3.amazonaws.com/aae46d9199e1edc8a22c96aba1ade12f6ebc1da1/gradio-4.21.0-py3-none-any.whl
阅读更多...
最新文章

Copyright @ 2022~2023