项目作者: zx06

项目描述 :
基于redis的分布式队列
高级语言: Python
项目地址: git://github.com/zx06/redque.git
创建时间: 2017-07-27T15:36:37Z
项目社区:https://github.com/zx06/redque

开源协议:

关键词:
queue redis

下载


redque

Build Status

基于redis的分布式队列

  • 基础使用

    1. import redque
    2. q = redque.RedisQueue("que")
    3. q.put(1)
    4. q.get()
  • 锁(多进程或者分布式场景)
    不是真正意义上的锁,只是提供一个标记

    1. import redque
    2. q = redque.RedisQueue("que")
    3. # put之前检查是否有锁,加锁成功返回True(原本没有锁),
    4. # 失败返回False(该队列已经被加锁)
    5. if q.lock(timeout=30):
    6. for i in range(100)
    7. q.put(i)
    8. q.unlock() # put结束后删除锁