马上注册,结交更多好友,享用更多功能,让你轻松玩转社区。
您需要 登录 才可以下载或查看,没有账号?立即注册
x
来源:http://www.open-open.com/code/view/1461224708346
- #!/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 '结束!'
复制代码
|