RxJava中computation调度器的线程为何需运行在不同CPU核心？

一、为什么线程数量和CPU核心数一致？是不是必须跑在不同核心？ #

首先明确：不是强制要求每个线程必须跑在不同核心，而是这种设计是为了最大化CPU密集型任务的执行效率。

Computation调度器是专门给CPU密集型任务（比如数据计算、编码解码）设计的——这类任务的特点是一旦开始就会持续占用CPU，不会频繁阻塞等待（不像IO任务会等网络/磁盘响应）。如果线程数超过CPU核心数，操作系统就得不停在不同线程间做上下文切换，每次切换都要保存/恢复线程状态，反而会浪费大量CPU资源，拖慢整体速度。

当线程数等于核心数时，操作系统的调度器会优先把每个线程分配到不同的物理核心（这是调度策略的最优选择），让每个核心都能满负荷处理一个任务，完全避免上下文切换的开销，把CPU的利用率拉到最高。当然，如果系统里还有其他进程在占用核心，个别线程也可能被调度到同一核心，但这种情况是小概率且会降低效率，所以设计时用核心数的线程数就是为了尽量避免这种场景。

二、这类线程创建有没有特殊机制？为什么它们能并行而大量线程会“阻塞”？ #

Computation调度器的线程创建没什么特殊黑科技，底层就是基于固定大小的线程池实现的，核心线程数直接取CPU核心数（通过Runtime.getRuntime().availableProcessors()获取）。

它能稳定并行的关键，在于任务类型和线程池的匹配：

• 给它的任务都是CPU密集型，每个线程拿到任务后会持续占用CPU直到完成，操作系统没必要频繁切换线程，自然能让它们在不同核心并行跑。
• 而如果你创建上百个线程，要么是任务里有大量阻塞操作（比如IO等待），要么是线程数远超核心数，操作系统不得不频繁切换线程，切换的开销远大于任务执行的收益，看起来就像是“互相阻塞”，本质是CPU都浪费在切换上了，没真正用来处理任务。

内容的提问来源于stack exchange，提问作者Pavel Kucherenko