Java反应式编程中Reactor与线程模型差异及相关技术问题咨询

问题1：注册的callback会由哪个线程执行？ #

默认情况下，回调由监听对应IO事件的Reactor内部Event Loop线程执行。比如你调用反应式数据库驱动发起查询，等数据库返回结果的IO事件就绪后，就是负责监听该连接事件的Event Loop线程来执行你注册的回调。
如果你主动通过publishOn、subscribeOn操作符指定了自定义调度器，或者回调逻辑涉及需要切换线程场景的话，回调会切换到你指定调度器对应的线程池中的线程执行。注意不要在回调里写阻塞逻辑，否则会卡住Event Loop线程，导致所有绑定在该线程上的请求全部超时。

问题2：Reactor中的event loop机制是什么？请用通俗语言举例说明 #

Event Loop本质是一个常驻线程的无限循环，每一轮循环固定做三件事：

• 轮询管辖范围内所有IO连接的就绪事件（比如网络返回、磁盘IO完成）
• 按顺序处理就绪事件对应的回调逻辑
• 处理当前线程待执行的异步任务队列

举个通俗的例子：你可以把每个Event Loop线程当成奶茶店的一名专职取餐员，他不用管点单的事，就守着出餐口一直循环干活：先看有没有做好的奶茶，有就喊对应的取餐号把餐给到顾客（对应处理IO事件回调），没餐出的时候就处理手里攒的其他活比如帮客人改糖度、补打包袋（对应处理异步任务队列），全程不会闲等。一个取餐员（Event Loop线程）可以同时管几百上千个顾客的取餐通知，完全不用给每个顾客配一个专属服务员，资源利用率极高。

问题3：反应式编程处理NIO任务时，如何充分利用多核CPU性能？ #

Reactor默认会根据当前服务器的CPU核心数，启动和核心数相等的Event Loop线程，每个线程独立负责自己的事件队列和IO监听，默认会尽可能绑定到不同的CPU核心上执行，避免线程上下文切换开销。比如8核CPU就会启动8个Event Loop线程，相当于8个取餐员同时独立干活，每个都跑满一个CPU核心的性能，不会出现多核闲置的情况。
如果有额外的CPU密集型计算任务，你还可以手动创建和核心数匹配的并行调度器，把计算任务拆分后分发到不同核心的线程上并行执行，进一步把多核CPU的性能吃满。

内容的提问来源于stack exchange，提问作者Vaishagkumar R