一、写在前面在 Java 后端面试中线程几乎是一个绕不开的话题。很多面试官喜欢从一个小问题切入再不断往深处追问比如下面这组连环问你知道有哪些方式可以开启一个线程这几种方式有什么区别你平时用哪一种如果让你开启 10000 个线程会有什么问题既然线程开多了有问题那应该怎么优化线程池的核心参数有哪些线程池的工作流程是怎样的表面上看这些问题考查的是「怎么创建线程」但真正考查的是候选人对线程底层原理、资源消耗、系统调度以及并发编程实战的理解深度。如果只会背几个创建线程的 API一旦面试官追问到线程栈、上下文切换、线程池参数设置就很容易露馅。本文就用 2 万字左右的篇幅把「如何开启一个线程、开启大量线程会有什么问题、如何优化」这条主线彻底讲透并给出可以直接照搬进面试的回答思路。文章会从线程最基础的概念讲起逐步过渡到八种开启线程的方式、大量线程带来的各种性能问题再到线程池、虚拟线程等优化手段最后整理出一套完整的面试回答模板。建议先通读理解原理再重点记忆结论和代码示例这样无论面试官如何追问都能从容应对。二、基础回顾进程与线程只有先把进程与线程的区别搞清楚才能理解「为什么大量线程会带来问题」。这一节我们先建立正确的底层认知。2.1 什么是进程进程是操作系统进行资源分配和调度的基本单位。当我们启动一个 JVM、运行一个 Java 程序时操作系统就会为其创建一个进程。进程拥有独立的内存空间包括代码段、数据段、堆、栈等。不同进程之间的内存空间是隔离的一个进程崩溃通常不会直接拖垮另一个进程。进程的核心特点是「资源隔离」。但资源隔离也有代价进程之间的通信只能通过进程间通信IPC机制完成比如管道、消息队列、共享内存、Socket 等通信成本较高。同时进程的创建和销毁开销也比较大因为操作系统需要为其分配独立的地址空间、维护进程控制块PCB等。2.2 什么是线程线程是操作系统能够进行运算调度的最小单位它被包含在进程之中是进程中的实际执行单元。一个进程可以包含多个线程同一个进程内的所有线程共享该进程的堆内存、方法区等资源但每个线程拥有自己独立的虚拟机栈、本地方法栈和程序计数器。可以把一个进程理解成一家公司线程就是公司里的员工。公司里的资源办公场地、打印机、数据库是所有员工共享的而每个员工都有自己的工作台和待办事项。多个线程共享进程资源可以更高效地利用 CPU但也因为共享资源带来了线程安全等一系列并发问题。对比维度进程线程资源分配单位是操作系统资源分配的基本单位是 CPU 调度的基本单位内存空间拥有独立地址空间共享所属进程的地址空间切换开销较大需要切换页表等相对较小但仍需保存上下文通信方式IPC如管道、共享内存、Socket可直接读写共享内存但需要同步崩溃影响一个进程崩溃不影响其他进程一个线程崩溃可能导致整个进程崩溃2.3 Java 线程与操作系统线程的映射Java 中的线程最终要映射到操作系统的内核线程才能被调度执行。历史上Java 线程模型经历过从用户线程到内核线程的演进。在 1.2 以前的早期版本中Java 曾经使用「绿色线程Green Thread」即用户态线程由 JVM 自己调度不依赖操作系统。这种方式的问题是无法充分利用多核 CPU因为操作系统只看到一个 JVM 进程在运行。从 JDK 1.2 开始Java 主流虚拟机尤其是 HotSpot VM采用一对一的线程模型即每一个 Java 线程都直接对应一个操作系统内核线程KLTKernel Level Thread。我们调用new Thread().start()时JVM 会通过系统调用创建一个真正的内核线程。这也是为什么大量创建 Java 线程会消耗操作系统资源你创建的每一层 Java 对象背后都有一个实实在在的内核线程在支撑。这种一对一模型的优点是每个线程可以真正并行运行在多核 CPU 上调度交给操作系统负责缺点是线程创建、销毁和切换都要陷入内核态成本不低。理解了这一点也就理解了后文「大量线程为什么会有问题」的底层根源。值得一提的是JDK 21 引入的虚拟线程Virtual Thread打破了这种一对一映射它由 JVM 自行调度大量虚拟线程可以复用少量内核线程载体线程。虚拟线程是解决「大量线程开销大」的重要方案本文第五章会重点展开。2.4 线程的生命周期Java 线程在java.lang.Thread.State中定义了六种状态理解这些状态有助于我们讨论线程开启、阻塞和销毁的过程NEW新建线程对象已创建但还没有调用start()方法。此时线程尚未真正启动。RUNNABLE可运行线程调用了start()后在 JVM 中处于可运行状态。注意这个状态包含「正在执行」和「等待 CPU 调度」两种情况因为底层是否真正拿到 CPU 时间片由操作系统决定。BLOCKED阻塞线程正在等待获取一个监视器锁synchronized 锁。例如线程 A 持有锁线程 B 想进入同步块就会处于 BLOCKED 状态。WAITING等待线程无限期等待另一个线程执行特定操作例如调用Object.wait()、Thread.join()或LockSupport.park()后进入的状态。需要其他线程显式唤醒。TIMED_WAITING超时等待与 WAITING 类似但有超时时间例如Thread.sleep(long)、Object.wait(long)、Thread.join(long)等。TERMINATED终止线程的run()方法执行完毕或者因为未捕获的异常退出线程结束。生命周期可以简要概括为NEW 经过start()进入 RUNNABLERUNNABLE 可能因等待锁进入 BLOCKED因等待条件进入 WAITING/TIMED_WAITING最终进入 TERMINATED。下面这段代码可以直观地观察线程状态javapublic class ThreadStateDemo { public static void main(String[] args) throws InterruptedException { Thread t new Thread(() - { System.out.println(线程运行中); }); System.out.println(创建后 t.getState()); // NEW t.start(); System.out.println(start 后 t.getState()); // 可能是 RUNNABLE t.join(); System.out.println(结束后 t.getState()); // TERMINATED } }注意代码中的-是 Java 8 引入的 Lambda 表达式写法用于简化匿名内部类。后面的示例会频繁使用这种写法如果你还停留在 Java 8 之前可以把 Lambda 表达式改写成匿名内部类二者在本质上等价。三、如何开启一个线程八种方式详解「如何开启一个线程」这个问题看似简单却能区分候选人的知识广度。很多初学者只知道继承 Thread 和实现 Runnable但实际项目里还有 Callable、线程池、CompletableFuture、虚拟线程等多种方式。下面我们逐一讲解并给出完整可运行的代码。3.1 方式一继承 Thread 类最直接的方式是继承java.lang.Thread类重写其run()方法。创建子类对象后调用start()方法即开启一个新线程。javapublic class MyThread extends Thread { Override public void run() { System.out.println(当前线程 Thread.currentThread().getName()); } public static void main(String[] args) { MyThread t1 new MyThread(); MyThread t2 new MyThread(); t1.start(); t2.start(); // 输出顺序不固定例如 // 当前线程Thread-0 // 当前线程Thread-1 } }继承Thread类的方式最简单直观但 Java 只支持单继承如果一个业务类已经继承了其他父类就无法再继承Thread扩展性比较受限。实际开发中更推荐把「任务」和「线程」解耦也就是下面要讲到的实现Runnable接口的方式。3.2 方式二实现 Runnable 接口实现java.lang.Runnable接口重写run()方法再把这个任务对象交给 Thread 启动。这样「任务」与「线程」分离拓展性更好也更适合线程池复用。javapublic class MyRunnable implements Runnable { Override public void run() { System.out.println(当前线程 Thread.currentThread().getName()); } public static void main(String[] args) { Runnable task new MyRunnable(); new Thread(task).start(); // Java 8 起可用 Lambda 进一步简化 Runnable lambdaTask () - System.out.println( Lambda 线程 Thread.currentThread().getName()); new Thread(lambdaTask).start(); } }Runnable 的缺点是没有返回值也不能直接抛出受检异常。如果你的任务需要返回计算结果就需要 Callable。3.3 方式三实现 Callable 接口配合 FutureTaskCallableV 接口的 call() 方法允许返回结果并抛出异常它不能直接交给 Thread通常要借助 FutureTask 这个包装器。javaimport java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.FutureTask; public class MyCallable implements CallableString { Override public String call() throws Exception { Thread.sleep(1000); return 任务执行完成 Thread.currentThread().getName(); } public static void main(String[] args) throws InterruptedException, ExecutionException { FutureTaskString futureTask new FutureTask(new MyCallable()); new Thread(futureTask).start(); System.out.println(获取结果 futureTask.get()); // 阻塞等待任务返回 } }FutureTask.get() 会阻塞当前调用线程直到任务执行完成这也是它与前两种方式最大的区别能拿到执行结果也能捕获执行异常。3.4 方式四使用线程池这是生产环境最推荐的方式。通过线程池复用线程避免频繁创建和销毁的开销同时可以限制并发规模。javaimport java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class ThreadPoolDemo { public static void main(String[] args) { ExecutorService pool Executors.newFixedThreadPool(3); for (int i 0; i 10; i) { final int taskId i; pool.execute(() - System.out.println( 任务 taskId 由 Thread.currentThread().getName() 执行)); } pool.shutdown(); // 不再接收新任务已有任务执行完后再关闭 } }注意Executors提供的快捷工厂方法虽然方便但其内部队列默认接近无界生产环境建议直接用ThreadPoolExecutor显式配置参数。第五章会详细介绍。3.5 方式五使用 CompletableFutureCompletableFuture 是 Java 8 引入的异步编程工具支持任务编排、回调、组合非常适合「任务之间有依赖关系」的场景。javaimport java.util.concurrent.CompletableFuture; public class CompletableFutureDemo { public static void main(String[] args) { CompletableFutureString future CompletableFuture.supplyAsync(() - { return 异步结果执行线程 Thread.currentThread().getName(); }); future.thenAccept(result - System.out.println(result)); future.join(); // 等待任务完成便于示例打印 } }它可以串行、并行地组织多个异步任务也能处理异常是现代 Java 异步编程的重要方式。3.6 方式六使用 Timer 定时任务java.util.Timer适合简单的定时或延迟任务。它的底层是单线程调度如果前一个任务执行时间过长会拖累后续任务。javaimport java.util.Timer; import java.util.TimerTask; public class TimerDemo { public static void main(String[] args) throws InterruptedException { Timer timer new Timer(true); // 设为守护线程方便退出 timer.schedule(new TimerTask() { Override public void run() { System.out.println(定时任务执行 Thread.currentThread().getName()); } }, 1000); Thread.sleep(3000); } }生产环境如果有对延迟任务、周期任务更强的控制需求建议使用ScheduledThreadPoolExecutor。3.7 方式七使用 ForkJoinPool 分治任务ForkJoinPool是面向「分而治之」的任务框架通过「工作窃取」算法把任务拆解为更小的子任务并行执行尤其适合 CPU 密集型的递归计算。javaimport java.util.concurrent.ForkJoinPool; import java.util.concurrent.RecursiveTask; public class ForkJoinDemo { static class SumTask extends RecursiveTaskLong { private static final long THRESHOLD 10_000; private final long start; private final long end; SumTask(long start, long end) { this.start start; this.end end; } Override protected Long compute() { if (end - start THRESHOLD) { long sum 0; for (long i start; i end; i) { sum i; } return sum; } long mid (start end) / 2; SumTask left new SumTask(start, mid); SumTask right new SumTask(mid 1, end); left.fork(); // 异步执行左半部分 Long rightResult right.compute(); // 同步执行右半部分 Long leftResult left.join(); // 等待左半部分结果 return leftResult rightResult; } } public static void main(String[] args) { ForkJoinPool pool new ForkJoinPool(); Long result pool.invoke(new SumTask(1, 1_000_000)); System.out.println(求和结果 result); } }3.8 方式八使用虚拟线程JDK 21JDK 21 正式引入虚拟线程它由 JVM 调度大量虚拟线程可以复用少量载体线程极大降低了线程创建、切换的开销非常适合高并发 IO 场景。javapublic class VirtualThreadDemo { public static void main(String[] args) throws InterruptedException { Thread thread Thread.ofVirtual() .name(virtual-demo) .start(() - System.out.println( 虚拟线程 Thread.currentThread().getName())); thread.join(); } }也可以使用配套的线程池工厂每个任务一个虚拟线程javaimport java.util.concurrent.Executors; public class VirtualThreadPoolDemo { public static void main(String[] args) throws InterruptedException { try (var executor Executors.newVirtualThreadPerTaskExecutor()) { for (int i 0; i 10_000; i) { final int taskId i; executor.submit(() - { Thread.sleep(1000); return 任务 taskId 完成; }); } } } }3.9 八种方式对比总结为了方便面试回答可以把这八种方式整理成一张表开启方式能否返回结果典型使用场景备注继承 Thread否简单演示受单继承限制实现 Runnable否任务与线程解耦最常用可配合线程池Callable FutureTask是需要返回值或异常通过 FutureTask 包装线程池 submit可返回生产环境主流控制并发、复用线程CompletableFuture是异步编排、回调支持串并行组合Timer否简单定时任务底层单线程生产慎用ForkJoinPool是CPU 密集型分治任务工作窃取算法虚拟线程是高并发 IO 场景JDK 21 正式特性四、大量线程会带来什么问题理解了前面的八种开启方式后还要回答面试官最常追问的问题如果开启 10000 个线程到底会怎么样答案不是「卡死」这么简单它涉及内存、系统资源、调度和 GC 多个层面。4.1 线程栈内存消耗巨大每个 Java 线程都拥有独立的虚拟机栈。JVM 默认的栈大小通常在 512KB 到 1MB 左右不同平台和版本略有差异可通过-Xss调整。如果开启 1 万个线程仅栈内存就可能占用 5GB 到 10GB很容易触发 OutOfMemoryError。java// 运行前建议先保存工作内容并在有限制的环境中测试 public class ThreadOOMDemo { public static void main(String[] args) { int count 0; while (true) { new Thread(() - { try { Thread.sleep(100_000); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } }).start(); System.out.println(已创建线程数 (count)); } } }4.2 内核线程数量与系统资源受限主流 JVM 采用一对一线程模型每个 Java 线程都对应一个操作系统内核线程。当线程数量很大时会很快耗尽操作系统的线程数上限、文件描述符等系统资源。Linux 环境中常见错误是textjava.lang.OutOfMemoryError: unable to create native thread: possibly out of memory or process/resource limits reached4.3 上下文切换开销成倍增加如果线程数远大于 CPU 核心数CPU 就需要频繁在不同线程之间切换。每次切换都要保存和恢复线程上下文还会导致 CPU 缓存失效。线程越多真正用于执行任务的 CPU 时间反而越少吞吐量下降。4.4 锁竞争和垃圾回收压力上升大量线程共享资源时锁竞争会愈发激烈很多线程可能频繁进入 BLOCKED 或 WAITING 状态。与此同时线程执行过程中产生的临时对象会加快堆内存增长触发更频繁的 GC甚至出现 GC 停顿时间明显变长的问题。五、如何优化线程池与虚拟线程「既然线程开多了有问题那应该怎么优化」这是整条追问链的关键也是面试官最想听到的答案。核心思路就两条一是用线程池控制并发规模二是根据业务类型选择更轻量的并发方案比如虚拟线程。5.1 线程池的核心参数先记住 ThreadPoolExecutor 的七个核心参数corePoolSize核心线程数线程池中会一直保留的线程数量。maximumPoolSize最大线程数核心线程忙不过来且队列满时最多能扩展到多少线程。keepAliveTime非核心线程空闲多长时间后被回收。unitkeepAliveTime 的时间单位。workQueue任务队列用于缓存提交但还没来得及执行的任务常见的有 ArrayBlockingQueue、LinkedBlockingQueue。threadFactory线程工厂用于给线程起有意义的名字便于排查问题。handler拒绝策略当线程池和队列都满时如何处理新任务。5.2 线程池的工作流程线程池处理一个新任务的整体流程可以概括为四条判断当前线程数是否小于 corePoolSize如果是新建一个核心线程执行任务。核心线程已满任务能否加入工作队列如果能先入队等待执行。队列也满了当前线程数是否小于 maximumPoolSize如果是再创建非核心线程执行任务。线程数达到上限且队列已满触发拒绝策略。常见的拒绝策略有四种AbortPolicy直接抛异常默认、CallerRunsPolicy由提交任务的线程执行、DiscardPolicy直接丢弃、DiscardOldestPolicy丢弃队列中最老的任务。javaimport java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; public class ThreadPoolExecutorDemo { public static void main(String[] args) { ThreadPoolExecutor pool new ThreadPoolExecutor( 2, 4, 60, TimeUnit.SECONDS, new ArrayBlockingQueue(10), new ThreadPoolExecutor.AbortPolicy() ); for (int i 0; i 20; i) { final int taskId i; pool.execute(() - System.out.println( 任务 taskId 由 Thread.currentThread().getName() 执行)); } pool.shutdown(); } }5.3 虚拟线程高并发 IO 场景的终极优化虚拟线程是 JDK 21 引入的轻量级线程。它的核心思想是让 JVM 在用户态调度大量虚拟线程复用少量内核线程作为载体。当虚拟线程遇到 IO 阻塞时它会自动让出载体线程让载体线程去执行其他虚拟线程从而实现极高的并发能力。虚拟线程适用于高并发 IO 密集型任务例如 HTTP 调用、数据库查询、文件读写。每个任务需要长时间等待下游响应。需要创建大量并发任务但又不希望消耗大量系统资源。虚拟线程不适用于CPU 密集型任务因为最终还是要依赖物理核心。依赖 ThreadLocal 传递大量上下文的场景虚拟线程的 ThreadLocal 支持有成本。使用了 synchronized 的代码块因为 synchronized 会导致虚拟线程被固定在载体线程上失去调度优势。5.4 线程池参数设计建议CPU 密集型任务线程数可设置为 CPU 核心数 1避免频繁上下文切换。IO 密集型任务线程数可以设置为 CPU 核心数 ×1 平均等待时间 / 平均计算时间也可以直接借助虚拟线程。混合型任务拆分为 CPU 和 IO 两类线程池分别处理。队列必须有界无界队列会掩盖系统过载的问题。拒绝策略要显式指定默认的 AbortPolicy 虽然在多数场景下可用但核心链路可以考虑 CallerRunsPolicy 形成背压。5.5 分片与批处理大量任务同时执行时把任务分片、按批处理可以有效降低瞬时并发压力分片把大任务拆成小任务每批提交固定数量。批处理批量查询数据库、批量写入减少网络往返。并发控制使用 Semaphore 或 RateLimiter 限制同时在执行的任务数。5.6 线程池监控线程池需要监控的关键指标活跃线程数activeCount。池中线程数poolSize。队列长度queue.size。完成任务数completedTaskCount。拒绝次数自定义拒绝策略中累计。这些指标可以接入 Micrometer、Prometheus、Grafana形成完整的监控体系。六、面试回答模板把前面几节的内容组织成一套可以直接背诵的面试回答模板。无论面试官从哪个角度切入都可以按下面的主线展开。6.1 「如何开启一个线程」回答Java 中开启线程有多种方式从简单到复杂分别有继承 Thread 类重写 run() 方法。简单直观但 Java 单继承扩展受限。实现 Runnable 接口把任务对象交给 Thread 启动。任务与线程解耦最常用。实现 Callable 接口配合 FutureTask。可以拿到返回值、捕获异常。使用线程池 ExecutorService。生产环境推荐能复用线程、控制并发、统一管理。使用 CompletableFuture。适合需要编排多个异步任务的场景。使用 Timer 或 ScheduledThreadPoolExecutor。适合定时、延迟任务。使用 ForkJoinPool。适合 CPU 密集型的分治任务。使用 JDK 21 的虚拟线程。适合高并发 IO 场景。实际开发中绝大多数场景都应优先使用线程池只有需要异步编排时才会用 CompletableFuture高并发 IO 场景可以考虑虚拟线程。6.2 「开启 10000 个线程会有什么问题」回答会从四个方面出问题内存消耗巨大每个线程独立栈 512KB 到 1MB10000 个线程光栈就要 5GB 到 10GB容易 OOM。系统资源受限Java 线程和内核线程一对一线程数过多会耗尽系统线程数和文件描述符抛出 unable to create native thread。上下文切换开销飙升线程数远超 CPU 核心数时CPU 大部分时间花在切换而不是执行任务上吞吐量下降。锁竞争和 GC 压力变大共享资源的锁竞争激烈临时对象堆积加快 GC 触发频率停顿时间变长。6.3 「既然线程开多了有问题那应该怎么优化」回答核心思路有两条用线程池控制规模或者用更轻量的线程模型。具体来说用线程池替代裸线程通过 corePoolSize、maximumPoolSize、workQueue 等参数控制并发上限让线程复用。按任务类型设置参数CPU 密集型用核心数 1IO 密集型可以适当放大混合型分开处理。队列必须有界无界队列会掩盖过载问题。拒绝策略要显式指定核心链路可用 CallerRunsPolicy 形成背压。使用虚拟线程JDK 21 引入高并发 IO 场景可以创建百万级线程而不耗尽资源。任务分片与批处理把大任务拆小、批量处理降低瞬时并发压力。监控线程池活跃线程、队列长度、拒绝次数等指标接入监控告警。6.4 「线程池的核心参数和工作流程」回答ThreadPoolExecutor 有七个核心参数corePoolSize、maximumPoolSize、keepAliveTime、unit、workQueue、threadFactory、handler。工作流程先创建核心线程核心线程满了入队队列满了继续创建非核心线程到 maximumPoolSize最后触发拒绝策略。6.5 面试常见追问Thread 的 start 和 run 有什么区别start 会创建新线程并让 JVM 调度 run 执行直接调用 run 只是在当前线程里当普通方法执行。Callable 和 Runnable 有什么区别Callable 有返回值可以抛异常Runnable 没有。线程池为什么推荐 ThreadPoolExecutor 而不是 ExecutorsExecutors 的快捷工厂大多使用无界队列或过大线程数容易 OOM 或线程数失控。线程池的核心线程会被回收吗默认不会除非调用 allowCoreThreadTimeOut(true)。什么是工作窃取ForkJoinPool 中空闲线程从其他线程的队列尾部窃取任务提升 CPU 利用率。七、总结「如何开启一个线程」这个看似简单的问题其实是一扇通往 Java 并发深层世界的门。回顾全文可以归纳出几条主线进程与线程的区别进程是资源分配单位线程是调度单位线程共享进程内存但有独立栈。Java 线程和内核线程一对一创建 Java 线程等于创建内核线程因此大量线程会消耗大量系统资源。八种开启方式从 Thread、Runnable、Callable到线程池、CompletableFuture、Timer、ForkJoinPool、虚拟线程各有适用场景。大量线程的四大问题栈内存消耗、系统资源受限、上下文切换开销、锁竞争和 GC 压力。优化路径线程池控制规模按任务类型设计参数队列有界拒绝策略显式监控闭环。虚拟线程JDK 21 引入的轻量级线程适合高并发 IO 场景是未来优化的重要方向。面试回答模板把原理、对比、问题、优化四条线记牢就能从容应对连环追问。
Java 线程从入门到面试通关：八种开启方式、性能陷阱与线程池优化（2 万字长文）
一、写在前面在 Java 后端面试中线程几乎是一个绕不开的话题。很多面试官喜欢从一个小问题切入再不断往深处追问比如下面这组连环问你知道有哪些方式可以开启一个线程这几种方式有什么区别你平时用哪一种如果让你开启 10000 个线程会有什么问题既然线程开多了有问题那应该怎么优化线程池的核心参数有哪些线程池的工作流程是怎样的表面上看这些问题考查的是「怎么创建线程」但真正考查的是候选人对线程底层原理、资源消耗、系统调度以及并发编程实战的理解深度。如果只会背几个创建线程的 API一旦面试官追问到线程栈、上下文切换、线程池参数设置就很容易露馅。本文就用 2 万字左右的篇幅把「如何开启一个线程、开启大量线程会有什么问题、如何优化」这条主线彻底讲透并给出可以直接照搬进面试的回答思路。文章会从线程最基础的概念讲起逐步过渡到八种开启线程的方式、大量线程带来的各种性能问题再到线程池、虚拟线程等优化手段最后整理出一套完整的面试回答模板。建议先通读理解原理再重点记忆结论和代码示例这样无论面试官如何追问都能从容应对。二、基础回顾进程与线程只有先把进程与线程的区别搞清楚才能理解「为什么大量线程会带来问题」。这一节我们先建立正确的底层认知。2.1 什么是进程进程是操作系统进行资源分配和调度的基本单位。当我们启动一个 JVM、运行一个 Java 程序时操作系统就会为其创建一个进程。进程拥有独立的内存空间包括代码段、数据段、堆、栈等。不同进程之间的内存空间是隔离的一个进程崩溃通常不会直接拖垮另一个进程。进程的核心特点是「资源隔离」。但资源隔离也有代价进程之间的通信只能通过进程间通信IPC机制完成比如管道、消息队列、共享内存、Socket 等通信成本较高。同时进程的创建和销毁开销也比较大因为操作系统需要为其分配独立的地址空间、维护进程控制块PCB等。2.2 什么是线程线程是操作系统能够进行运算调度的最小单位它被包含在进程之中是进程中的实际执行单元。一个进程可以包含多个线程同一个进程内的所有线程共享该进程的堆内存、方法区等资源但每个线程拥有自己独立的虚拟机栈、本地方法栈和程序计数器。可以把一个进程理解成一家公司线程就是公司里的员工。公司里的资源办公场地、打印机、数据库是所有员工共享的而每个员工都有自己的工作台和待办事项。多个线程共享进程资源可以更高效地利用 CPU但也因为共享资源带来了线程安全等一系列并发问题。对比维度进程线程资源分配单位是操作系统资源分配的基本单位是 CPU 调度的基本单位内存空间拥有独立地址空间共享所属进程的地址空间切换开销较大需要切换页表等相对较小但仍需保存上下文通信方式IPC如管道、共享内存、Socket可直接读写共享内存但需要同步崩溃影响一个进程崩溃不影响其他进程一个线程崩溃可能导致整个进程崩溃2.3 Java 线程与操作系统线程的映射Java 中的线程最终要映射到操作系统的内核线程才能被调度执行。历史上Java 线程模型经历过从用户线程到内核线程的演进。在 1.2 以前的早期版本中Java 曾经使用「绿色线程Green Thread」即用户态线程由 JVM 自己调度不依赖操作系统。这种方式的问题是无法充分利用多核 CPU因为操作系统只看到一个 JVM 进程在运行。从 JDK 1.2 开始Java 主流虚拟机尤其是 HotSpot VM采用一对一的线程模型即每一个 Java 线程都直接对应一个操作系统内核线程KLTKernel Level Thread。我们调用new Thread().start()时JVM 会通过系统调用创建一个真正的内核线程。这也是为什么大量创建 Java 线程会消耗操作系统资源你创建的每一层 Java 对象背后都有一个实实在在的内核线程在支撑。这种一对一模型的优点是每个线程可以真正并行运行在多核 CPU 上调度交给操作系统负责缺点是线程创建、销毁和切换都要陷入内核态成本不低。理解了这一点也就理解了后文「大量线程为什么会有问题」的底层根源。值得一提的是JDK 21 引入的虚拟线程Virtual Thread打破了这种一对一映射它由 JVM 自行调度大量虚拟线程可以复用少量内核线程载体线程。虚拟线程是解决「大量线程开销大」的重要方案本文第五章会重点展开。2.4 线程的生命周期Java 线程在java.lang.Thread.State中定义了六种状态理解这些状态有助于我们讨论线程开启、阻塞和销毁的过程NEW新建线程对象已创建但还没有调用start()方法。此时线程尚未真正启动。RUNNABLE可运行线程调用了start()后在 JVM 中处于可运行状态。注意这个状态包含「正在执行」和「等待 CPU 调度」两种情况因为底层是否真正拿到 CPU 时间片由操作系统决定。BLOCKED阻塞线程正在等待获取一个监视器锁synchronized 锁。例如线程 A 持有锁线程 B 想进入同步块就会处于 BLOCKED 状态。WAITING等待线程无限期等待另一个线程执行特定操作例如调用Object.wait()、Thread.join()或LockSupport.park()后进入的状态。需要其他线程显式唤醒。TIMED_WAITING超时等待与 WAITING 类似但有超时时间例如Thread.sleep(long)、Object.wait(long)、Thread.join(long)等。TERMINATED终止线程的run()方法执行完毕或者因为未捕获的异常退出线程结束。生命周期可以简要概括为NEW 经过start()进入 RUNNABLERUNNABLE 可能因等待锁进入 BLOCKED因等待条件进入 WAITING/TIMED_WAITING最终进入 TERMINATED。下面这段代码可以直观地观察线程状态javapublic class ThreadStateDemo { public static void main(String[] args) throws InterruptedException { Thread t new Thread(() - { System.out.println(线程运行中); }); System.out.println(创建后 t.getState()); // NEW t.start(); System.out.println(start 后 t.getState()); // 可能是 RUNNABLE t.join(); System.out.println(结束后 t.getState()); // TERMINATED } }注意代码中的-是 Java 8 引入的 Lambda 表达式写法用于简化匿名内部类。后面的示例会频繁使用这种写法如果你还停留在 Java 8 之前可以把 Lambda 表达式改写成匿名内部类二者在本质上等价。三、如何开启一个线程八种方式详解「如何开启一个线程」这个问题看似简单却能区分候选人的知识广度。很多初学者只知道继承 Thread 和实现 Runnable但实际项目里还有 Callable、线程池、CompletableFuture、虚拟线程等多种方式。下面我们逐一讲解并给出完整可运行的代码。3.1 方式一继承 Thread 类最直接的方式是继承java.lang.Thread类重写其run()方法。创建子类对象后调用start()方法即开启一个新线程。javapublic class MyThread extends Thread { Override public void run() { System.out.println(当前线程 Thread.currentThread().getName()); } public static void main(String[] args) { MyThread t1 new MyThread(); MyThread t2 new MyThread(); t1.start(); t2.start(); // 输出顺序不固定例如 // 当前线程Thread-0 // 当前线程Thread-1 } }继承Thread类的方式最简单直观但 Java 只支持单继承如果一个业务类已经继承了其他父类就无法再继承Thread扩展性比较受限。实际开发中更推荐把「任务」和「线程」解耦也就是下面要讲到的实现Runnable接口的方式。3.2 方式二实现 Runnable 接口实现java.lang.Runnable接口重写run()方法再把这个任务对象交给 Thread 启动。这样「任务」与「线程」分离拓展性更好也更适合线程池复用。javapublic class MyRunnable implements Runnable { Override public void run() { System.out.println(当前线程 Thread.currentThread().getName()); } public static void main(String[] args) { Runnable task new MyRunnable(); new Thread(task).start(); // Java 8 起可用 Lambda 进一步简化 Runnable lambdaTask () - System.out.println( Lambda 线程 Thread.currentThread().getName()); new Thread(lambdaTask).start(); } }Runnable 的缺点是没有返回值也不能直接抛出受检异常。如果你的任务需要返回计算结果就需要 Callable。3.3 方式三实现 Callable 接口配合 FutureTaskCallableV 接口的 call() 方法允许返回结果并抛出异常它不能直接交给 Thread通常要借助 FutureTask 这个包装器。javaimport java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.FutureTask; public class MyCallable implements CallableString { Override public String call() throws Exception { Thread.sleep(1000); return 任务执行完成 Thread.currentThread().getName(); } public static void main(String[] args) throws InterruptedException, ExecutionException { FutureTaskString futureTask new FutureTask(new MyCallable()); new Thread(futureTask).start(); System.out.println(获取结果 futureTask.get()); // 阻塞等待任务返回 } }FutureTask.get() 会阻塞当前调用线程直到任务执行完成这也是它与前两种方式最大的区别能拿到执行结果也能捕获执行异常。3.4 方式四使用线程池这是生产环境最推荐的方式。通过线程池复用线程避免频繁创建和销毁的开销同时可以限制并发规模。javaimport java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class ThreadPoolDemo { public static void main(String[] args) { ExecutorService pool Executors.newFixedThreadPool(3); for (int i 0; i 10; i) { final int taskId i; pool.execute(() - System.out.println( 任务 taskId 由 Thread.currentThread().getName() 执行)); } pool.shutdown(); // 不再接收新任务已有任务执行完后再关闭 } }注意Executors提供的快捷工厂方法虽然方便但其内部队列默认接近无界生产环境建议直接用ThreadPoolExecutor显式配置参数。第五章会详细介绍。3.5 方式五使用 CompletableFutureCompletableFuture 是 Java 8 引入的异步编程工具支持任务编排、回调、组合非常适合「任务之间有依赖关系」的场景。javaimport java.util.concurrent.CompletableFuture; public class CompletableFutureDemo { public static void main(String[] args) { CompletableFutureString future CompletableFuture.supplyAsync(() - { return 异步结果执行线程 Thread.currentThread().getName(); }); future.thenAccept(result - System.out.println(result)); future.join(); // 等待任务完成便于示例打印 } }它可以串行、并行地组织多个异步任务也能处理异常是现代 Java 异步编程的重要方式。3.6 方式六使用 Timer 定时任务java.util.Timer适合简单的定时或延迟任务。它的底层是单线程调度如果前一个任务执行时间过长会拖累后续任务。javaimport java.util.Timer; import java.util.TimerTask; public class TimerDemo { public static void main(String[] args) throws InterruptedException { Timer timer new Timer(true); // 设为守护线程方便退出 timer.schedule(new TimerTask() { Override public void run() { System.out.println(定时任务执行 Thread.currentThread().getName()); } }, 1000); Thread.sleep(3000); } }生产环境如果有对延迟任务、周期任务更强的控制需求建议使用ScheduledThreadPoolExecutor。3.7 方式七使用 ForkJoinPool 分治任务ForkJoinPool是面向「分而治之」的任务框架通过「工作窃取」算法把任务拆解为更小的子任务并行执行尤其适合 CPU 密集型的递归计算。javaimport java.util.concurrent.ForkJoinPool; import java.util.concurrent.RecursiveTask; public class ForkJoinDemo { static class SumTask extends RecursiveTaskLong { private static final long THRESHOLD 10_000; private final long start; private final long end; SumTask(long start, long end) { this.start start; this.end end; } Override protected Long compute() { if (end - start THRESHOLD) { long sum 0; for (long i start; i end; i) { sum i; } return sum; } long mid (start end) / 2; SumTask left new SumTask(start, mid); SumTask right new SumTask(mid 1, end); left.fork(); // 异步执行左半部分 Long rightResult right.compute(); // 同步执行右半部分 Long leftResult left.join(); // 等待左半部分结果 return leftResult rightResult; } } public static void main(String[] args) { ForkJoinPool pool new ForkJoinPool(); Long result pool.invoke(new SumTask(1, 1_000_000)); System.out.println(求和结果 result); } }3.8 方式八使用虚拟线程JDK 21JDK 21 正式引入虚拟线程它由 JVM 调度大量虚拟线程可以复用少量载体线程极大降低了线程创建、切换的开销非常适合高并发 IO 场景。javapublic class VirtualThreadDemo { public static void main(String[] args) throws InterruptedException { Thread thread Thread.ofVirtual() .name(virtual-demo) .start(() - System.out.println( 虚拟线程 Thread.currentThread().getName())); thread.join(); } }也可以使用配套的线程池工厂每个任务一个虚拟线程javaimport java.util.concurrent.Executors; public class VirtualThreadPoolDemo { public static void main(String[] args) throws InterruptedException { try (var executor Executors.newVirtualThreadPerTaskExecutor()) { for (int i 0; i 10_000; i) { final int taskId i; executor.submit(() - { Thread.sleep(1000); return 任务 taskId 完成; }); } } } }3.9 八种方式对比总结为了方便面试回答可以把这八种方式整理成一张表开启方式能否返回结果典型使用场景备注继承 Thread否简单演示受单继承限制实现 Runnable否任务与线程解耦最常用可配合线程池Callable FutureTask是需要返回值或异常通过 FutureTask 包装线程池 submit可返回生产环境主流控制并发、复用线程CompletableFuture是异步编排、回调支持串并行组合Timer否简单定时任务底层单线程生产慎用ForkJoinPool是CPU 密集型分治任务工作窃取算法虚拟线程是高并发 IO 场景JDK 21 正式特性四、大量线程会带来什么问题理解了前面的八种开启方式后还要回答面试官最常追问的问题如果开启 10000 个线程到底会怎么样答案不是「卡死」这么简单它涉及内存、系统资源、调度和 GC 多个层面。4.1 线程栈内存消耗巨大每个 Java 线程都拥有独立的虚拟机栈。JVM 默认的栈大小通常在 512KB 到 1MB 左右不同平台和版本略有差异可通过-Xss调整。如果开启 1 万个线程仅栈内存就可能占用 5GB 到 10GB很容易触发 OutOfMemoryError。java// 运行前建议先保存工作内容并在有限制的环境中测试 public class ThreadOOMDemo { public static void main(String[] args) { int count 0; while (true) { new Thread(() - { try { Thread.sleep(100_000); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } }).start(); System.out.println(已创建线程数 (count)); } } }4.2 内核线程数量与系统资源受限主流 JVM 采用一对一线程模型每个 Java 线程都对应一个操作系统内核线程。当线程数量很大时会很快耗尽操作系统的线程数上限、文件描述符等系统资源。Linux 环境中常见错误是textjava.lang.OutOfMemoryError: unable to create native thread: possibly out of memory or process/resource limits reached4.3 上下文切换开销成倍增加如果线程数远大于 CPU 核心数CPU 就需要频繁在不同线程之间切换。每次切换都要保存和恢复线程上下文还会导致 CPU 缓存失效。线程越多真正用于执行任务的 CPU 时间反而越少吞吐量下降。4.4 锁竞争和垃圾回收压力上升大量线程共享资源时锁竞争会愈发激烈很多线程可能频繁进入 BLOCKED 或 WAITING 状态。与此同时线程执行过程中产生的临时对象会加快堆内存增长触发更频繁的 GC甚至出现 GC 停顿时间明显变长的问题。五、如何优化线程池与虚拟线程「既然线程开多了有问题那应该怎么优化」这是整条追问链的关键也是面试官最想听到的答案。核心思路就两条一是用线程池控制并发规模二是根据业务类型选择更轻量的并发方案比如虚拟线程。5.1 线程池的核心参数先记住 ThreadPoolExecutor 的七个核心参数corePoolSize核心线程数线程池中会一直保留的线程数量。maximumPoolSize最大线程数核心线程忙不过来且队列满时最多能扩展到多少线程。keepAliveTime非核心线程空闲多长时间后被回收。unitkeepAliveTime 的时间单位。workQueue任务队列用于缓存提交但还没来得及执行的任务常见的有 ArrayBlockingQueue、LinkedBlockingQueue。threadFactory线程工厂用于给线程起有意义的名字便于排查问题。handler拒绝策略当线程池和队列都满时如何处理新任务。5.2 线程池的工作流程线程池处理一个新任务的整体流程可以概括为四条判断当前线程数是否小于 corePoolSize如果是新建一个核心线程执行任务。核心线程已满任务能否加入工作队列如果能先入队等待执行。队列也满了当前线程数是否小于 maximumPoolSize如果是再创建非核心线程执行任务。线程数达到上限且队列已满触发拒绝策略。常见的拒绝策略有四种AbortPolicy直接抛异常默认、CallerRunsPolicy由提交任务的线程执行、DiscardPolicy直接丢弃、DiscardOldestPolicy丢弃队列中最老的任务。javaimport java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; public class ThreadPoolExecutorDemo { public static void main(String[] args) { ThreadPoolExecutor pool new ThreadPoolExecutor( 2, 4, 60, TimeUnit.SECONDS, new ArrayBlockingQueue(10), new ThreadPoolExecutor.AbortPolicy() ); for (int i 0; i 20; i) { final int taskId i; pool.execute(() - System.out.println( 任务 taskId 由 Thread.currentThread().getName() 执行)); } pool.shutdown(); } }5.3 虚拟线程高并发 IO 场景的终极优化虚拟线程是 JDK 21 引入的轻量级线程。它的核心思想是让 JVM 在用户态调度大量虚拟线程复用少量内核线程作为载体。当虚拟线程遇到 IO 阻塞时它会自动让出载体线程让载体线程去执行其他虚拟线程从而实现极高的并发能力。虚拟线程适用于高并发 IO 密集型任务例如 HTTP 调用、数据库查询、文件读写。每个任务需要长时间等待下游响应。需要创建大量并发任务但又不希望消耗大量系统资源。虚拟线程不适用于CPU 密集型任务因为最终还是要依赖物理核心。依赖 ThreadLocal 传递大量上下文的场景虚拟线程的 ThreadLocal 支持有成本。使用了 synchronized 的代码块因为 synchronized 会导致虚拟线程被固定在载体线程上失去调度优势。5.4 线程池参数设计建议CPU 密集型任务线程数可设置为 CPU 核心数 1避免频繁上下文切换。IO 密集型任务线程数可以设置为 CPU 核心数 ×1 平均等待时间 / 平均计算时间也可以直接借助虚拟线程。混合型任务拆分为 CPU 和 IO 两类线程池分别处理。队列必须有界无界队列会掩盖系统过载的问题。拒绝策略要显式指定默认的 AbortPolicy 虽然在多数场景下可用但核心链路可以考虑 CallerRunsPolicy 形成背压。5.5 分片与批处理大量任务同时执行时把任务分片、按批处理可以有效降低瞬时并发压力分片把大任务拆成小任务每批提交固定数量。批处理批量查询数据库、批量写入减少网络往返。并发控制使用 Semaphore 或 RateLimiter 限制同时在执行的任务数。5.6 线程池监控线程池需要监控的关键指标活跃线程数activeCount。池中线程数poolSize。队列长度queue.size。完成任务数completedTaskCount。拒绝次数自定义拒绝策略中累计。这些指标可以接入 Micrometer、Prometheus、Grafana形成完整的监控体系。六、面试回答模板把前面几节的内容组织成一套可以直接背诵的面试回答模板。无论面试官从哪个角度切入都可以按下面的主线展开。6.1 「如何开启一个线程」回答Java 中开启线程有多种方式从简单到复杂分别有继承 Thread 类重写 run() 方法。简单直观但 Java 单继承扩展受限。实现 Runnable 接口把任务对象交给 Thread 启动。任务与线程解耦最常用。实现 Callable 接口配合 FutureTask。可以拿到返回值、捕获异常。使用线程池 ExecutorService。生产环境推荐能复用线程、控制并发、统一管理。使用 CompletableFuture。适合需要编排多个异步任务的场景。使用 Timer 或 ScheduledThreadPoolExecutor。适合定时、延迟任务。使用 ForkJoinPool。适合 CPU 密集型的分治任务。使用 JDK 21 的虚拟线程。适合高并发 IO 场景。实际开发中绝大多数场景都应优先使用线程池只有需要异步编排时才会用 CompletableFuture高并发 IO 场景可以考虑虚拟线程。6.2 「开启 10000 个线程会有什么问题」回答会从四个方面出问题内存消耗巨大每个线程独立栈 512KB 到 1MB10000 个线程光栈就要 5GB 到 10GB容易 OOM。系统资源受限Java 线程和内核线程一对一线程数过多会耗尽系统线程数和文件描述符抛出 unable to create native thread。上下文切换开销飙升线程数远超 CPU 核心数时CPU 大部分时间花在切换而不是执行任务上吞吐量下降。锁竞争和 GC 压力变大共享资源的锁竞争激烈临时对象堆积加快 GC 触发频率停顿时间变长。6.3 「既然线程开多了有问题那应该怎么优化」回答核心思路有两条用线程池控制规模或者用更轻量的线程模型。具体来说用线程池替代裸线程通过 corePoolSize、maximumPoolSize、workQueue 等参数控制并发上限让线程复用。按任务类型设置参数CPU 密集型用核心数 1IO 密集型可以适当放大混合型分开处理。队列必须有界无界队列会掩盖过载问题。拒绝策略要显式指定核心链路可用 CallerRunsPolicy 形成背压。使用虚拟线程JDK 21 引入高并发 IO 场景可以创建百万级线程而不耗尽资源。任务分片与批处理把大任务拆小、批量处理降低瞬时并发压力。监控线程池活跃线程、队列长度、拒绝次数等指标接入监控告警。6.4 「线程池的核心参数和工作流程」回答ThreadPoolExecutor 有七个核心参数corePoolSize、maximumPoolSize、keepAliveTime、unit、workQueue、threadFactory、handler。工作流程先创建核心线程核心线程满了入队队列满了继续创建非核心线程到 maximumPoolSize最后触发拒绝策略。6.5 面试常见追问Thread 的 start 和 run 有什么区别start 会创建新线程并让 JVM 调度 run 执行直接调用 run 只是在当前线程里当普通方法执行。Callable 和 Runnable 有什么区别Callable 有返回值可以抛异常Runnable 没有。线程池为什么推荐 ThreadPoolExecutor 而不是 ExecutorsExecutors 的快捷工厂大多使用无界队列或过大线程数容易 OOM 或线程数失控。线程池的核心线程会被回收吗默认不会除非调用 allowCoreThreadTimeOut(true)。什么是工作窃取ForkJoinPool 中空闲线程从其他线程的队列尾部窃取任务提升 CPU 利用率。七、总结「如何开启一个线程」这个看似简单的问题其实是一扇通往 Java 并发深层世界的门。回顾全文可以归纳出几条主线进程与线程的区别进程是资源分配单位线程是调度单位线程共享进程内存但有独立栈。Java 线程和内核线程一对一创建 Java 线程等于创建内核线程因此大量线程会消耗大量系统资源。八种开启方式从 Thread、Runnable、Callable到线程池、CompletableFuture、Timer、ForkJoinPool、虚拟线程各有适用场景。大量线程的四大问题栈内存消耗、系统资源受限、上下文切换开销、锁竞争和 GC 压力。优化路径线程池控制规模按任务类型设计参数队列有界拒绝策略显式监控闭环。虚拟线程JDK 21 引入的轻量级线程适合高并发 IO 场景是未来优化的重要方向。面试回答模板把原理、对比、问题、优化四条线记牢就能从容应对连环追问。
