Python 通用任务队列（内存+线程池，可持久化）

用途 / 功能

后台任务处理、批量耗时操作、消息处理

简介

这是一个纯 Python 实现的轻量级任务队列，基于线程池和优先级队列构建，专为中小项目设计。它支持任务提交、失败自动重试、优先级调度以及完成/错误回调，无需依赖 Celery 或 Redis，进程内即可运行。适用于后台任务处理、批量耗时操作和消息队列场景。通过 PriorityQueue 实现任务优先级控制，配合线程池并发执行，既保证了执行效率，又避免了引入外部依赖的复杂度。对于不需要分布式部署、但需要异步任务调度的项目来说，这是一个轻量且实用的选择。

代码预览

使用说明

TaskQueue(workers=N).start() 然后 submit(fn, args)

依赖环境

无（标准库）