很久以前用过，可以的，支持下

@Keyes 是什么赚钱的门道？

写个中间件

ig 牛批

@binux 嗯嗯，删除操作是在 fetch 方法里面执行的

```
async def worker(self):
"""
任务调度
:return:
"""
while True:
if not self.queue.empty():
next_data = await self.queue.get()
task_id = uuid.uuid1()
self.task_running_list.append(task_id)
if isinstance(next_data, Item):
asyncio.create_task(self.set_item(task_id, next_data.info))
else:
asyncio.create_task(self.fetch(task_id, next_data.info))
self.queue.task_done()
else:
await asyncio.sleep(0)
if self.queue.empty() and not self.task_running_list:
break
```
根据 @binux 的提示，这么处理可解决该问题。

一样可以 xpath 取到的

@Yourshell #9 谢回复！代码中是在 while 中从队列获取任务直接注册到事件循环，然后就执行了 task_done。这么如果用 join 去判断的话应该也是一样的，我尝试用链接中的例子去改写上面的爬虫代码，但是好像也是行不通，会一直阻塞。不知何故。

@binux #10 谢回复！判断任务状态，在官方文档中找到了 all_tasks 和 current_task 这两个方法，但是好像不好使，即使任务全部完成也不为 None，导致判断失败。。

@binux 请教一下这个标记的动作应该放在哪里执行？？
@so1n 替换后无法执行。。。

@Yourshell 呃，判断队列为空不是 empty 么？