【原创】简单的python多线程队列
2017-03-20 14:42
176 查看
import threading #线程库
import Queue #队列库
import string #字符串操作库
#继承Thread
class g(threading.Thread):
def __init__(self,
que):
threading.Thread.__init__(self)
self.que = que
def run
(self):#重写run方法
while True:
if not
self.que.empty():
print "%s:%s," % (self.name,
self.que.get())#输出线程名字,取队列内容
else:
break
que = Queue.Queue() #实例一个queue队列
thread_num = 5 #要开启的线程数量
k = string.ascii_letters #+ string.digits #大小写字母,数字
for i in k:
que.put(i)
#将大小写字母填充至队列(貌似是生产者?),也就是生成需要用到的资源,比如文件的url等
for i in range(1, thread_num + 1):
h = g(que)
#实例指定数量的线程
h.start() #启动线程
-----
================================ RESTART
================================
>>>
>>>
Thread-1:a,Thread-2:b,Thread-3:c,Thread-4:d,
Thread-1:e,Thread-2:f,Thread-3:g,Thread-4:h,
Thread-1:i,Thread-2:j,Thread-3:k,Thread-4:l,
Thread-1:m,Thread-2:n,Thread-3:o,Thread-4:p,
Thread-1:q,Thread-2:r,Thread-3:s,Thread-4:t,
Thread-1:u,Thread-2:v,Thread-3:w,Thread-4:x,
Thread-1:y,Thread-2:z,Thread-3:A,Thread-4:B,
Thread-1:C,Thread-2:D,Thread-3:E,Thread-4:F,
Thread-1:G,Thread-2:H,Thread-3:I,Thread-4:J,
Thread-1:K,Thread-2:L,Thread-3:M,Thread-4:N,
Thread-1:O,Thread-2:P,Thread-3:Q,Thread-4:R,
Thread-1:S,Thread-2:T,Thread-3:U,Thread-4:V,
Thread-1:W,Thread-2:X,Thread-3:Y,Thread-4:Z,
================================ RESTART
================================
>>>
>>>
Thread-1:a,Thread-2:b,Thread-3:c,Thread-4:d,
Thread-1:e,Thread-4:f,
Thread-1:g,Thread-4:h,
Thread-1:i,Thread-4:j,
Thread-1:k,Thread-4:l,
Thread-1:m,Thread-4:n,
Thread-1:o,Thread-4:p,
Thread-1:q,Thread-4:r,
Thread-1:s,Thread-4:t,
Thread-1:u,Thread-4:v,
Thread-1:w,Thread-4:x,
Thread-1:y,Thread-4:z,
Thread-1:A,Thread-4:B,
Thread-1:C,Thread-4:D,
Thread-1:E,Thread-4:F,
Thread-2:G,Thread-1:H,Thread-3:I,Thread-4:J,
Thread-2:K,Thread-1:L,Thread-3:M,Thread-4:N,
Thread-2:O,Thread-1:P,Thread-3:Q,Thread-4:R,
Thread-2:S,Thread-1:T,Thread-3:U,Thread-4:V,
Thread-3:W,Thread-2:X,
Thread-2:Y,Thread-3:Z,
运行结果肿么这么乱捏...
import Queue #队列库
import string #字符串操作库
#继承Thread
class g(threading.Thread):
def __init__(self,
que):
threading.Thread.__init__(self)
self.que = que
def run
(self):#重写run方法
while True:
if not
self.que.empty():
print "%s:%s," % (self.name,
self.que.get())#输出线程名字,取队列内容
else:
break
que = Queue.Queue() #实例一个queue队列
thread_num = 5 #要开启的线程数量
k = string.ascii_letters #+ string.digits #大小写字母,数字
for i in k:
que.put(i)
#将大小写字母填充至队列(貌似是生产者?),也就是生成需要用到的资源,比如文件的url等
for i in range(1, thread_num + 1):
h = g(que)
#实例指定数量的线程
h.start() #启动线程
-----
================================ RESTART
================================
>>>
>>>
Thread-1:a,Thread-2:b,Thread-3:c,Thread-4:d,
Thread-1:e,Thread-2:f,Thread-3:g,Thread-4:h,
Thread-1:i,Thread-2:j,Thread-3:k,Thread-4:l,
Thread-1:m,Thread-2:n,Thread-3:o,Thread-4:p,
Thread-1:q,Thread-2:r,Thread-3:s,Thread-4:t,
Thread-1:u,Thread-2:v,Thread-3:w,Thread-4:x,
Thread-1:y,Thread-2:z,Thread-3:A,Thread-4:B,
Thread-1:C,Thread-2:D,Thread-3:E,Thread-4:F,
Thread-1:G,Thread-2:H,Thread-3:I,Thread-4:J,
Thread-1:K,Thread-2:L,Thread-3:M,Thread-4:N,
Thread-1:O,Thread-2:P,Thread-3:Q,Thread-4:R,
Thread-1:S,Thread-2:T,Thread-3:U,Thread-4:V,
Thread-1:W,Thread-2:X,Thread-3:Y,Thread-4:Z,
================================ RESTART
================================
>>>
>>>
Thread-1:a,Thread-2:b,Thread-3:c,Thread-4:d,
Thread-1:e,Thread-4:f,
Thread-1:g,Thread-4:h,
Thread-1:i,Thread-4:j,
Thread-1:k,Thread-4:l,
Thread-1:m,Thread-4:n,
Thread-1:o,Thread-4:p,
Thread-1:q,Thread-4:r,
Thread-1:s,Thread-4:t,
Thread-1:u,Thread-4:v,
Thread-1:w,Thread-4:x,
Thread-1:y,Thread-4:z,
Thread-1:A,Thread-4:B,
Thread-1:C,Thread-4:D,
Thread-1:E,Thread-4:F,
Thread-2:G,Thread-1:H,Thread-3:I,Thread-4:J,
Thread-2:K,Thread-1:L,Thread-3:M,Thread-4:N,
Thread-2:O,Thread-1:P,Thread-3:Q,Thread-4:R,
Thread-2:S,Thread-1:T,Thread-3:U,Thread-4:V,
Thread-3:W,Thread-2:X,
Thread-2:Y,Thread-3:Z,
运行结果肿么这么乱捏...
相关文章推荐
- Python实现简单多线程任务队列
- Python实现简单多线程任务队列
- Python--简单的多线程服务端
- Python 多线程简单例子
- python 多线程就这么简单
- python基于mysql实现的简单队列以及跨进程锁实例详解
- Python爬虫之路——简单网页抓图升级版(增加多线程支持)
- 简单的学习Python多线程
- Python 多线程 -thread threading Queue- 简单学习
- python 简单的多线程链接
- 【多线程】python界面阻塞,白屏,not responding解决的简单例子
- 【Python】多线程-简单
- 【多线程】python界面阻塞,白屏,not responding解决的简单例子
- python 多线程 +队列下载资源
- c++ 多线程阻塞队列的简单实现
- python 简单的多线程链接(二)
- 基于HTTP协议的轻量级开源简单队列服务:HTTPSQS[原创]
- python实现简单的redis 队列 SIMPLE PYTHON QUEUE WITH REDIS
- 【多线程】python界面阻塞,白屏,not responding解决的简单例子
- python基于mysql实现的简单队列以及跨进程锁