如何用Java创建和使用线程类 Java线程创建方式与示例-java教程-PHP中文网

java中创建线程的核心方式有两种：实现runnable接口和继承thread类。1. 实现runnable接口更灵活，适合类已继承其他类或需任务与线程解耦的场景，通过将任务逻辑与线程分离，实现更好的复用性和设计灵活性。2. 继承thread类较直观，但受限于java单继承机制，线程类无法再继承其他类，任务逻辑与线程本身紧密耦合，复用性较差。两种方式均可创建线程并执行任务，但runnable方式更推荐使用，尤其结合线程池可提升并发管理效率。

如何用Java创建和使用线程类 Java线程创建方式与示例

在Java中创建和使用线程，核心思路其实就两种：要么实现Runnable接口，要么继承Thread类。这两种方式各有千秋，但最终目的都是让你的程序能够并行处理任务，提升效率，或者处理一些需要后台运行的逻辑。选择哪种，很多时候取决于你的具体场景和个人偏好，但通常来说，实现Runnable接口会是更推荐的做法。

解决方案

要创建和使用Java线程，我们主要围绕Runnable接口和Thread类展开。

1. 实现Runnable接口

立即学习“Java免费学习笔记（深入）”；

这是我个人觉得更灵活、也更符合Java设计哲学的方式。当你的类已经继承了其他类，或者你希望将任务逻辑与线程本身解耦时，Runnable就是你的不二之选。

// 定义一个实现Runnable接口的任务
class MyRunnableTask implements Runnable {
    private String taskName;

    public MyRunnableTask(String name) {
        this.taskName = name;
    }

    @Override
    public void run() {
        // 线程执行的逻辑写在这里
        System.out.println(Thread.currentThread().getName() + " 正在执行任务: " + taskName);
        try {
            Thread.sleep(1000); // 模拟耗时操作
        } catch (InterruptedException e) {
            System.out.println(Thread.currentThread().getName() + " 的任务被中断了！");
            Thread.currentThread().interrupt(); // 重新设置中断标志
        }
        System.out.println(Thread.currentThread().getName() + " 完成任务: " + taskName);
    }
}

public class ThreadWithRunnableDemo {
    public static void main(String[] args) {
        // 创建Runnable任务实例
        MyRunnableTask task1 = new MyRunnableTask("下载文件");
        MyRunnableTask task2 = new MyRunnableTask("处理数据");

        // 将Runnable任务包装到Thread对象中
        Thread thread1 = new Thread(task1, "下载线程");
        Thread thread2 = new Thread(task2, "处理线程");

        // 启动线程，执行run方法中的逻辑
        thread1.start();
        thread2.start();

        System.out.println("主线程继续执行...");
    }
}

登录后复制

你看，这里MyRunnableTask只关注它要“做什么”，而Thread对象则负责“如何运行”这个任务。这种分离，让代码结构清晰，也更容易复用。

2. 继承Thread类

这种方式直观，但有其局限性。如果你希望你的线程类除了线程功能外，不再需要继承其他任何类，那么这种方式也挺方便。

// 定义一个继承Thread类的线程
class MyThread extends Thread {
    private String threadName;

    public MyThread(String name) {
        super(name); // 调用父类构造器设置线程名
        this.threadName = name;
    }

    @Override
    public void run() {
        // 线程执行的逻辑
        System.out.println(threadName + " 启动了！");
        for (int i = 0; i < 3; i++) {
            System.out.println(threadName + " 正在执行计数: " + i);
            try {
                Thread.sleep(500);
            } catch (InterruptedException e) {
                System.out.println(threadName + " 被中断了！");
                Thread.currentThread().interrupt();
            }
        }
        System.out.println(threadName + " 运行结束。");
    }
}

public class ThreadExtendsThreadDemo {
    public static void main(String[] args) {
        // 创建并启动线程实例
        MyThread threadA = new MyThread("线程A");
        MyThread threadB = new MyThread("线程B");

        threadA.start();
        threadB.start();

        System.out.println("主线程也在忙活...");
    }
}

登录后复制

这里，MyThread本身就是一个线程。你直接创建它的实例，然后调用start()就行了。

Java线程的两种核心创建方式有何区别？

这两种方式，虽然都能达到创建线程的目的，但它们在设计理念和实际使用中有着明显的区别，理解这些区别对于写出健壮的并发程序至关重要。

首先，最直接的区别在于Java的单继承限制。Java类只能继承一个父类。如果你选择继承Thread类来创建线程，那么你的线程类就不能再继承其他任何类了。这在很多时候是个大问题，比如你的业务逻辑类已经继承了某个框架提供的基类，这时候你再想让它成为一个线程，就只能选择实现Runnable接口。而Runnable是一个接口，一个类可以实现多个接口，所以它提供了更大的灵活性。

其次，是任务与线程的解耦。实现Runnable接口的方式，将“任务（run()方法里的逻辑）”和“执行任务的线程（Thread对象）”分开了。这意味着你可以把同一个Runnable实例传递给多个Thread对象，让它们共享同一个任务逻辑，但每个线程独立运行。这对于资源共享和任务调度来说，是非常有用的。比如，你有一个数据处理任务，可以创建多个线程来并行处理，它们都使用同一个Runnable任务实例，但处理的数据片段不同。而继承Thread类的方式，任务逻辑是和线程本身紧密耦合在一起的，每个Thread实例都包含了它自己的任务逻辑，复用起来就没那么直接了。

我个人更倾向于使用Runnable，因为它更符合“面向接口编程”的思想，也避免了Java单继承的限制。在现代Java开发中，结合线程池（ExecutorService）来管理Runnable任务，更是标准实践，能更好地控制并发，避免资源耗尽。

如何管理和控制Java线程的生命周期？

线程的生命周期，可不是你启动了它就万事大吉那么简单。一个线程从诞生到消亡，会经历几个状态，我们作为开发者，需要知道如何去引导和控制它。

一个线程的生命周期大致分为：新建（New）、可运行（Runnable）、运行（Running）、阻塞（Blocked）、等待（Waiting）、计时等待（Timed Waiting）和终止（Terminated）。

启动线程： 调用Thread对象的start()方法。注意，不是run()方法！start()方法会告诉JVM，为这个线程分配资源，并调用其内部的run()方法。如果直接调用run()，那它就只是一个普通的方法调用，不会创建新的线程。
暂停执行： Thread.sleep(long millis)。这个方法会让当前线程暂停指定毫秒数，进入计时等待状态。它不会释放锁，所以如果当前线程持有某个对象的锁，其他线程是无法获取这个锁的。

芦笋演示
一键出成片的录屏演示软件，专为制作产品演示、教学课程和使用教程而设计。

34

查看详情

等待其他线程完成： thread.join()。当一个线程A调用另一个线程B的join()方法时，线程A会进入等待状态，直到线程B执行完毕或者等待时间到期（join(long millis)）。这在需要等待某个后台任务完成后才能继续主流程的场景非常有用。

// 示例：join()的使用
Thread worker = new Thread(() -> {
    System.out.println("工人线程开始工作...");
    try {
        Thread.sleep(3000);
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
    System.out.println("工人线程工作完成。");
}, "工人线程");

worker.start();
System.out.println("主线程等待工人线程完成...");
try {
    worker.join(); // 主线程等待工人线程结束
} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
}
System.out.println("主线程继续执行，因为工人线程已经完成了。");

登录后复制

中断线程： thread.interrupt()。这是一种协作式机制，它并不会强制停止一个线程，而是向线程发送一个中断信号（设置中断标志位）。线程内部需要周期性地检查这个标志位（Thread.currentThread().isInterrupted()），或者在执行可中断操作（如sleep(), join(), wait()）时捕获InterruptedException，然后根据业务逻辑决定是退出还是继续。

// 示例：中断线程
Thread interruptibleThread = new Thread(() -> {
    while (!Thread.currentThread().isInterrupted()) {
        System.out.println("我还在努力工作...");
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            System.out.println("我被中断了，准备退出！");
            Thread.currentThread().interrupt(); // 重新设置中断标志，以便外层循环检查
        }
    }
    System.out.println("我优雅地退出了。");
}, "可中断线程");

interruptibleThread.start();
try {
    Thread.sleep(3500); // 让它跑一会儿
} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
}
interruptibleThread.interrupt(); // 发送中断信号

登录后复制

线程同步与协作： wait(), notify(), notifyAll()。这些方法必须在同步块（synchronized）中使用，并且是Object类的方法。它们用于线程间的通信和协作，让线程在特定条件下等待（释放锁），并在条件满足时被唤醒。

管理线程生命周期，尤其是中断和同步，是并发编程中非常容易出错的地方。记住，永远不要使用Thread.stop()、suspend()、resume()这些已废弃的方法，它们是线程不安全的，可能导致死锁或资源泄露。

在实际项目中，Java线程有哪些常见应用场景与最佳实践？

在实际的软件开发中，线程可不是为了炫技而存在的，它们解决的是实实在在的性能、响应性以及资源利用率问题。

常见应用场景：

后台任务处理： 这是最常见的场景。比如用户上传了一个大文件，你不可能让用户一直等着文件上传和处理完成。这时候就可以把文件处理的任务扔给一个后台线程去执行，主线程（通常是UI线程或请求处理线程）可以立即响应用户。像日志写入、数据备份、报表生成等，都属于这类。
异步操作： 当你需要调用一个耗时很长的外部服务（比如网络请求、数据库查询），又不想阻塞当前线程时，可以将其放在一个新线程中异步执行。结果可以通过回调或者Future/CompletableFuture来获取。这对于提升系统的吞吐量和响应速度非常关键。
并行计算： 对于一些可以拆分成独立子任务的计算密集型工作，比如大数据处理、图像渲染、科学计算等，可以利用多核CPU的优势，将任务分配给多个线程并行执行，显著缩短总执行时间。
定时任务： 使用ScheduledExecutorService可以很方便地创建定时执行或周期性执行的任务，比如每隔一小时同步一次数据，或者每天凌晨生成一份日报。

最佳实践：

优先使用线程池： 直接创建new Thread()在大多数生产环境中都是不推荐的。频繁地创建和销毁线程会带来很大的性能开销。使用ExecutorService（如ThreadPoolExecutor）来管理线程池，可以复用线程，控制并发线程的数量，避免系统资源耗尽。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class ThreadPoolDemo {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池，比如5个线程
        ExecutorService executor = Executors.newFixedThreadPool(5);

        for (int i = 0; i < 10; i++) {
            final int taskNum = i;
            executor.submit(() -> { // 提交一个Runnable任务
                System.out.println(Thread.currentThread().getName() + " 正在处理任务 " + taskNum);
                try {
                    Thread.sleep(500 + (long) (Math.random() * 500));
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
                System.out.println(Thread.currentThread().getName() + " 完成任务 " + taskNum);
            });
        }

        // 关闭线程池，等待所有任务执行完毕
        executor.shutdown();
        try {
            if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
                executor.shutdownNow(); // 强制关闭
            }
        } catch (InterruptedException e) {
            executor.shutdownNow();
            Thread.currentThread().interrupt();
        }
        System.out.println("所有任务提交完毕，线程池已关闭。");
    }
}

登录后复制

你看，通过线程池，我们不需要手动去管理每个线程的生命周期，把任务丢进去就行了，这大大简化了并发编程的复杂度。

关注线程安全： 当多个线程访问和修改共享数据时，必须采取同步措施（如synchronized关键字、ReentrantLock、volatile关键字、Atomic类等），否则会导致数据不一致或不可预测的行为。这是并发编程中最大的坑之一，需要投入大量精力去理解和实践。
避免死锁： 死锁是多线程编程中一个经典问题，当两个或多个线程在等待彼此释放资源时，就会发生死锁。设计时要尽量避免循环依赖的资源获取，或者使用定时锁来打破死锁条件。
合理设置线程优先级： 线程优先级只是给调度器一个提示，并不能保证高优先级线程一定先执行。在大多数情况下，让操作系统自行调度是最好的选择，过度依赖优先级可能会导致意想不到的行为。