python 多线程模块threadpo

发布时间：2019-08-24 09:29:18编辑：auto阅读（1182）

      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


关键字：

上一篇： python学习笔记（一）-文件操作

下一篇： python-SQL查询语句精华使用简要