并行处理 - 在 python 中使用多处理并行化递归代码


如何使用

python多处理并行化以下代码

def func(a,i):
   if (a>i):
      func(a-1,i)
      func(a-5,i)
   else :
      print a

编辑:一旦父进程退出,所有子子进程也会退出,这是真的吗?

编辑 2 :

我已经实现了以下代码,但它不起作用。 你能找到错误吗?

p=[]
def func(a,i):
 if a>i :
   proc=Process(target=func,args=(a-1,i,))
   p.append(proc)
   proc=Process(target=func,args=(a-5,i,))
   p.append(proc)
 else :
   print a
if _name_=='_main_':
   proc=Process(target=func,args=(100,25,))
   p.append(proc)
   for x in p:
     x.start()
     x.join()

上面的代码只对 (100,25) 执行,而不是为子进程执行,即使子进程被添加到列表中也是如此。

在代码开头分配的变量在函数中没有保留值,因此您需要在函数中使用之前向函数添加全局。将代码更改为:

p=[]
def func(a,i):
    global p
    if a>i :
        proc=Process(target=func,args=(a-1,i,))
        p.append(proc)
        proc=Process(target=func,args=(a-5,i,))
        p.append(proc)

    else :
        print a
if _name_=='_main_':
   global p
   proc=Process(target=func,args=(100,25,))
   p.append(proc)
   for x in p:
     x.start()
     x.join()

最新更新