使用multiprocessing.pool.map函数的问题

kc_hxd_jp

感觉很简单啊.....不知道哪里错了

1. from multiprocessing import *
   
2. import os
   
3. import time
   
4. 
   
5. def sleeper(name, seconds):
   
6.         print name
   
7.         print seconds
   
8.         time.sleep(10)
   
9.         print "Done sleeping"
   
10.        
    
11. 
    
12. if __name__=="__main__":
    
13.         pool = Pool(5)
    
14.         print "parnet process (id %s)" % os.getpid()
    
15.         pool.map(sleeper, range(10), range(10))
    
16.         print "All Done

复制代码

错误信息
D:\>python processtest.py
parnet process (id 3160)
Traceback (most recent call last):
  File "processtest.py", line 15, in <module>
    pool.map(sleeper, range(10), range(10))
  File "C:\PYTHON25\lib\site-packages\multiprocessing\pool.py", line 148, in map
    return self.map_async(func, iterable, chunksize).get()
  File "C:\PYTHON25\lib\site-packages\multiprocessing\pool.py", line 209, in map_async
    result = MapResult(self._cache, chunksize, len(iterable), callback)
  File "C:\PYTHON25\lib\site-packages\multiprocessing\pool.py", line 451, in __init__
    self._number_left = length//chunksize + bool(length % chunksize)
TypeError: unsupported operand type(s) for //: 'int' and 'list'

D:\>

azer

1. from multiprocessing import Pool
   
2. import os
   
3. import time
   
4. 
   
5. def sleeper((name, sec)):
   
6.     print name
   
7.     print sec
   
8.     time.sleep(2)
   
9.     print "Done sleeping"
   
10. 
    
11. if __name__=="__main__":
    
12.     pool = Pool(5)
    
13.     print "parnet process (id %s)" % os.getpid()
    
14.     pool.map(sleeper, zip(range(10), range(10)))
    
15.     print "All Done"

复制代码

kc_hxd_jp

多谢azer兄....