python - 收集 IronPython 并行循环结果

Question

我正在尝试从 IronPython 中的任务方法获取结果，类似于results.get使用 CPython multiprocessing.Queue

from System.Threading.Tasks import *
def testThread(dataPnt,constData):
    return dataPnt

def main():

    dataToSplit = range(5)
    constData = 10

    threadResult = Parallel.ForEach(dataToSplit, lambda dataPnt: testThread(dataPnt,constData))

    print(threadResult)

main()

此时threadResult为System.Threading.Tasks.ParallelLoopResult但我找不到任何像样的文档。最接近的是this post但它正在递增，我需要返回一个数组。

Answer 1

Parallel.ForEach是一个多处理操作，但考虑到您期望操作的结果，您必须使用共享结果变量(例如某种 concurrent collection )或使用 parallel LINQ projection operation .

接近您的示例的方法可能如下所示:

# get LINQ dependencies
import clr
clr.AddReference("System.Core")
import System
clr.ImportExtensions(System.Linq)

from System.Threading.Tasks import *
def testThread(dataPnt,constData):
    print dataPnt
    return dataPnt

def main():

    dataToSplit = range(5)
    constData = 10

    threadResult = dataToSplit.AsParallel().Select(lambda dataPnt: testThread(dataPnt,constData)).ToList()

    print(threadResult)

main()