python自定义线程池控制线程数量的示例
1.自定义线程池
importthreading importQueue importtime queue=Queue.Queue() defput_data_in_queue(): foriinxrange(10): queue.put(i) classMyThread(threading.Thread): defrun(self): whilenotqueue.empty(): sleep_times=queue.get() time.sleep(sleep_times) queue.task_done() defmain_function(): threads_num=6 whileTrue: put_data_in_queue() foriinxrange(threads_num): myThread=MyThread() myThread.setDaemon(True) myThread.start() queue.join() time.sleep(60)
2.多线程与signal信号的监控结合
importthreading importQueue importtime importsignal queue=Queue.Queue() stop=False defreceive_signal(signum,stack): signal.signal(signal.SIGTERM,original_sigterm) globalstop stop=True defput_data_in_queue(): foriinxrange(10): queue.put(i) classMyThread(threading.Thread): defrun(self): whilenotqueue.empty(): sleep_times=queue.get() time.sleep(sleep_times) queue.task_done() defmain_function(): threads_num=6 whilenotstop: put_data_in_queue() foriinxrange(threads_num): myThread=MyThread() myThread.setDaemon(True) myThread.start() queue.join() time.sleep(60) if__name__=="__main__": original_sigterm=signal.getsignal(signal.SIGTERM) signal.signal(signal.SIGTERM,receive_signal) main_function()
以上这篇python自定义线程池控制线程数量的示例就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持毛票票。
热门推荐
10 拿到驾照的祝福语简短
11 关于旅游的简短祝福语
12 亲戚结婚祝福语简短大全
13 女孩自己生日祝福语简短
14 虎年春节拜年祝福语简短
15 接到英文简短老师祝福语
16 爱心大叔生日祝福语简短
17 精简短句生日祝福语
18 买车新年祝福语简短创意