Flink窗口机制深度解析:从WindowOperator到Watermark实战
2026/10/2 21:49:39
先回顾一下我们写过的 9 个裸机工程,它们几乎都是同一种结构 ——超级循环(Super Loop):
intmain(void){HAL_Init();/* 各种初始化 */SystemClock_Config();MX_GPIO_Init();/* ... 外设初始化 ... */while(1)/* 超级循环 */{task_a();/* 干活 1 */delay_ms(500);/* 阻塞延时 */task_b();/* 干活 2 */}}例如29_DHT11工程的主循环:每 100ms 读一次温湿度、刷一次屏,每 200ms 翻转一次 LED。它在“一次只做一件事”时工作得很好,但随着功能增加,超级循环很快会遇到三个天花板:
delay_ms()期间 CPU 只能空转,什么也干不了。想“按键随时响应 + LED 按节奏闪烁 + 屏幕持续刷新”,就得把所有延时拆碎、把状态机写成一团。04_EXIT工程干脆把按键处理写进中断里“绕开”主循环,但中断里做消抖延时又是另一个坑(第 5 章细讲)。RTOS(实时操作系统)的思路:把每个“干活单元”拆成独立的任务(Task),每个任务里可以“自然地”写自己的循环 + 延时,操作系统负责在任务之间调度 CPU:
voidtask_dht11(void*argument)/* 温湿度读取任务