|
|
@@ -44,7 +44,8 @@ class RedisQueue:
|
|
|
def push_task(self, key, tasks, level=1):
|
|
|
"""
|
|
|
双端队列，左边推进任务
|
|
|
- :param key: 任务队列名称
|
|
|
+
|
|
|
+ :param key: 键名称
|
|
|
:param tasks: 任务
|
|
|
:param level: 优先级(int类型)，数值越大优先级越高，默认1
|
|
|
:return: 任务队列任务数量
|
|
|
@@ -64,6 +65,7 @@ class RedisQueue:
|
|
|
def pop_task(self, keys=None, priority=False):
|
|
|
"""
|
|
|
双端队列 右边弹出任务
|
|
|
+
|
|
|
:param keys: 键列表，默认为None（将获取所有任务的keys）
|
|
|
:param priority: 优先级
|
|
|
:return:
|
