python + redis 实现 分布式队列任务

import time
from queue import Queue  # 用于创建队列任务
import threading # 多线程
import redis # redis 模块
q=Queue() # 队列列表

red=redis.ConnectionPool(host="localhost",port=6379) # redis 连接池
r=redis.Redis(connection_pool=red) # redis 连接池实例

def gup(): # 生产者，产生任务丢到远程redis 维护一个队列，用于替代queue
    for x in range(100):
        r.lpush("list",x)

def gget():
    while True: # 进来首先判断一次列表长度，度过为0表示队列空了，退出
        ll=r.llen("list")
        print(ll)
        if ll==0:
            break
        try: # 增加代码健壮性
            a=r.lpop("list") # 维护的list 栈中弹出左侧的key
            print(a)
            time.sleep(2)
        except Exception as e:
            print(e)
            continue

def ma():
    for x in range(10): # 创建10个线程 ，充当线程池作用
        th=threading.Thread(target=gget)
        th.start()
    th.join()

if __name__ == '__main__':
    gup()
    time.sleep(1)
    ma()