python多进程pool.imap获取结果

使用`pool.imap()`方法可以获取多进程的结果。`imap()`方法返回一个迭代器，可以使用`for`循环遍历它并获取结果。

以下是一个示例代码：

import multiprocessing

def func(x):
    return x * x

if __name__ == '__main__':
    with multiprocessing.Pool(processes=4) as pool:
        results = pool.imap(func, range(10))
        for result in results:
            print(result)

在上面的代码中，`func()`函数定义了一个简单的任务，即计算一个数的平方。使用`Pool()`创建了一个具有4个进程的进程池对象，并使用`imap()`方法并行地执行任务。

`imap()`方法返回一个迭代器对象，可以在`for`循环中遍历它以获取结果。在循环中，每次迭代都会返回一个结果，直到没有更多的结果可供获取。

相关问题

如何使用python pool.imap

Python中的`pool.imap()`函数是一个迭代器函数，用于并行处理可迭代的对象。它可以让你在多个CPU核心上同时执行函数，并返回结果。

下面是一个使用`pool.imap()`函数的示例：

import multiprocessing

def square(x):
    return x*x

if __name__ == '__main__':
    mylist = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]
    with multiprocessing.Pool(processes=4) as pool:
        result = pool.imap(square, mylist)
        for r in result:
            print(r)

在这个示例中，我们定义了一个`square()`函数，用于计算一个数的平方。然后，我们创建一个包含10个数字的列表`mylist`，并使用`pool.imap()`函数并行计算每个数字的平方。我们使用`multiprocessing.Pool()`创建一个进程池，将`processes`参数设置为4，以便使用4个处理器核心来并行处理任务。`pool.imap()`函数返回一个迭代器对象，我们可以使用`for`循环来遍历结果，并打印每个数字的平方。

需要注意的是，在使用`pool.imap()`时，我们必须在`if __name__ == '__main__':`语句块中调用它。这是为了避免在Windows平台上出现多次调用的问题。

pool.imap_unordered

b'pool.imap_unordered' 是一个 Python multiprocessing 模块中的函数，用于创建进程池，并支持无序的多进程 Map 映射操作。具体功能是将一个可迭代对象作为输入，分配给进程池中的多个进程并行处理，返回一个迭代器，可以在处理完成时按任意顺序输出每个进程的处理结果。