博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
用redis实现队列实例
阅读量:6915 次
发布时间:2019-06-27

本文共 1298 字,大约阅读时间需要 4 分钟。

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)
 

转载于:https://www.cnblogs.com/crawer-1/p/7638860.html

你可能感兴趣的文章
第十四周(OOP版电子词典)
查看>>
网络基础知识小小说
查看>>
linux lsof命令详解
查看>>
POJ 1163 The Triangle【dp+杨辉三角加强版(递归)】
查看>>
vue如何在路由跳转的时候更新组件
查看>>
Java多线程(二)
查看>>
《深入浅出数据分析》读后具体解释
查看>>
C++中的异常安全性
查看>>
Xcode中的变量模板(variable template)的使用方法
查看>>
java POI实现Excel单元格数据换行
查看>>
python3第一次作业
查看>>
国内物联网平台初探(三) ——QQ物联·智能硬件开放平台
查看>>
Python开源框架、库、软件和资源大集合
查看>>
透过IL看C# 开篇
查看>>
那是什么进程 —— wmpnscfg.exe是什么? 它为何运行?
查看>>
g++宏扩展
查看>>
《http权威指南》阅读笔记(七)
查看>>
webservices base64编码
查看>>
泛型数组
查看>>
设计模式的征途—4.抽象工厂(Abstract Factory)模式
查看>>