1. 线程基础与核心概念在计算机科学领域线程是操作系统能够进行运算调度的最小单位它被包含在进程之中是进程中的实际运作单元。理解线程的创建机制对于开发高性能、响应迅速的应用程序至关重要。每个线程都共享进程的内存空间但拥有独立的程序计数器、寄存器集合和栈空间这种特性使得线程成为实现并发编程的高效工具。现代操作系统普遍采用抢占式多任务处理机制线程的调度由内核负责。当我们在程序中创建多个线程时操作系统会在这些线程之间快速切换营造出并行执行的假象。这种并发执行的能力特别适合处理I/O密集型任务当一个线程等待I/O操作时其他线程可以继续执行从而显著提高CPU利用率。注意虽然线程共享进程资源减少了通信开销但也带来了同步问题。多个线程同时访问共享数据时可能引发竞态条件必须通过同步机制如互斥锁来保护临界区。2. 线程创建方法全解析2.1 继承Thread类这是Java语言中最基础的线程创建方式通过继承Thread类并重写run()方法来实现class MyThread extends Thread { Override public void run() { // 线程执行的代码逻辑 System.out.println(线程ID: Thread.currentThread().getId()); } } // 创建并启动线程 MyThread thread new MyThread(); thread.start();这种方式的优点是简单直观适合快速实现简单的线程逻辑。但缺点也很明显由于Java不支持多重继承一旦继承了Thread类就无法再继承其他类这在复杂的面向对象设计中会带来限制。实操心得start()方法会调用本地方法启动新线程而直接调用run()方法则会在当前线程中同步执行这是新手常犯的错误。线程启动后其执行顺序由操作系统调度决定具有不确定性。2.2 实现Runnable接口更推荐的线程创建方式是实现Runnable接口这种方式解耦了线程和任务class MyRunnable implements Runnable { Override public void run() { // 任务执行逻辑 System.out.println(通过Runnable创建的线程); } } // 使用方式 Thread thread new Thread(new MyRunnable()); thread.start();这种方法的主要优势在于避免了继承的单一性限制可以灵活实现多个接口更适合资源池化场景同一个Runnable实例可以被多个线程共享符合面向接口编程的原则代码耦合度更低在Java 8之后可以利用lambda表达式进一步简化new Thread(() - { System.out.println(Lambda表达式线程); }).start();2.3 使用Callable和Future当需要获取线程执行结果时Callable是比Runnable更强大的选择CallableInteger task () - { Thread.sleep(1000); return 123; }; FutureTaskInteger futureTask new FutureTask(task); new Thread(futureTask).start(); // 获取结果会阻塞直到计算完成 Integer result futureTask.get();Callable与Runnable的关键区别可以返回计算结果可以抛出受检异常需要配合Future或FutureTask使用性能提示Future.get()是阻塞调用在实际应用中应该配合超时参数使用避免长时间阻塞主线程。2.4 线程池创建方式直接创建线程在高并发场景下会导致资源耗尽使用线程池是生产环境的最佳实践ExecutorService executor Executors.newFixedThreadPool(4); // 提交Runnable任务 executor.execute(() - System.out.println(线程池任务)); // 提交Callable任务 FutureString future executor.submit(() - 结果); // 优雅关闭 executor.shutdown();Java提供的几种标准线程池newFixedThreadPool固定大小线程池newCachedThreadPool弹性大小线程池newSingleThreadExecutor单线程池newScheduledThreadPool定时任务线程池3. 线程生命周期与状态管理3.1 线程状态转换Java线程在其生命周期中会经历多种状态NEW新建状态尚未调用start()RUNNABLE可运行状态包括就绪和运行中BLOCKED阻塞状态等待监视器锁WAITING无限期等待需要其他线程显式唤醒TIMED_WAITING限期等待超时后自动唤醒TERMINATED终止状态线程执行完毕状态监测代码示例Thread thread new Thread(/*...*/); System.out.println(thread.getState()); // NEW thread.start(); System.out.println(thread.getState()); // RUNNABLE3.2 线程中断机制正确的线程中断方式是通过interrupt()方法Thread worker new Thread(() - { while (!Thread.currentThread().isInterrupted()) { // 执行任务 } System.out.println(线程被中断); }); worker.start(); // 中断线程 worker.interrupt();关键中断相关方法interrupt()设置中断标志isInterrupted()检查中断状态interrupted()检查并清除中断状态重要原则不要使用已废弃的stop()方法强制终止线程这会导致资源无法正确释放。应该通过中断机制实现优雅退出。4. 线程同步与通信4.1 同步基础synchronized关键字保证线程安全的最基本方式是使用synchronizedclass Counter { private int count 0; public synchronized void increment() { count; } public synchronized int getCount() { return count; } }synchronized的三种使用方式实例方法锁是当前实例对象静态方法锁是当前类的Class对象同步代码块可以指定任意对象作为锁4.2 更灵活的Lock接口Java 5引入了更灵活的Lock实现ReentrantLock lock new ReentrantLock(); lock.lock(); try { // 临界区代码 } finally { lock.unlock(); }Lock相比synchronized的优势可尝试获取锁(tryLock)可中断的获取锁(lockInterruptibly)公平锁选项多个条件变量支持4.3 线程间通信wait/notify机制实现线程协作class SharedResource { private boolean ready false; public synchronized void waitForReady() throws InterruptedException { while (!ready) { wait(); } } public synchronized void setReady() { ready true; notifyAll(); } }经典问题为什么wait()要在循环中调用因为可能存在虚假唤醒(spurious wakeup)唤醒后需要重新检查条件。5. 高级线程特性与最佳实践5.1 ThreadLocal的使用ThreadLocal为每个线程提供独立的变量副本ThreadLocalSimpleDateFormat dateFormat ThreadLocal.withInitial(() - new SimpleDateFormat(yyyy-MM-dd)); // 每个线程获取自己的SimpleDateFormat实例 String date dateFormat.get().format(new Date());适用场景线程安全的工具类如SimpleDateFormat避免参数层层传递事务上下文传递5.2 原子变量类java.util.concurrent.atomic包提供了高效的原子操作AtomicInteger counter new AtomicInteger(0); // 线程安全的递增 counter.incrementAndGet();常用原子类AtomicInteger/AtomicLongAtomicReferenceAtomicIntegerArrayLongAdder高并发计数器优化5.3 并发集合线程安全的集合实现ConcurrentHashMapString, Integer map new ConcurrentHashMap(); map.put(key, 1); CopyOnWriteArrayListString list new CopyOnWriteArrayList(); list.add(item);与同步包装类的区别更高的并发性能特定的线程安全保证特殊的迭代器行为6. 常见问题排查与性能优化6.1 死锁诊断与预防典型死锁示例// 线程1 synchronized (lockA) { synchronized (lockB) { /*...*/ } } // 线程2 synchronized (lockB) { synchronized (lockA) { /*...*/ } }预防策略固定锁获取顺序使用tryLock超时机制通过jstack等工具检测死锁6.2 线程泄漏问题线程泄漏常见原因忘记关闭线程池任务执行时间过长且无超时未处理的异常导致线程终止检测方法ThreadMXBean threadMXBean ManagementFactory.getThreadMXBean(); threadMXBean.dumpAllThreads(true, true);6.3 上下文切换开销减少上下文切换的方法合理设置线程池大小CPU密集型任务≈CPU核数使用协程如Quasar、Project Loom避免过度同步使用无锁数据结构性能测试代码long start System.currentTimeMillis(); for (int i 0; i 1000000; i) { synchronized (this) { count; } } System.out.println(同步耗时 (System.currentTimeMillis() - start));7. 现代并发编程趋势7.1 CompletableFuture组合式异步编程CompletableFuture.supplyAsync(() - Hello) .thenApplyAsync(s - s World) .thenAccept(System.out::println);优势链式调用简化异步编程异常处理机制完善支持任务组合allOf/anyOf7.2 响应式编程模型Reactor示例Flux.range(1, 10) .parallel() .runOn(Schedulers.parallel()) .map(i - i * 2) .subscribe(System.out::println);核心概念背压支持非阻塞I/O声明式编程风格7.3 虚拟线程Project LoomJava 19引入的轻量级线程Thread.startVirtualThread(() - { System.out.println(虚拟线程); });特点用户态线程极低创建开销百万级线程支持在实际项目中我通常会根据任务特性选择线程实现方式对于短期任务使用线程池长时间运行的服务使用独立线程需要结果返回的使用Future/Callable高并发场景考虑响应式编程。线程同步优先考虑并发集合和原子变量必要时才使用显式锁。最重要的是保持代码简洁清晰避免过度复杂的线程交互。
