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)