使用multiprocessing 使用multiprocessing.dummy 單使用multiprocessing模塊的指的是多進程,使用multiprocessing.dummy則表示使用的是多線程 ...
使用multiprocessing
使用multiprocessing.dummy
單使用multiprocessing模塊的指的是多進程,使用multiprocessing.dummy則表示使用的是多線程
# from multiprocessing import Pool
from multiprocessing.dummy import Pool as ThreadPool
from multiprocessing import cpu_count
import time
import urllib2
urls = [
'http://www.baidu.com',
'http://home.baidu.com/',
'http://tieba.baidu.com/',
'http://zhidao.baidu.com/',
'http://music.baidu.com/',
'http://image.baidu.com/',
'http://python-china.org/',
'http://python-china.org/node/about',
'http://python-china.org/node/',
'http://python-china.org/account/signin',
'http://python-china.org/account/signup',
'http://www.qq.com',
'http://www.youku.com',
'http://www.tudou.com'
]
start = time.time()
results = map(urllib2.urlopen, urls)
print 'Normal:', time.time() - start
start2 = time.time()
# 開cpu_count個 worker,沒有參數時預設是 cpu 的核心數
pool = ThreadPool(processes=cpu_count)
# 線上程中執行 urllib2.urlopen(url) 並返回執行結果
results2 = pool.map(urllib2.urlopen, urls)
pool.close()
pool.join()
print 'Thread Pool:', time.time() - start2