FishAsyncTask 文档

FishAsyncTask Logo

FishAsyncTask 是一个高性能异步任务管理器,支持线程池和动态伸缩。

默认采用 Rust 核心实现,提供卓越性能。安装即用,无需额外配置。

特性

  • Rust 核心实现(默认) - 状态存储和优先级队列使用 Rust 实现,性能提升 2-4x

  • Python 友好 API - 完整的 Python 接口,易于使用

  • 动态伸缩 - 根据负载自动调整工作线程数量

  • 状态跟踪 - 完整的任务状态管理和查询功能

  • 线程安全 - 使用无锁数据结构保证并发安全

  • 多种队列支持 - 内置队列、Redis、Huey、Dramatiq

  • 优先级支持 - 支持任务优先级调度

  • 任务依赖 - 支持任务依赖管理,自动处理执行顺序

快速开始

安装:

pip install fish-async-task

基础用法:

from fish_async_task import TaskManager

# 创建任务管理器
manager = TaskManager()

# 提交任务
task_id = manager.submit_task(lambda: "Hello, World!")

# 获取结果
result = manager.get_task_result(task_id)
print(result)  # 输出: "Hello, World!"

# 关闭管理器
manager.shutdown()

文档目录

索引和表格