#!/usr/bin/env python2.7
# -*- coding: utf-8 -*-
import threadpool
import time,random
"""
安装threadpool
sudo easy_install threadpool
"""
def threadpool_test(arg):
# 做一些事情
time.sleep(0.01)
return arg
def print_result(request, result):
print "结果 %s %r" % (request.requestID, result)
if __name__ == "__main__":
data = ['test_%d' % i for i in range(20)]
pool = threadpool.ThreadPool(5)
requests = threadpool.makeRequests(threadpool_test, data, print_result)
for req in requests:
pool.putRequest(req)
pool.wait()
print '结束!'
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。