用Queue控制python多线程并发数量|开发技术分享-西西软件园

python 多线程如果不进行并发数量控制，在启动线程数量多到一定程度后，会造成线程无法启动的错误。

下面介绍用 Queue 控制多线程并发数量的方法 (python3).


	# -*- coding: utf-8 -*-
	import threading
	import Queue
	import random
	import time
	maxThreads = 3
	class store(threading.Thread):
   	 def __init__(self, store, queue):
        	threading.Thread.__init__(self)
        	self.queue = queue
        	self.store = store

    	def run(self):
       	 try:
           	 time.sleep(random.randint(1,3))
            	print('This is store %s' % self.store)
       	 except Exception as e:
            	print(e)
        	finally:
           	 self.queue.get()
            	self.queue.task_done()

	def main():
    	q = Queue.Queue(maxThreads)
    	for s in range(15):
        	q.put(s)
        	t = store(s, q)
       	 t.start()
    	q.join()
   	 print('over')
	if __name__ == '__main__':
   	 main()

上一篇: PyQt5日期时间控件QDateTimeEdit实例二下一篇: 【Python面试】谈谈对 Python 和其他语言的区别？

西西软件

用 Queue 控制 python 多线程并发数量

相关推荐

随机推荐

热门专题