课时

本讲我们解析多线程与并行性的区别：何时重在响应性，何时在多核上获得真实加速。我们将讨论通过 Thread 创建线程、实现 Runnable 以及高级的线程池 ExecutorService，看看一个数组求和的简单示例，分析并行性何时有益、何时有害，以及常见问题：数据竞争、通过 synchronized 进行同步、死锁与负载均衡。最后——对比表和场景可视化。

更专业地实践多线程：将任务提交给 ExecutorService，而不是手动创建 Thread；并管理线程池、队列和生命周期（ shutdown()、 shutdownNow()）。讲解 Runnable 与 Callable<T> 的区别，通过 Future 及其方法（ get()、 isDone()、 cancel(...)、 isCancelled()）获取结果。演示启动多个任务、 invokeAll/ invokeAny、处理 ExecutionException 以及常见错误。

弄清如何用一行代码将普通数据流切换为并行处理——通过 parallelStream() 或 .parallel()，了解 ForkJoinPool.commonPool() 底层在做什么，何时并行确实能加速（大集合、计算开销大的操作），以及何时会变慢。我们将展示过滤、聚合、排序、性能测量的示例，并剖析常见错误： forEach 中的副作用、保持顺序、集合选择以及并行度配置。

Java 并行计算实用指南：任务池 ForkJoinPool 与递归任务 RecursiveTask<T>/ RecursiveAction 的工作原理，work-stealing 算法的优势，如何通过 fork() 拆分任务并在 compute() 内使用 join() 合并结果。我们将解析通过 pool.invoke() 启动、数组求和与查找最大值的示例、 ForkJoinPool 在 parallelStream() 中的位置，以及常见错误与规避方法。

Java 并行编程实用指南：什么时候该使用 ExecutorService，哪里 parallelStream 更合适，以及哪些任务需要 ForkJoinPool。我们将讨论如何使用 ConcurrentHashMap/ CopyOnWriteArrayList 和原子类（ AtomicInteger）来确保线程安全，如何通过 System.nanoTime() 和 JMH 进行性能测量，如何处理来自 Future.get() 和 ForkJoinTask 的错误，如何正确响应 InterruptedException，以及日志记录（ Thread.currentThread().getName()）与测试（ Awaitility）的技巧。最后——工具选择表与常见错误汇总。