08-03 限制任务数量

题目

用两名异步工作任务处理一百个路径，让有界队列负责交付；统计同时处理数量与等待队列大小，结果按输入编号排列。

推导与做法

只创建两个长期 worker，producer 把编号和路径送进容量为 3 的队列。队列满时 await put 等待，工作任务取走一项后才有空位。

结果按输入编号写入预先建立的列表，所以完成顺序不影响最终次序。每次 get 都在 finally 中配对 task_done；结束标记每个 worker 一份。返回值同时给出最大在途数、最大排队数和首尾结果。

过程图

%% 每个节点保留输入、执行位置或执行后的实际状态。 flowchart TD S0["producer 逐项 put，队列容量3"] S1["两个worker各取一项，在途最多2"] S0 --> S1 S2["满队列使 producer 等待"] S1 --> S2 S3["按输入编号保存结果，再送两个结束标记"] S2 --> S3 classDef default fill:#EEF0FB,stroke:#4657B5,color:#24324A linkStyle default stroke:#4657B5

实现与运行

查看带注释实现。本题与相关处理函数放在同一章节代码文件中；启动工具负责定位相邻项目和选择题号。

在配套目录的 并发异步与HTTP/network_project 中运行。先按项目 README 执行 uv sync --locked。

# 使用项目解释器运行本题，题号决定执行哪一组演示。
uv run python "../../学习索引/参考实现/代码/ch08.py" 08-03

程序按题号输出处理后的值、查询结果或状态。先和前面的手算比较，再修改一项输入重跑。

查看本题运行结果

# 与上面的手算状态和题目数值逐项比较。
{
  "peak": 2,
  "queue_peak": 3,
  "count": 100,
  "first_last": [
    "/books/0",
    "/books/99"
  ]
}