Java 编码系列：线程基础与最佳实践

引言

在多任务处理和并发编程中，线程是不可或缺的一部分。Java 提供了丰富的线程管理和并发控制机制，使得开发者可以轻松地实现多线程应用。本文将深入探讨 Java 线程的基础知识，包括 Thread 类、Runnable 接口、Callable 接口以及线程的生命周期，并结合大厂的最佳实践和底层核心原理，帮助读者全面掌握这些关键技术。

1. 线程基础
1.1 什么是线程

线程是操作系统能够进行运算调度的最小单位。它被包含在进程之中，是进程中的实际运作单位。一个进程可以包含多个线程，这些线程共享进程的资源，如内存和文件句柄。

1.2 线程的优势
  • 提高响应速度：通过多线程，可以同时执行多个任务，提高应用程序的响应速度。
  • 资源共享：线程共享进程的资源，减少了资源开销。
  • 简化编程模型：多线程编程模型使得复杂的任务可以分解为多个简单的任务并行执行。
2. 创建线程的方式
2.1 继承 Thread 类

通过继承 Thread 类并重写 run 方法，可以创建一个新的线程。

class MyThread extends Thread {@Overridepublic void run() {System.out.println("线程 " + Thread.currentThread().getName() + " 运行中...");}
}public class ThreadExample {public static void main(String[] args) {MyThread myThread = new MyThread();myThread.start(); // 启动线程}
}
2.2 实现 Runnable 接口

通过实现 Runnable 接口并实现 run 方法，可以创建一个新的线程。这种方式更加灵活，因为一个 Runnable 对象可以被多个线程共享。

class MyRunnable implements Runnable {@Overridepublic void run() {System.out.println("线程 " + Thread.currentThread().getName() + " 运行中...");}
}public class RunnableExample {public static void main(String[] args) {MyRunnable myRunnable = new MyRunnable();Thread thread = new Thread(myRunnable, "MyThread");thread.start(); // 启动线程}
}
2.3 实现 Callable 接口

Callable 接口类似于 Runnable，但它可以返回一个结果，并且可以抛出异常。Callable 接口通常与 Future 和 ExecutorService 一起使用。

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;class MyCallable implements Callable<Integer> {@Overridepublic Integer call() throws Exception {int sum = 0;for (int i = 0; i < 100; i++) {sum += i;}return sum;}
}public class CallableExample {public static void main(String[] args) {ExecutorService executorService = Executors.newFixedThreadPool(2);Future<Integer> future = executorService.submit(new MyCallable());try {int result = future.get(); // 获取结果System.out.println("计算结果: " + result);} catch (InterruptedException | ExecutionException e) {e.printStackTrace();} finally {executorService.shutdown(); // 关闭线程池}}
}
3. 线程的生命周期
3.1 线程状态

Java 线程有以下几种状态：

  • New：线程被创建但尚未启动。
  • Runnable：线程正在 JVM 中运行，但可能在等待操作系统资源。
  • Blocked：线程被阻塞，等待监视器锁。
  • Waiting：线程在等待另一个线程执行特定操作。
  • Timed Waiting：线程在等待指定的时间。
  • Terminated：线程已退出。
3.2 线程状态转换
  • New -> Runnable：调用 start 方法。
  • Runnable -> Blocked：尝试获取已被其他线程持有的锁。
  • Runnable -> Waiting：调用 wait、join 或 LockSupport.park 方法。
  • Runnable -> Timed Waiting：调用 sleep、wait(long)、join(long) 或 LockSupport.parkNanos 方法。
  • Blocked -> Runnable：获取到所需的锁。
  • Waiting -> Runnable：等待的条件满足。
  • Timed Waiting -> Runnable：等待时间到期。
  • Runnable -> Terminated：线程的 run 方法执行完毕或因未捕获的异常而终止。
4. 线程同步
4.1 同步方法

通过在方法上使用 synchronized 关键字，可以确保同一时间只有一个线程可以访问该方法。

public class SynchronizedMethodExample {private int count = 0;public synchronized void increment() {count++;}public static void main(String[] args) {SynchronizedMethodExample example = new SynchronizedMethodExample();Thread t1 = new Thread(() -> {for (int i = 0; i < 1000; i++) {example.increment();}});Thread t2 = new Thread(() -> {for (int i = 0; i < 1000; i++) {example.increment();}});t1.start();t2.start();try {t1.join();t2.join();} catch (InterruptedException e) {e.printStackTrace();}System.out.println("最终计数: " + example.count);}
}
4.2 同步代码块

通过在代码块上使用 synchronized 关键字，可以确保同一时间只有一个线程可以访问该代码块。

public class SynchronizedBlockExample {private int count = 0;private final Object lock = new Object();public void increment() {synchronized (lock) {count++;}}public static void main(String[] args) {SynchronizedBlockExample example = new SynchronizedBlockExample();Thread t1 = new Thread(() -> {for (int i = 0; i < 1000; i++) {example.increment();}});Thread t2 = new Thread(() -> {for (int i = 0; i < 1000; i++) {example.increment();}});t1.start();t2.start();try {t1.join();t2.join();} catch (InterruptedException e) {e.printStackTrace();}System.out.println("最终计数: " + example.count);}
}
5. 线程间通信
5.1 wait 和 notify 方法

wait 和 notify 方法用于线程间的通信。wait 方法使当前线程进入等待状态，notify 方法唤醒一个等待的线程。

public class WaitNotifyExample {private final Object lock = new Object();private boolean flag = false;public void producer() {synchronized (lock) {while (flag) {try {lock.wait();} catch (InterruptedException e) {e.printStackTrace();}}// 生产数据System.out.println("生产数据");flag = true;lock.notify();}}public void consumer() {synchronized (lock) {while (!flag) {try {lock.wait();} catch (InterruptedException e) {e.printStackTrace();}}// 消费数据System.out.println("消费数据");flag = false;lock.notify();}}public static void main(String[] args) {WaitNotifyExample example = new WaitNotifyExample();Thread producerThread = new Thread(() -> {for (int i = 0; i < 5; i++) {example.producer();}});Thread consumerThread = new Thread(() -> {for (int i = 0; i < 5; i++) {example.consumer();}});producerThread.start();consumerThread.start();}
}
6. 线程池
6.1 什么是线程池

线程池是一种多线程处理形式，处理过程中将任务添加到队列，然后在创建线程后自动启动这些任务。线程池可以有效控制运行的线程数量，减少创建和销毁线程的开销。

6.2 创建线程池

Java 提供了 ExecutorService 接口和 Executors 工具类来创建和管理线程池。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class ThreadPoolExample {public static void main(String[] args) {ExecutorService executorService = Executors.newFixedThreadPool(2);for (int i = 0; i < 5; i++) {int taskId = i;executorService.execute(() -> {System.out.println("任务 " + taskId + " 在线程 " + Thread.currentThread().getName() + " 上运行");});}executorService.shutdown(); // 关闭线程池}
}
7. 大厂最佳实践
7.1 阿里巴巴《Java开发手册》
  • 避免滥用线程：合理使用线程池，避免频繁创建和销毁线程。
  • 同步方法优先：在多线程环境中，优先使用同步方法或同步代码块。
  • 避免死锁：设计线程同步时，避免出现死锁的情况。
7.2 Google Java Style Guide
  • 线程安全：确保多线程环境下的代码是线程安全的。
  • 资源管理：使用 try-with-resources 语句管理资源，确保资源在使用后正确释放。
  • 异常处理：合理处理线程中的异常，避免未捕获的异常导致线程终止。
7.3 Oracle 官方文档
  • 线程池：推荐使用 ExecutorService 来管理线程池，提高线程的复用率。
  • 线程同步：使用 synchronized 关键字或 ReentrantLock 来实现线程同步。
  • 线程间通信：使用 wait 和 notify 方法实现线程间的通信。
8. 底层核心原理
8.1 线程调度
  • 时间片轮转：操作系统通过时间片轮转的方式调度线程，每个线程在分配的时间片内运行。
  • 优先级：线程的优先级决定了线程被调度的频率，优先级高的线程更有可能被调度。
8.2 线程同步
  • 锁机制：synchronized 关键字和 ReentrantLock 都是基于锁机制实现的线程同步。
  • 监视器锁：synchronized 关键字使用的是监视器锁（Monitor），每个对象都有一个监视器锁。
8.3 线程间通信
  • 等待/通知机制：wait 和 notify 方法通过等待/通知机制实现线程间的通信。
  • 条件变量：Condition 接口提供了更灵活的等待/通知机制，可以替代 wait 和 notify。
9. 示例代码
9.1 继承 Thread 类
class MyThread extends Thread {@Overridepublic void run() {System.out.println("线程 " + Thread.currentThread().getName() + " 运行中...");}
}public class ThreadExample {public static void main(String[] args) {MyThread myThread = new MyThread();myThread.start(); // 启动线程}
}
9.2 实现 Runnable 接口
class MyRunnable implements Runnable {@Overridepublic void run() {System.out.println("线程 " + Thread.currentThread().getName() + " 运行中...");}
}public class RunnableExample {public static void main(String[] args) {MyRunnable myRunnable = new MyRunnable();Thread thread = new Thread(myRunnable, "MyThread");thread.start(); // 启动线程}
}
9.3 实现 Callable 接口
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;class MyCallable implements Callable<Integer> {@Overridepublic Integer call() throws Exception {int sum = 0;for (int i = 0; i < 100; i++) {sum += i;}return sum;}
}public class CallableExample {public static void main(String[] args) {ExecutorService executorService = Executors.newFixedThreadPool(2);Future<Integer> future = executorService.submit(new MyCallable());try {int result = future.get(); // 获取结果System.out.println("计算结果: " + result);} catch (InterruptedException | ExecutionException e) {e.printStackTrace();} finally {executorService.shutdown(); // 关闭线程池}}
}
9.4 线程同步
public class SynchronizedMethodExample {private int count = 0;public synchronized void increment() {count++;}public static void main(String[] args) {SynchronizedMethodExample example = new SynchronizedMethodExample();Thread t1 = new Thread(() -> {for (int i = 0; i < 1000; i++) {example.increment();}});Thread t2 = new Thread(() -> {for (int i = 0; i < 1000; i++) {example.increment();}});t1.start();t2.start();try {t1.join();t2.join();} catch (InterruptedException e) {e.printStackTrace();}System.out.println("最终计数: " + example.count);}
}
9.5 线程间通信
public class WaitNotifyExample {private final Object lock = new Object();private boolean flag = false;public void producer() {synchronized (lock) {while (flag) {try {lock.wait();} catch (InterruptedException e) {e.printStackTrace();}}// 生产数据System.out.println("生产数据");flag = true;lock.notify();}}public void consumer() {synchronized (lock) {while (!flag) {try {lock.wait();} catch (InterruptedException e) {e.printStackTrace();}}// 消费数据System.out.println("消费数据");flag = false;lock.notify();}}public static void main(String[] args) {WaitNotifyExample example = new WaitNotifyExample();Thread producerThread = new Thread(() -> {for (int i = 0; i < 5; i++) {example.producer();}});Thread consumerThread = new Thread(() -> {for (int i = 0; i < 5; i++) {example.consumer();}});producerThread.start();consumerThread.start();}
}
10. 总结

本文深入探讨了 Java 线程的基础知识，包括 Thread 类、Runnable 接口、Callable 接口以及线程的生命周期，并结合大厂的最佳实践和底层核心原理，帮助读者全面掌握这些关键技术。合理地使用线程管理机制可以提高程序的性能和响应速度，避免线程安全问题。希望本文对你有所帮助，如果你有任何问题或建议，欢迎留言交流。

希望这篇文章能够满足你的需求，如果有任何进一步的问题或需要更多内容，请随时告诉我！

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

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

相关文章

Vue引入js脚本问题记录（附解决办法）

Vue引入js脚本问题记录（附解决办法）

目录 一、需求 二、import引入问题记录 三、解决方式 一、需求 我想在我的Vue项目中引入jquery.js和bootstrap.js这种脚本文件&#xff0c;但发现不能单纯的import引入&#xff0c;问题如下。 二、import引入问题记录 我直接这么引入&#xff0c;发现控制台报错TypeError: …
阅读更多...
华为HarmonyOS地图服务 11 - 如何在地图上增加点注释？

华为HarmonyOS地图服务 11 - 如何在地图上增加点注释？

场景介绍 本章节将向您介绍如何在地图的指定位置添加点注释以标识位置、商家、建筑等&#xff0c;并可以通过信息窗口展示详细信息。 点注释支持功能&#xff1a; 支持设置图标、文字、碰撞规则等。支持添加点击事件。 PointAnnotation有默认风格&#xff0c;同时也支持自定…
阅读更多...
vue通过ref实现组件之间传值

vue通过ref实现组件之间传值

文章目录 概述父组件向子组件传值示例 子组件通知父组件示例 概述 在Vue 2中&#xff0c;可以使用ref属性在父子组件之间传递值。父组件可以通过ref属性获取子组件的实例&#xff0c;进而访问子组件的方法和数据。 父组件向子组件传值 示例 父组件 (Parent.vue): <temp…
阅读更多...
Xk8s证书续期

Xk8s证书续期

Master节点 备份文件 cp -r /etc/kubernetes/ /etc/kubernetes-20211021-bak tar -cvzf kubernetes-20211021-bak.tar.gz /etc/kubernetes-20211021-bak/cp -r ~/.kube/ ~/.kube-20211021-bak tar -cvzf kube-20211021-bak.tar.gz ~/.kube-20211021-bakcp -r /var/lib/kube…
阅读更多...
嵌入式内存优化可以从哪些方面下手？

嵌入式内存优化可以从哪些方面下手？

在嵌入式开发中&#xff0c;内存管理是一项至关重要的任务&#xff0c;直接影响到系统的稳定性和性能。由于嵌入式设备通常资源有限&#xff0c;尤其是内存资源&#xff0c;因此内存管理与优化显得尤为重要。 1&#xff09;避免内存泄漏&#xff1a;使用智能指针、RAII&#x…
阅读更多...
⭐ Unity 对象池的应用 Cube流星落

⭐ Unity 对象池的应用 Cube流星落

此次Demo里生成一些 Cube 从天上往下掉&#xff0c;并且当它们掉到特定高度&#xff08;例如 y 轴小于 0&#xff09;时销毁。为了优化性能&#xff0c;避免频繁创建和销毁物体&#xff0c;使用 对象池&#xff08;Object Pooling&#xff09; 技术来复用这些 Cube。 先看一下…
阅读更多...
《强化学习的数学原理》(2024春)_西湖大学赵世钰 Ch9 策略梯度方法 Box 8.1 马尔可夫决策过程的平稳分布

《强化学习的数学原理》(2024春)_西湖大学赵世钰 Ch9 策略梯度方法 Box 8.1 马尔可夫决策过程的平稳分布

Box 8.1&#xff1a; 马尔可夫决策过程的平稳分布 整理自 链接 分析平稳分布的关键工具是 P π ∈ R n n P_\pi \in {\mathbb R}^{n\times n} Pπ​∈Rnn&#xff0c;它是给定策略 π π π 下的概率转移矩阵。 如果状态被索引为 s 1 , ⋯ , s n s_1,\cdots, s_n s1​,⋯…
阅读更多...
idea2021git从dev分支合并到主分支master

idea2021git从dev分支合并到主分支master

1、新建分支 新建一个名称为dev的分支&#xff0c;切换到该分支下面&#xff0c;输入新内容 提交代码到dev分支的仓库 2、切换分支 切换到主分支&#xff0c;因为刚刚提交的分支在dev环境&#xff0c;所以master是没有 3、合并分支 点击push&#xff0c;将dev里面的代码合并到…
阅读更多...
图片尺寸不合适？这3款免费好用的AI绘图神器帮你免费无缝拓展！一键扩展画面之外的内容，真的泰裤啦！

图片尺寸不合适？这3款免费好用的AI绘图神器帮你免费无缝拓展！一键扩展画面之外的内容，真的泰裤啦！

大家好&#xff0c;我是灵魂画师向阳 在处理图片素材时&#xff0c;大家有没有遇到过尺寸不合适但又不能裁切的情况&#xff1f;是不是也想过图像要是能自己“长”出一块就好了&#xff1f;这种要求在以前或许很难实现&#xff0c;但生产式 AI 技术出现后它就不再是问题了&…
阅读更多...
基于GIKT深度知识追踪模型的习题推荐系统源代码+数据库+使用说明，后端采用flask，前端采用vue

基于GIKT深度知识追踪模型的习题推荐系统源代码+数据库+使用说明，后端采用flask，前端采用vue

基于GIKT深度知识追踪模型的习题推荐系统 目录结构 Flask-BackEnd flask后端 app 后端主体文件 alg 深度学习模块 data 数据集data_process.py 数据预处理gikt.py GIKT模型pebg.py PEBG模型params.py 一些参数train.py 仅模型训练train_test.py 模型训练和测试-五折交叉验证t…
阅读更多...
WebGIS开发四大开源框架对比

WebGIS开发四大开源框架对比

本篇文章主要介绍GIS开发四大地图框架的差异和特点。 Cesium: Cesium是目前主流的一款三维地图框架&#xff0c;支持桌面端、web端、移动端等多平台。Mapbox&#xff1a;高清经纬度矢量瓦片&#xff0c;个性化前端表达&#xff0c;前端矢量绘制&#xff0c;支持海量地名地址。…
阅读更多...
数据库实验2—1

数据库实验2—1

10-1 查询重量在[40,65]之间的产品信息 本题目要求编写SQL语句&#xff0c; 检索出product表中所有符合40 < Weight < 65的记录。 提示&#xff1a;请使用SELECT语句作答。 表结构: CREATE TABLE product (Pid varchar(20), --商品编号PName varchar(50), --商品名称…
阅读更多...
[论文总结] 深度学习在农业领域应用论文笔记13

[论文总结] 深度学习在农业领域应用论文笔记13

文章目录 1. Downscaling crop production data to fine scale estimates with geostatistics and remote sensing: a case study in mapping cotton fibre quality &#xff08;Precision Agriculture &#xff0c;2024&#xff0c; IF5.585&#xff09;背景方法结果结论个人总…
阅读更多...
仓颉编程入门2，启动HTTP服务

仓颉编程入门2，启动HTTP服务

上一篇配置了仓颉sdk编译和运行环境&#xff0c;读取一个配置文件&#xff0c;并把配置文件简单解析了一下。 前面读取配置文件&#xff0c;使用File.readFrom()&#xff0c;这个直接把文件全部读取出来&#xff0c;返回一个字节数组。然后又创建一个字节流&#xff0c;给文件…
阅读更多...
C语言实现常见的数据结构

C语言实现常见的数据结构

栈 栈是一种后进先出&#xff08;LIFO, Last In First Out&#xff09;的数据结构 #include <stdio.h> #include <stdlib.h>#define MAX 100typedef struct {int data[MAX];int top; } Stack;// 初始化栈 void init(Stack *s) {s->top -1; }// 判断栈是否为空…
阅读更多...
kafka 消息位移提交几种方式:消息重复消息、消息丢失的关键

kafka 消息位移提交几种方式:消息重复消息、消息丢失的关键

消费位移 Kafka 中的位移&#xff08;offset&#xff09;是用来记录消息在分区中的位置的标志&#xff0c;简单说就是记录消费者的消费进度&#xff0c;每次消息消费后需要更新消费进度&#xff0c;也就是位移提交 由此可见一旦位移提交发生异常&#xff0c;会导致消费进度不正…
阅读更多...
VBA技术资料MF204：右键多按钮弹出菜单中使用图标

VBA技术资料MF204：右键多按钮弹出菜单中使用图标

我给VBA的定义&#xff1a;VBA是个人小型自动化处理的有效工具。利用好了&#xff0c;可以大大提高自己的工作效率&#xff0c;而且可以提高数据的准确度。“VBA语言専攻”提供的教程一共九套&#xff0c;分为初级、中级、高级三大部分&#xff0c;教程是对VBA的系统讲解&#…
阅读更多...
p,div等里面支持br换行 对应后台换过来的textarea的富文本内容

p,div等里面支持br换行 对应后台换过来的textarea的富文本内容

如何使用CSS来支持或者允许<br>标签在HTML中创建换行。<br>标签是一个空元素&#xff0c;它的存在表示在HTML中的那个位置需要一个换行。 在CSS中&#xff0c;使用white-space属性来控制文本的换行行为。设置white-space: pre-wrap; 这样的属性&#xff0c;这样就…
阅读更多...
【python】【绘制小程序】动态爱心绘制

【python】【绘制小程序】动态爱心绘制

背景介绍 参考链接&#xff1a;https://blog.csdn.net/Python_HUHU/article/details/139703289点的背景颜色在开始修改&#xff1b;文字的颜色在最后修改。文字内容可以修改。 python 代码 import tkinter as tk import random from math import sin, cos, pi, log from PIL…
阅读更多...
学习篇 | Jupyter 使用（notebook hub）

学习篇 | Jupyter 使用（notebook hub）

1. JupyterHub 1.1 快速尝试 jupyterhub -f/path/jupyter_config.py --no-ssl1.2 长期后台运行 bash -c "nohup jupyterhub -f/path/jupyter_config.py --no-ssl" > ~/jupyterhub.log 2>&1 &1.3 帮助 jupyterhub --help2. Jupyter Notebook 2.1 快…
阅读更多...
最新文章

Copyright @ 2022~2023