Python在使用multiprocessing.pool.map()调用的函数中递增一个数字
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了Python在使用multiprocessing.pool.map()调用的函数中递增一个数字,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含1335字,纯文字阅读大概需要2分钟。
内容图文
我试图在multiprocessing.pool.map()调用的函数中按顺序递增一个数字.当我运行以下代码时,我得到的数字增加的次数与每个数字的池数相同.
import time
import multiprocessing
import decimal
import random
lists = ['a', 'b', 'c', 'd', 'e', 'f', 'g', 'h','i', 'j', 'k']
def thefunction(listi):
global number
number += 1
time.sleep(decimal.Decimal(random.random()))
print time.strftime('%H:%M:%S'), number, listi
number = 0
pool = multiprocessing.Pool(4)
pool.map(thefunction, lists)
print number
结果打印出来像这样
01:01:28 1 b
01:01:28 2 e
01:01:28 1 a
01:01:28 1 c
01:01:28 1 d
01:01:28 2 h
01:01:29 2 i
01:01:29 2 g
01:01:29 3 f
01:01:29 3 j
01:01:29 3 k
0
如何正确增加数字?
(time.sleep(decimal.Decimal(random.random()))仅用于停止脚本打印到同一行)
解决方法:
该示例不起作用的原因是正在创建计数器的多个实例并单独递增.
您需要为每个启动的进程创建一个适当初始化的共享计数器和锁:
import time
from multiprocessing import Pool, Value, Lock
import decimal
import random
number = Value('i', 0)
lock = Lock()
lists = ['a', 'b', 'c', 'd', 'e', 'f', 'g', 'h','i', 'j', 'k']
def thefunction(listi):
time.sleep(decimal.Decimal(random.random()))
with lock:
number.value += 1
print time.strftime('%H:%M:%S'), number.value, listi
def initializer(*args):
global number, lock
number, lock = args
pool = Pool(4, initializer, (number, lock))
pool.map(thefunction, lists)
print number.value
内容总结
以上是互联网集市为您收集整理的Python在使用multiprocessing.pool.map()调用的函数中递增一个数字全部内容,希望文章能够帮你解决Python在使用multiprocessing.pool.map()调用的函数中递增一个数字所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。