线程池
线程池,是一个能够重复使用已经存在的线程而不是每次都创建新的线程的机制。线程池中的线程可以执行指定的任务,当一个任务执行完成之后,线程并不会死掉,而是再次回到线程池中,等待下一个任务。
使用线程池能够有效的提高系统的资源利用率,减少系统的开销。
Python中有一个模块叫threadpool,可以方便的创建线程池。
下面是一个简单的例子:
import time from threadpool import ThreadPool, makeRequests pool = ThreadPool(4) 4个线程 def sayhello(str): print "Hello ", str time.sleep(2) return str "888" 要执行的任务 生成要执行的任务列表 args = [] for i in range(10): args.append(([i], None)) 执行任务 requests = makeRequests(sayhello, args) [pool.putRequest(req) for req in requests] 等待任务完成 pool.wait()
运行结果:
Hello 0 Hello 1 Hello 2 Hello 3 Hello 4 Hello 5 Hello 6 Hello 7 Hello 8 Hello 9
可以看到,我们在创建线程池的时候,指定了线程池的大小为4。然后我们创建了一个任务列表,将10个任务放到了任务列表中,接着我们使用makeRequests方法批量创建了这10个任务,并放到了线程池中。最后我们使用pool.wait()方法等待任务完成。
运行结果可以看到,线程池中的4个线程被重复使用,当一个任务执行完成之后,线程并不会死掉,而是再次回到线程池中,等待下一个任务。
线程池的使用能够有效的提高系统的资源利用率,减少系统的开销。