管道本身不支持定时或高并发，但可作为解耦生产者与消费者的可控数据通道：cron定时写入命名管道，清洗进程非阻塞读取；匿名管道串联多阶段子进程实现零io清洗；多命名管道分流多消费者；信号协同控制原子性与优雅退出。
匿名管道（pipe）和命名管道（named pipe / FIFO）本身不直接支持“定时任务”或“高并发数据清洗”，但可以作为安全、可控的数据传输通道，嵌入到异步清洗流程中。关键不是让管道“做定时”或“扛并发”，而是用它来解耦生产者与消费者，配合信号、子进程管理、非阻塞IO等机制，构建稳定的数据流骨架。
定时触发 + 管道写入：用at/cron驱动数据源，避免轮询
定时任务本身由系统调度器（cron/at/systemd timer）负责，管道只承担“瞬时投递”角色：
- cron 每5分钟执行一个脚本，该脚本采集原始日志片段 → 写入已存在的命名管道（如
/tmp/cleaner_in），写完即退出 - 清洗主进程（长期运行）始终以
O_RDONLY | O_NONBLOCK打开该 FIFO，用read()尝试读取；若无数据则立即返回，不阻塞 - 避免用
while true; do ...; sleep 1; done轮询 —— 这是伪异步，浪费CPU且不准时
匿名管道用于父子协同清洗链：单次清洗任务内部流水线化
当一次清洗需多阶段（如：解析→过滤→格式化→入库），可用匿名管道串联子进程，避免临时文件和竞态：
Zynq Linux Hardware Debug
下载
Zynq‑7000 / Zynq UltraScale+ 硬件调试技能。适用于 Xilinx Zynq（Cortex‑A9/A53 + FPGA）Linux 环境，调试 I2C、I2S、UART、GPIO 等外设。包括设备树配置、内核驱动、用户空间调试工具、交叉编译和常见问题排查，支持 PetaLinux 开发。
- 主清洗进程调用
pipe()创建一对 fd，再fork() - 子进程关闭读端，将解析后结构化数据
write()到管道；父进程关闭写端，read()接收并继续下游处理 - 整个链路在内存缓冲区完成，零磁盘IO，适合高频小批量清洗（如每秒数千条JSON日志）
- 注意：必须及时 close 未使用的 fd，否则读端可能永远阻塞（因写端未全关）
命名管道实现多消费者安全分流：应对并发清洗请求
单一清洗服务需同时响应多个上游（如不同采集 agent），不能靠一个 FIFO 串行排队：
- 创建多个命名管道，如
/tmp/cleaner_0~/tmp/cleaner_7，按哈希或轮询分发请求 - 每个清洗 worker 进程绑定一个 FIFO，独立 open + read 循环，互不干扰
- 用
open(..., O_RDWR)（而非只读）可避免“所有 reader 关闭后 writer 报 Broken pipe”问题，提升鲁棒性 - worker 异常退出时，FIFO 文件仍存在，新 worker 可无缝接管，无需重启调度器
信号协同保障清洗原子性与优雅退出
清洗过程可能跨多阶段，需响应中断或重载配置，此时信号（如 SIGUSR1/SIGTERM）配合管道状态控制更可靠：
- 主进程注册
sigaction(SIGUSR1, &sa, NULL)，收到信号后向内部控制管道（另一 FIFO）写入"RELOAD" - 清洗线程循环中
poll()监听数据管道 + 控制管道，任一就绪即响应，不卡死在 read 上 - 收到 SIGTERM 时，先停止接收新数据，等当前管道缓冲区清空后再退出，保证已进来的数据不丢失
