用redis实现队列实例

queue input

#coding = utf-8
__autor__ = 'litao'
import redis
import time
pool = redis.ConnectionPool(host='192.168.1.106',password="Password!23", port=6379, decode_responses=True)
r = redis.Str1ictRedis(connection_pool=pool)
start = time.time()
a = []
for i in range(10000):
    with open("souce",'r',encoding='utf-8') as f:
        for line in f.readlines():
            a.append(line.strip())
r.lpush('all', a)
print(r.llen("all"))
end = time.time()
print(end-start)

queue get -----1

#coding = utf-8

__autor__ = 'litao'

import time
import redis
pool = redis.ConnectionPool(host='192.168.1.106',password="Password!23", port=6379, decode_responses=True)
r = redis.StrictRedis(connection_pool=pool)
while True:
    a = time.time()
    if r.lindex("all",0) != None:
        print(r.rpop("all"))
    else:
        break
        # print(r.llen("all"))
        time.time()
        # time.sleep(2)

queue get -----2

#coding = utf-8

__autor__ = 'litao'

import time
import redis
pool = redis.ConnectionPool(host='192.168.1.106',password="Password!23", port=6379, decode_responses=True)
r = redis.StrictRedis(connection_pool=pool)
while True:
    if r.llen("all"):
        print(r.rpop("all").strip())
        # print(r.llen("all"))
        # time.sleep(2)

巴特西

用redis实现队列实例

最新文章

热门文章