Java多线程案例如何基础开发

wen java案例 2026-07-01 23

Java多线程案例：基础开发实战指南

目录导读

为什么需要多线程？——一个简单的场景分析
Java多线程基础核心概念解析
三大经典案例：从零到一编写多线程程序
常见问题与问答（Q&A）
最佳实践：避免踩坑，提升效率

为什么需要多线程？——一个简单的场景分析

假设你正在开发一个“文件批量下载器”：用户点击下载后，需同时下载10个文件，如果用单线程，只能挨个下载，用户等待时间=10个文件的时间总和，体验极差，而多线程可以并行处理，让多个下载任务同时进行,极大缩短总耗时。

Java多线程案例如何基础开发

核心问题：单线程的串行执行无法充分利用CPU资源，尤其在多核处理器上，Java多线程允许程序同时执行多个任务,提升响应速度和资源利用率。

Java多线程基础核心概念解析

1 线程与进程的区别

进程：系统资源分配的基本单位，拥有独立的内存空间（如打开的一个Word文档）。
线程：CPU调度的最小单位，共享进程的内存资源（如Word文档中的“自动保存”功能与“输入文字”功能）。

2 创建线程的三种方式

继承Thread类（简单但不推荐,因Java单继承限制）
实现Runnable接口（无返回值,常用）
实现Callable接口（支持返回值与异常,结合Future）

3 线程生命周期

新建→就绪→运行→阻塞/等待→死亡，理解此模型对排查死锁、资源饥饿非常重要。

三大经典案例：从零到一编写多线程程序

使用Runnable实现多线程下载模拟

public class FileDownloadTask implements Runnable {
    private String fileName;
    public FileDownloadTask(String fileName) { this.fileName = fileName; }
    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + " 开始下载：" + fileName);
        try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); }
        System.out.println(Thread.currentThread().getName() + " 下载完成：" + fileName);
    }
    public static void main(String[] args) {
        Thread t1 = new Thread(new FileDownloadTask("文件1.mp4"));
        Thread t2 = new Thread(new FileDownloadTask("文件2.jpg"));
        t1.start();
        t2.start();
    }
}

输出示例（注意线程名交替）：

Thread-0 开始下载：文件1.mp4
Thread-1 开始下载：文件2.jpg
Thread-0 下载完成：文件1.mp4
Thread-1 下载完成：文件2.jpg

银行账户转账——线程同步的安全问题

public class BankAccount {
    private int balance = 1000;
    // 不加synchronized会导致账目错误
    public synchronized void transfer(int amount) {
        if (balance >= amount) {
            balance -= amount;
            System.out.println(Thread.currentThread().getName() + " 转账成功，余额：" + balance);
        }
    }
}

问题：多个线程同时转账可能导致“透支”，使用synchronized或Lock保证原子性。

生产消费模式——使用阻塞队列

BlockingQueue<Integer> queue = new LinkedBlockingQueue<>(5);
// 生产者线程
new Thread(() -> {
    for (int i = 0; i < 10; i++) {
        try { queue.put(i); } catch (InterruptedException e) { }
    }
}).start();
// 消费者线程
new Thread(() -> {
    while (true) {
        try { Integer val = queue.take(); System.out.println("消费：" + val); } catch (InterruptedException e) { }
    }
}).start();

优势：阻塞队列自动处理锁与条件等待，比手动wait/notify更安全。