python pool.apply_async

`pool.apply_async()` 是 Python `multiprocessing` 模块中的一个方法，用于向进程池中提交异步任务。

其语法如下：

apply_async(func[, args[, kwds[, callback[, error_callback]]]])

其中，`func` 是要执行的任务函数，`args` 是要传入任务函数的参数，`kwds` 是要传入任务函数的关键字参数。`callback` 是任务执行完成后要调用的回调函数，`error_callback` 是任务执行发生错误时要调用的回调函数。

`apply_async()` 方法会立即返回一个 `AsyncResult` 对象，这个对象可以用来获取任务执行的结果或者等待任务执行完成。可以使用 `get()` 方法来获取任务的结果，或者使用 `wait()` 方法等待任务执行完成。

下面是一个使用 `pool.apply_async()` 方法的示例代码：

import multiprocessing

def worker(num):
    """子进程要执行的任务"""
    result = num * 2
    return result

if __name__ == '__main__':
    # 创建进程池
    pool = multiprocessing.Pool()

    # 提交任务到进程池中
    results = []
    for i in range(5):
        result = pool.apply_async(worker, args=(i,))
        results.append(result)

    # 关闭进程池
    pool.close()

    # 等待所有进程完成任务
    pool.join()

    # 输出结果
    for result in results:
        print(result.get())

在这个示例中，首先创建了一个进程池 `pool`，然后使用 `apply_async()` 方法向进程池提交任务，每个任务都会调用 `worker()` 函数，计算结果并返回。在提交完所有任务后，关闭进程池并等待所有进程完成任务。最后，遍历任务结果并输出。