# 并发模型

## BEAM 并发

FluxiQ STA 利用 Elixir/OTP 的 Actor 模型实现高效并发处理。

## 进程架构

- **Poller GenServer** - 管理文件轮询调度
- **Worker Pool** - 文件处理 Worker 池
- **Rate Limiter** - 令牌桶速率限制器
- **File Processor** - 单个文件处理进程

## 配置参数

| 参数 | 默认值 | 描述 |
|------|--------|------|
| `worker_count` | 4 | Worker 进程数量 |
| `batch_size` | 10 | 每批处理文件数 |
| `poll_interval` | 30000 | 轮询间隔 (ms) |

## 背压控制

系统通过以下机制防止过载：

1. **Worker 池大小限制** - 控制并发处理数
2. **批次大小限制** - 控制每次轮询处理量
3. **速率限制** - 遵守 BCB 速率限制
4. **重试退避** - 失败时指数退避