4. 任务提交与执行

SchedulerNG 调度器 #

调度器创建与启动 #

StreamTask 详解 #

结构 #

核心方法 #

初始化 #

invoke #

beforeInvoke #

runMailboxLoop #

TaskMailboxImpl 详解

处理数据

afterInvoke #

核心方法 `runMailboxLoop` #

Mailbox 线程模型 #

方法 #