python中的多处理不会停止运行

Question

我从他们的网站本身尝试了一个简单的 python 多处理示例，但它没有提供任何输入。它显示为正在运行，我无法在 jupyter 笔记本中停止它。

from multiprocessing import Pool

def f(x):
    return x*x

if __name__ == '__main__':
    p = Pool(5)
    print(p.map(f, [1, 2, 3]))

其他多处理示例也是如此。它不会给出任何错误或超时或任何东西。就像陷入无限循环或死锁一样。

Answer 1

我也在Windows上。

1. 正如所指出的，“from multiprocessing.pool import ThreadPool as Pool”有效。
2. 您还需要添加 if name == ' main '：
3. 同样在下面，您需要添加：'with Pool(4) as pool:'

例子

from multiprocessing.pool import ThreadPool as Pool
from os import getpid
import time
import pandas as pd


pyfiles = [10,2,3,5]    

def scraper(x):
    results_df = pd.DataFrame({})
    print('Program started:',x,"I'm process", getpid())
    time.sleep(x)
    print('Program completed:',x)
    results_df.to_csv('multi{}.csv'.format(x))


if __name__ == '__main__':
    with Pool(4) as pool:
        start=time.time()
        result = pool.map(scraper, pyfiles)
        pool.terminate()
        pool.join()
        print("Time Taken: ",str(time.time()-start))