【Java】了解线程 Thread 类的使用，如何创建、终止、等待一个线程，一文读懂不迷路

news2024/9/21 22:56:35

线程是什么

线程是操作系统中调度的基本单位，是比进程更小的执行单元。线程在进程内部运行，共享该进程的资源，如内存和文件句柄，但每个线程都有自己的执行栈和程序计数器。

线程的主要特点包括：

  1. 轻量级：线程相较于进程更加轻量，创建和销毁的开销较小。
  2. 共享资源：同一进程中的线程共享该进程的内存空间和资源，从而可以更高效地进行数据交换。
  3. 并发执行：多个线程可以并发执行，充分利用多核处理器，提高程序的执行效率。
  4. 简化管理：线程的切换和管理相对于进程更为简单和迅速，有助于提升系统的响应速度。

线程的使用在现代操作系统中非常普遍，尤其是在需要高并发和高性能的应用场景中，例如网络服务器和多任务应用程序等。

为什么要有线程

首先, "并发编程" 成为 "刚需"。

单核 CPU 的发展遇到了瓶颈. 要想提高算力, 就需要多核 CPU. 而并发编程能更充分利用多核 CPU资源。
有些任务场景需要 "等待 IO", 为了让等待 IO 的时间能够去做一些其他的工作, 也需要用到并发编
程。

其次, 虽然多进程也能实现 并发编程, 但是线程比进程更轻量。

  • 创建线程比创建进程更快.
  • 销毁线程比销毁进程更快.
  • 调度线程比调度进程更快.

创建出一个线程

在Java中，可以通过两种主要方式创建线程：继承Thread类和实现Runnable接口。下面分别介绍这两种方式，并附上代码示例。

方法一：继承 Thread 类

  1. 创建一个子类，继承Thread类，并重写run()方法，该方法包含了线程的执行代码。
  2. 创建子类的实例，然后调用start()方法来启动线程。

示例代码：

class MyThread extends Thread {
    @Override
    public void run() {
        // 线程执行的代码
        for (int i = 0; i < 5; i++) {
            System.out.println("Thread running: " + i);
            try {
                Thread.sleep(1000); // 暂停1秒
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

public class ThreadExample {
    public static void main(String[] args) {
        Thread thread = new MyThread(); // 创建线程对象
        thread.start(); // 启动线程
    }
}

方法二：实现 Runnable 接口

  1. 创建一个类，实现Runnable接口，并实现run()方法。
  2. 创建Runnable接口的实例，将其传递给Thread构造函数，然后调用start()方法启动线程。

示例代码：

class MyRunnable implements Runnable {
    @Override
    public void run() {
        // 线程执行的代码
        for (int i = 0; i < 5; i++) {
            System.out.println("Runnable thread running: " + i);
            try {
                Thread.sleep(1000); // 暂停1秒
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

public class RunnableExample {
    public static void main(String[] args) {
        MyRunnable myRunnable = new MyRunnable(); // 创建Runnable实例
        Thread thread = new Thread(myRunnable); // 将Runnable实例传递给Thread
        thread.start(); // 启动线程
    }
}

解析：

  • 在这两个示例中，我们创建了一个简单的线程，该线程在运行时每秒打印一次数字（0到4）。
  • 使用Thread.sleep(1000)使线程暂停1秒，这样可以模拟一些耗时的操作，也使得输出不至于淹没在快速的执行中。
  • 调用start()方法时，Java虚拟机会调用线程的run()方法，而不是直接调用run()。这保证了线程的正确启动和管理。

总结：

通过这两种方式，Java允许灵活地创建和管理线程，开发者可以根据具体需求选择适合的方式。继承Thread类比较直接，但实现Runnable接口则可以实现更灵活的线程管理和资源共享。

引入匿名内部类和 Lambda 简化上述方法

匿名内部类

方法一

public class ThreadExample {
    public static void main(String[] args) {
        Thread thread = new Thread() {
            // 线程执行的代码
            @Override
            public void run() {
                // 线程执行的代码
                for (int i = 0; i < 5; i++) {
                    System.out.println("Runnable thread running: " + i);
                    try {
                        Thread.sleep(1000); // 暂停1秒
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        };

        thread.start();
    }
}

方法二

public class ThreadExample {
    public static void main(String[] args) {
        Thread thread = new Thread(new Runnable() {
            @Override
            public void run() {
                // 线程执行的代码
                for (int i = 0; i < 5; i++) {
                    System.out.println("Runnable thread running: " + i);
                    try {
                        Thread.sleep(1000); // 暂停1秒
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        });

        thread.start();
    }
}

   Lambda 表达式

public class ThreadExample {
    public static void main(String[] args) {
        Thread thread = new Thread(() -> {
            // 线程执行的代码
            for (int i = 0; i < 5; i++) {
                System.out.println("Runnable thread running: " + i);
                try {
                    Thread.sleep(1000); // 暂停1秒
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });

        thread.start();
    }
}

Lambda 表达式由于简洁，所以是日常开发中常用的方法。

查看线程

当我们创建好一个线程后如何查看线程的状态呢？

使用 jconsole 命令观察线程

我们打开 jdk 文件夹所在目录，找到 bin 文件夹。

找到 jconsole.exe 双击打开。

 

 选择我们的类名的选项，点击连接。

 连接好了后，选择线程，然后找到 Thread-0 这个就是我们手动创建的线程，我们可以查看该线程的运行情况。

 Thread 中常见的方法

Thread类是Java中用于创建和管理线程的重要类，提供了多种方法来控制线程的行为和状态。以下是一些常见的Thread类方法：

  1. **start()**：启动线程，JVM会调用线程的run()方法。

  2. **run()**：线程执行的代码逻辑所在的方法。可以被重写来定义线程的任务。

  3. **sleep(long millis)**：使当前线程暂停指定的时间（毫秒），在此期间线程不会执行。

  4. **join()**：等待调用该方法的线程完成后再继续执行。这是实现线程间的同步的一种方式。

  5. **interrupt()**：中断线程，设置线程的中断状态。如果该线程正在阻塞（例如在sleep()或wait()中），则会抛出InterruptedException。

  6. **isAlive()**：判断线程是否仍在运行中，返回true表示线程处于活动状态。

  7. **getName()**：返回线程的名称。

  8. **setName(String name)**：设置线程的名称。

  9. **getPriority()**：返回线程的优先级。

  10. **setPriority(int priority)**：设置线程的优先级，优先级范围为Thread.MIN_PRIORITY（1）到Thread.MAX_PRIORITY（10）。

  11. **yield()**：提示调度器当前线程愿意让出对 CPU 的占用，由其他同等或更高优先级的线程获得执行机会。

  12. **currentThread()**：静态方法，返回对当前正在执行的线程对象的引用。

示例：

以下是一个简单的代码示例，演示了部分常见方法的用法：

class MyThread extends Thread {
    @Override
    public void run() {
        System.out.println(getName() + " is running");
        try {
            sleep(1000); // 暂停1秒
        } catch (InterruptedException e) {
            System.out.println(getName() + " was interrupted");
        }
        System.out.println(getName() + " has finished running");
    }
}

public class ThreadMethodsExample {
    public static void main(String[] args) {
        MyThread thread1 = new MyThread();
        MyThread thread2 = new MyThread();
        
        thread1.setName("Thread-1");
        thread2.setName("Thread-2");
        
        thread1.start();
        thread2.start();

        try {
            thread1.join(); // 等待thread1完成
            thread2.join(); // 等待thread2完成
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        
        System.out.println("All threads have finished executing.");
    }
}

在这个示例中，我们创建了两个线程，设置了它们的名称，并演示了start()、sleep()和join()方法的使用。

如何中断一个线程

在Java中，手动中断一个线程的原理主要依赖于线程的 interrupt() 方法和线程的 isInterrupted() 状态。通过调用一个线程的 interrupt() 方法，可以设置该线程的中断状态为 true。这通常用于通知线程它应该停止当前的工作，并进行清理或其他的收尾操作。

当一个线程被中断后，如果该线程在阻塞状态（例如，等待输入、休眠等），则会抛出 InterruptedException。如果线程在其他执行状态中，通常需要在合适的位置检查该线程的中断状态，决定是否需要停止执行。

以下是一个简单的案例，展示如何手动中断一个线程：

示例代码

class MyRunnable implements Runnable {
    @Override
    public void run() {
        try {
            System.out.println("线程开始工作...");
            // 模拟长时间工作的情况
            for (int i = 0; i < 10; i++) {
                // 检查线程是否被中断
                if (Thread.currentThread().isInterrupted()) {
                    System.out.println("线程被中断，退出工作...");
                    return; // 退出运行
                }
                System.out.println("工作中: " + i);
                // 模拟工作过程中的延时
                Thread.sleep(1000);
            }
        } catch (InterruptedException e) {
            // 如果线程因为sleep被中断，会抛出InterruptedException
            System.out.println("线程被中断，捕获到异常: " + e.getMessage());
        } finally {
            System.out.println("线程清理工作，准备结束...");
        }
    }
}

public class ThreadInterruptExample {
    public static void main(String[] args) throws InterruptedException {
        Thread myThread = new Thread(new MyRunnable());
        myThread.start();

        // 主线程等待2秒，然后中断myThread
        Thread.sleep(2000);
        System.out.println("主线程请求中断myThread...");
        myThread.interrupt(); // 中断线程

        // 等待myThread结束
        myThread.join();
        System.out.println("主线程结束。");
    }
}

代码解释

  1. MyRunnable 类实现 Runnable 接口并重写 run() 方法。
  2. 在 run() 方法中，模拟了一个长时间工作的循环，每次循环检查线程的中断状态。
  3. 如果线程被中断，可以通过 Thread.currentThread().isInterrupted() 方法来检测，并通过返回来优雅地退出工作。
  4. 在主线程中，创建并启动一个新线程，等待2秒后调用 interrupt() 方法中断它。
  5. 如果在 sleep() 等待期间线程被中断，InterruptedException 将被抛出，因此可以在 catch 块中进行相应处理。
  6. 最后，使用 join() 等待 myThread 完成所有操作后再结束主线程。

总结

通过这个案例，可以清晰地看到如何手动中断线程以及如何处理线程的中断状态。这种机制在多线程编程中非常重要，确保了线程可以在合适的时机响应中断请求，从而实现更好的资源管理和程序健壮性。

join 等待一个线程

在Java中，等待一个线程的原理主要依赖于 Thread 类中的 join() 方法。调用 join() 方法可以使当前线程（即调用 join() 的线程）等待另一个线程完成执行。原理是通过线程的状态管理，使得调用 join() 的线程在被调用线程执行完之前不会继续执行，确保线程之间的执行顺序。

示例代码

下面是一个简单的案例，展示如何等待一个线程的完成：

class MyRunnable implements Runnable {
    @Override
    public void run() {
        System.out.println("线程 " + Thread.currentThread().getName() + " 开始工作...");
        try {
            // 模拟长时间的工作
            Thread.sleep(2000); // 休眠2秒
        } catch (InterruptedException e) {
            System.out.println("线程被中断: " + e.getMessage());
        }
        System.out.println("线程 " + Thread.currentThread().getName() + " 工作完成。");
    }
}

public class ThreadJoinExample {
    public static void main(String[] args) {
        Thread myThread = new Thread(new MyRunnable(), "MyThread");
        myThread.start(); // 启动线程

        try {
            System.out.println("主线程等待 " + myThread.getName() + " 完成...");
            myThread.join(); // 等待 myThread 完成
        } catch (InterruptedException e) {
            System.out.println("主线程被中断: " + e.getMessage());
        }

        System.out.println("主线程继续执行，已等待 " + myThread.getName() + " 完成。");
    }
}

代码解释

  1. MyRunnable 类：实现 Runnable 接口并重写 run() 方法。在 run() 方法中，我们模拟了一个长时间的工作，使用 Thread.sleep(2000) 使线程休眠 2 秒。
  2. 主类 ThreadJoinExample：
    • 创建一个新的线程 myThread，并将 MyRunnable 实例作为参数传入。
    • 启动线程 myThread，这会调用其 run() 方法。
    • 在主线程中，调用 myThread.join()，这将使主线程等待 myThread 完成执行。
    • 一旦 myThread 执行完成，主线程将继续执行，并打印出相应的信息。

总结

通过这个案例，可以看到如何使用 join() 方法来等待线程的完成。这样可以有效地控制线程的执行顺序，确保在某些操作完成后再进行后续处理。例如，在多个线程之间需要协调工作时，使用 join() 使得某些操作依赖于另一个线程的完成，可以减少潜在的竞争和数据不一致问题。这种机制在多线程编程中非常重要，特别是在任务依赖的场景下。

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

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

相关文章

格式工厂怎么转换mp4？简单4步实现视频转换

格式工厂怎么转换mp4？简单4步实现视频转换

视频转换的重要性不言而喻。随着科技的发展&#xff0c;视频已经成为我们生活中不可或缺的一部分。然而&#xff0c;不同的设备和平台往往支持不同的视频格式&#xff0c;这就导致了视频兼容性问题。此外&#xff0c;不同格式的视频文件在存储和传输方面也存在差异。因此&#…
阅读更多...
【MySQL】数据库基础与MySQL的安装

【MySQL】数据库基础与MySQL的安装

1. 数据库基础 1.1 什么是数据库 在接触数据库之前&#xff0c;回想一下我们之前写的所有小项目&#xff0c;如果需要持久化保存一些内容&#xff0c;我们是保存在文件中的&#xff0c;似乎也能够很不错的支持我们的操作&#xff0c;解决我们的需求。但是&#xff0c;实际上是…
阅读更多...
健身房管理系统的设计与实现设计与实现(源码+lw+部署文档+讲解等)

健身房管理系统的设计与实现设计与实现(源码+lw+部署文档+讲解等)

文章目录 前言具体实现截图详细视频演示技术栈系统测试为什么选择我官方认证玩家&#xff0c;服务很多代码文档&#xff0c;百分百好评&#xff0c;战绩可查&#xff01;&#xff01;入职于互联网大厂&#xff0c;可以交流&#xff0c;共同进步。有保障的售后 代码参考数据库参…
阅读更多...
Redis7基础篇（七）

Redis7基础篇（七）

redis哨兵&#xff08;sentinel&#xff09; 目录 redis哨兵&#xff08;sentinel&#xff09; 是什么 能干吗 案例演示 架构 案例步骤 出现的问题 哨兵的运行流程和选举原理 哨兵的使用建议​编辑 是什么 在之前的复制中我们了解到 主机shutdown之后 从机就会一直等…
阅读更多...
轻松创作高质量的AI音乐——Suno API

轻松创作高质量的AI音乐——Suno API

Suno 歌曲生成 API 对接指南 随着人工智能技术的飞速发展&#xff0c;各类 AI 程序已如雨后春笋般涌现。AI 不再是遥不可及的存在&#xff0c;它的身影深入了人类工作与生活的每一个角落。其应用领域也愈加广泛&#xff0c;从初期的写作&#xff0c;到现如今的医疗、教育&…
阅读更多...
为什么同一台手机连着电脑的ip地址不一样

为什么同一台手机连着电脑的ip地址不一样

在现代社会中&#xff0c;网络已成为我们日常生活不可或缺的一部分。从日常办公到休闲娱乐&#xff0c;网络无处不在。然而&#xff0c;在享受网络带来的便利时&#xff0c;我们可能会遇到一些看似复杂实则有趣的网络现象。今天&#xff0c;我们就来探讨一个常见却又容易被忽视…
阅读更多...
LLM | 面向对话式医疗健康场景的医疗大模型

LLM | 面向对话式医疗健康场景的医疗大模型

近日&#xff0c;复旦大学数据智能与社会计算实验室 (Fudan-DISC) 开发并开源了一个专门针对医疗健康对话式场景而设计的医疗领域大模型&#xff1a;DISC-MedLLM。 DISC-MedLLM DISC-MedLLM 是一个专为医疗健康对话场景而打造的领域大模型&#xff0c;它可以满足您的各种医疗保…
阅读更多...
嵌入式堆栈、ARM寄存器

嵌入式堆栈、ARM寄存器

栈里面存放的内容&#xff1a;局部变量和系统信息&#xff0c;函数调用链路也是系统信息的一环 ARM寄存器 LR&#xff1a;程序跳转的时候&#xff0c;返回到的地址就保存到此处 PC&#xff1a;程序计数器&#xff0c;pc 要执行的下一条指令地址&#xff0c;就存放在此处&#…
阅读更多...
Obsidian Publish的开源替代品Markopolis

Obsidian Publish的开源替代品Markopolis

什么是 Markopolis &#xff1f; Markopolis 是一款旨在提供 Markdown 文件的 Web 应用和 API 服务器。它允许您以网站形式共享 Markdown 笔记&#xff0c;并使用 API 与 Markdown 文件交互和操作它们。类似于 Obsidian Publish&#xff0c;但又不会被锁定在 Obsidian 生态系统…
阅读更多...
FMS 2024：多家厂商CXL技术方案总览

FMS 2024：多家厂商CXL技术方案总览

CXL&#xff08;Compute Express Link&#xff09;联盟自成立以来一直是FMS闪存峰会的常客。在2022年的峰会上&#xff0c;CXL联盟宣布了CXL 3.0版本规范&#xff0c;随后在2023年的超级计算大会上推出了CXL 3.1版本。起初&#xff0c;CXL作为一种主机到设备的互联标准&#xf…
阅读更多...
【LiteX】【仿真】使用litex_sim在Python环境中实现FPGA SoC仿真测试

【LiteX】【仿真】使用litex_sim在Python环境中实现FPGA SoC仿真测试

目录 介绍环境依赖litex_sim 入门仿真litex_server、litex_cli、litescope_cli仿真调试litex_sim仿真窗口litex_server窗口litex_cli窗口litescope_cli窗口 波形DUMP方法一&#xff1a;导出指定时间段的波形方法二&#xff1a;在命令行中配置寄存器控制波形导出方法三&#xff…
阅读更多...
BI分析实操案例分享：零售企业如何利用BI工具对销售数据进行分析？

BI分析实操案例分享：零售企业如何利用BI工具对销售数据进行分析？

在当下这个竞争激烈的零售市场&#xff0c;企业如何在波诡云谲的商场中站稳脚跟&#xff0c;实现销售目标的翻倍增长&#xff1f; 答案可能就藏在那些看似杂乱无章的数字里。 是的&#xff0c;你没有看错&#xff0c;答案正是那些我们日常接触的销售数据。它们就像是宝藏&…
阅读更多...
92.SAP ABAP - RFC函数外部调用时的debug - 笔记

92.SAP ABAP - RFC函数外部调用时的debug - 笔记

当RFC函数被外部系统访问&#xff0c;需要联合调试时&#xff0c;也需要debug模式&#xff0c;打断点进行跟踪。这种要如何做呢&#xff1f; 目录 1.SE37进入程序&#xff0c;通过菜单Utilities-Settings进入 2.ABAP Editor-Debugging Tab页面 3.单击Set/Delete External Br…
阅读更多...
软件设计师全套备考系列文章7 -- 树、二叉树、图

软件设计师全套备考系列文章7 -- 树、二叉树、图

软考-- 软件设计师&#xff08;7&#xff09;-- 树、二叉树、图 文章目录 软考-- 软件设计师&#xff08;7&#xff09;-- 树、二叉树、图前言一、树的基本概念二、二叉树的基本概念三、二叉树的考点四、线索二叉树五、平衡二叉树六、图 前言 考试时间&#xff1a;每年5月、11…
阅读更多...
制冷系统四通阀、截止阀和单向阀

制冷系统四通阀、截止阀和单向阀

一、 四通阀 (一)作用&#xff1a;是热泵型空调中的关键部件&#xff0c;起制冷系统中制冷、制热转换的作用&#xff0c;通过更换压缩机排气管和回气管进入蒸发器和冷凝器的方向&#xff0c;从而达到制冷和制热目的。亦可以用于除湿系统的换向化霜。 (二)工作原理&#xff1…
阅读更多...
java接口 controller层接收list集合传参,postman 调用接口时required parameter XXX is not present

java接口 controller层接收list集合传参,postman 调用接口时required parameter XXX is not present

开发过程中开发一个java接口 controller层接收list集合传参&#xff0c;然后postman调用一直不成功&#xff0c;报错 使用RequestParam方式&#xff0c;如果postman 调用接口时报错required parameter XXX is not present 可能是&#xff08;value“items”&#xff09;跟你输…
阅读更多...
微信小程序--31(todolist案例)

微信小程序--31(todolist案例)

一.功能 输入待办事件添加代办事件删除代办事件 二、步骤 1.添加输入框 .wxml代码&#xff1a; <!-- 1.输入框 --><input type"text" bindinput"handleInput" value"{{text}}" /> .wxss代码&#xff1a; /* 1.输入框样式 */ i…
阅读更多...
百度地图API快速使用 - 以批量算路为例讲解

百度地图API快速使用 - 以批量算路为例讲解

目录 1. 开发文档链接 2. 开发流程说明 &#xff08;1&#xff09;首先-创建应用获取访问应用的AK &#xff08;2&#xff09; 查看文档的示例代码并分析 3. 简单改编示例的代码 1. 开发文档链接 批量算路 | 百度地图API SDK (baidu.com)https://lbsyun.baidu.com/faq/ap…
阅读更多...
Adobe After Effects的插件--------3D Stroke

Adobe After Effects的插件--------3D Stroke

3D Stroke是蒙版路径描边插件。它是AE的外置插件，需要自己下载，可以在lookAE中下载。 该插件会依据图层上的蒙版路径（内部）创建蒙版，并且使原蒙版失效。 基础属性 英文属性名中文属性名描述Path路径用来选择图层上的某一段蒙版路径，若 Use All Paths 属性未勾选，该属性…
阅读更多...
【SQL】下属员工数量

【SQL】下属员工数量

目录 题目 分析 代码 题目 表&#xff1a;Employees ----------------------- | Column Name | Type | ----------------------- | employee_id | int | | name | varchar | | reports_to | int | | age | int | -------------------…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023