python多处理不运行函数

Question

我只是想看看windows上多处理的简单代码实现，但它既不进入/运行函数，也不在jupyternotebook或运行保存的.py中p>

import time
import multiprocessing
s=[1,4]
def subu(remo):
    s[remo-1]=remo*9
    print(f'here{remo}')
    return
if __name__=="__main__":
    p1=multiprocessing.Process(target=subu , args=[1])
    p2=multiprocessing.Process(target=subu , args=[2])
    p1.start()
    p2.start()
    p1.join()
    p2.join()
#     print("2222here")
print(s)
input()

.py 的输出是：

[1, 4]
[1, 4]

jupyternotebook 的输出是：

[1,4]

我希望是这样的：

here1
here2
[9,18]

上面的代码有什么问题？那么这段代码呢：

import concurrent
thread_num=2
s=[1,4]
def subu(remo):
    s[remo-1]=remo*9
    print(f'here{remo}')
    return
with concurrent.futures.ProcessPoolExecutor() as executor:
## or if __name__=="__main__":
##...    with concurrent.futures.ProcessPoolExecutor() as executor:
    results=[executor.submit(subu,i) for i in range(thread_num)]
    for f in concurrent.futures.as_completed(results):
        print(f.result())
input()

在 jupyter pull 错误中根本不运行

BrokenProcessPool: A process in the process pool was terminated abruptly while the future was running or pending.

我知道我不能指望 jupyter 运行多处理。但 saved.py 也无法运行它。它不等待输入（）就退出了

Answer 1

有几个潜在的问题。 worker 函数需要是可导入的（至少在 Windows 上），以便子进程可以找到它。而且由于父进程看不到子进程内存，因此需要返回结果。所以，把工人放在一个单独的模块中

子模块.py

def subu(remo):
    remo = remo*9
    print(f'here{remo}')
    return remo

并使用进程池的现有基础架构将工作器返回值返回给父级。你可以

import time
import multiprocessing
if __name__=="__main__":
    with multiprocessing.Pool(2) as pool:
        s = list(pool.map(subu, (1,2))) #here
    print(s)
    input()