原文链接:http://www.juzicode.com/archives/3768
错误提示:
在使用Python的multiprocessing启动多进程时,实际上没有启动多进程,看到的“子进程”id和主进程id是同一个:
'''
author: juzicode
address: www.juzicode.com
公众号: 桔子code/juzicode
'''
import os,time, multiprocessing
def func1():
proc_name = multiprocessing.current_process().name
proc_id = os.getpid()
print('进入子进程: pid = ', proc_id,' name=',proc_name)
loopcnt = 0
while loopcnt < 10:
loopcnt = loopcnt + 1
print('子进程: %s, loopcnt=%d' % (proc_id, loopcnt))
time.sleep(0.2)
print('退出子进程: ' , proc_id)
if __name__ == '__main__':
print('\n-----欢迎来到www.juzicode.com')
print('-----公众号: 桔子code/juzicode \n')
proc_name = multiprocessing.current_process().name
proc_id = os.getpid()
print('进入主进程: pid = ', proc_id,' name=',proc_name)
p1 = multiprocessing.Process(target=func1(), name='func1')
p1.start()
time.sleep(5)
print('退出主进程: ' ,proc_id)
运行该文件看到的主进程pid和子进程pid是一样的:
错误原因:
1、该语句p1 = multiprocessing.Process(target=func1(), name=’func1′)试图启动一个子进程,但是target赋值的不是一个函数对象,而是函数返回值,我们知道函数的调用方式是函数名(),会导致该函数执行,而函数func1中没有显式地使用return语句,实际上返回的是一个None,所以target赋值的是一个None,所有该语句并没有启动一个子进程。
解决方法:
1、去掉func1()中的括号(),只使用func1:
p1 = multiprocessing.Process(target=func1, name='func1')
扩展内容:
如果本文还没有完全解决你的疑惑,你也可以在微信公众号“桔子code”后台给我留言,欢迎一起探讨交流。