python 多线程模块threadpo
短信预约 -IT技能 免费直播动态提醒
python实现线程池通常使用threading或thread模块来编写，现在已经有了threadpool模块来实现线程池。
英文文档见：http://www.chrisarndt.de/projects/threadpool/
中文文档见：http://gashero.yeax.com/?p=44
现给出一个简易的使用threadpool模块来实现线程池的例子：
# -*-coding:utf-8-*-
__author__ = 'magicpwn'
import threadpool
import time, random
# worker 工作函数【多线程中每个线程工作的函数】
def worker_get(str):
return str
# 回调函数，接受的参数（请求本身，和请求工作函数执行结果）可以省略
def print_result(request, result):
print "the result is %s %r" % (request.requestID, result)
# data 设置为有20个随机1-10间的整数的列表，（列表中每一个数作为参数传递给工作函数运行一次）
data = [random.randint(1,10) for i in range(20)]
# 声明可容纳五个线程的池
pool = threadpool.ThreadPool(5)
# 创建线程运行内容请求列表（线程工作函数，线程工作参数列表，回调函数）
requests = threadpool.makeRequests(worker_get, data, print_result)
# 将每一个线程请求扔进线程池
[pool.putRequest(req) for req in requests]
# 等待data被消耗完，所有线程运行结束。
pool.wait()上面的程序用pool.size个线程运行worker_get函数，处理了data.size个数据处理请求。
本文出自 “Get and Share” 博客，请务必保留此出处http://dgfpeak.blog.51cto.com/195468/861994
免责声明：
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的，并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据，供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
