这是python中多线程的简单代码。
p1 = multiprocessing.Process(target=f1, args=('f1'))
p2 = multiprocessing.Process(target=f2, args=('f2'))
p1.start()
# starting process 2
p2.start()
# wait until process 1 is finished
p1.join()
# wait until process 2 is finished
p2.join()
但是在运行代码后,我收到以下错误:
BrokenPipeError:[Errno 32] 损坏的管道
我搜索了 SO 和其他网站,常见的答案是包含以下代码段:
from signal import signal, SIGPIPE, SIG_DFL
signal(SIGPIPE, SIG_DFL)
但是当我运行它时,我收到以下错误:
ImportError:无法从“信号”导入名称“SIGPIPE”(C:\Users\u65988\AppData\Local\Continuum\anaconda3\lib\signal.py)
我尝试检查所有解决方案,但没有一个解决方案!请帮我解决这个问题!
两个功能供参考:
def f1 (string):
print(string)
def f2 (string):
print(string)