我有一个生成器(或者,一组生成器)。让我们把它们称为gens
gens
中的每个生成器都是一个复杂的函数,它返回复杂过程的下一个值。幸运的是,它们相互独立。
我想对gens
中的每个元素gen
调用gen.__next __()
,并将结果值作为列表返回。但是,multiprocessing无法对生成器进行pickle处理。
在Python中,是否有一种快速简单的方法来实现这一点?我希望gens
的长度为m,在我的本地机器上映射到n个核心,其中n可以大于或小于m。每个生成器应该在单独的核心上运行。
如果这是可能的,能否提供一个最小的示例?
but I am looking for a minimal solution
, great but that would require a minimal reproducible example from your side as well :). Maybe give an example of thecomplicated function that returns the next value of a complicated procedure
- Akshay Sehgal