Python 3 中的多处理

Multiprocessing in Python 3

我有两个变量需要依次定义。如何使用多处理定义它们?

train_X = preprocess_data(train_X)
test_X = preprocess_data(test_X)

A Pool 让这变得足够简单:

with multiprocessing.Pool() as pool:
    train_X, text_X = pool.map(preprocess_data, (train_X, test_X))

只要确保你做了足够的工作来处理值得将数据传入和传出子进程(当你使用 Pool workers 时隐式发生)。