这篇文章主要介绍了Python自定义线程池实现方法,结合实例形式较为详细的分析了Python自定义线程池的概念、原理、实现方法及相关注意事项,需要的朋友可以参考下
本文实例讲述了Python自定义线程池实现方法。分享给大家供大家参考，具体如下：
关于python的多线程，由与GIL的存在被广大群主所诟病，说python的多线程不是真正的多线程。但多线程处理IO密集的任务效率还是可以杠杠的。
我实现的这个线程池其实是根据银角的思路来实现的。
主要思路：
任务获取和执行：
1、任务加入队列，等待线程来获取并执行。
2、按需生成线程，每个线程循环取任务。
线程销毁：
1、获取任务是终止符时，线程停止。
2、线程池close()时，向任务队列加入和已生成线程等量的终止符。
3、线程池terminate()时，设置线程下次任务取到为终止符。
流程概要设计：
详细代码：
import threading import contextlib from Queue import Queue import time class ThreadPool(object): def __init__(self, max_num): self.StopEvent = 0#线程任务终止符，当线程从队列获取到StopEvent时，代表此线程可以销毁。可设置为任意与任务有区别的值。 self.q = Queue() self.max_num = max_num #最大线程数 self.terminal = False #是否设置线程池强制终止 self.created_list = [] #已创建线程的线程列表 self.free_list = [] #空闲线程的线程列表 self.Deamon=False #线程是否是后台线程 def run(self, func, args, callback=None): """ 线程池执行一个任务 :param func: 任务函数 :param args: 任务函数所需参数 :param callback: :return: 如果线程池已经终止，则返回True否则None """ if len(self.free_list) == 0 and len(self.created_list)
关于上下文处理：
来个简单例子说明：
下面的代码手动自定义了一个myopen方法，模拟我们常见的with open() as f:语句。具体的contextlib模块使用，会单独开章来将。
# coding:utf-8 import contextlib @contextlib.contextmanager#定义该函数支持上下文with语句 def myopen(filename,mode): f=open(filename,mode) try: yield f.readlines()#正常执行返回f.readlines() except Exception as e: print e finally: f.close()#最后在with代码快执行完毕后返回执行finally下的f.close()实现关闭文件 if __name__ == '__main__': with myopen(r'c:\ip1.txt','r') as f: for line in f: print line
更多关于Python相关内容感兴趣的读者可查看本站专题：《Python进程与线程操作技巧总结》、《Python Socket编程技巧总结》、《Python数据结构与算法教程》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》及《Python文件与目录操作技巧汇总》
希望本文所述对大家Python程序设计有所帮助。
以上就是Python自定义线程池实现方法分析的详细内容，更多请关注0133技术站其它相关文章！
