我在Python中定义了一个函数,它使用伽比特库来找到博弈论模型的纳什均衡。我有二十种不同的博弈,并且能够写一个循环,找出每个博弈的纳什均衡。给定游戏的输出如下所示:
(“多项式系统方法:”,[“家庭”的)
现在,我试图在apply_async
包中使用multiprocessing
包并行化这个任务,使用如下代码:
# Open the pool for parallelization
pool = mp.Pool(mp.cpu_count())
# Run a loop in parallel to find the Nash equilibria of all the families
nasheqobj = {f:pool.apply_async(find_nash, args=[f]) for f in range(20)}
pool.close()
pool.join()
# Retrieve the output of the loop
nasheq_fams = {}
for f in range(20):
nasheq_fams[f] = nasheqobj[f].get()
print('Results from running in parallel: ', nasheq_fams)
但是,当我试图检索存储在nasheqobj
中的循环的输出以创建字典nasheq_fams
时,我会得到来自nasheq_fams[f] = nasheqobj[f].get()
的错误。
引发self._value multiprocessing.pool.MaybeEncodingError:错误发送结果:‘[家庭的]。原因:'TypeError('self.profile不能转换为用于泡菜的Python对象‘)
这个问题似乎与函数的输出格式化方式有关(例如,[<NashProfile for 'family': [[0.0, 1.0, 0.0, 0.0], [0.0, 1.0]]>]
),但我不知道它有什么问题.
发布于 2021-10-09 02:27:59
谢谢大家的评论。我做了更多的研究,结果发现NashProfile类不是一个纯Python类,也不支持被腌制。最后,我将NashProfile中的信息保存到了一个列表中,并将其传递给了周围的人,它起了作用。
https://stackoverflow.com/questions/69485244
复制