1

我需要与不同的进程并行运行一个函数。我正在使用下面的代码。我的函数参数类型是（二进制数的嵌套列表，int）。问题是当我运行脚本进程开始运行但它们在函数中间完成（检查我在代码中放置“这里”的位置）没有错误。

def CreateP(pattern):
      print("start")
      import pandas as pd
      P=[]
      for j in range( n1):
      
          for i in range(n):
              for i1 in range(n):
                  if i1!=i:

                      #Here (my processes end here)
                      if pattern[i][j]==pattern[i1][j]:
                             
                          
                                if (i,i1,j) not in P:
                                    P.append((i,i1,j))
                                    
                                if (i1,i,j) not in P:
                                    P.append((i1,i,j))
                       
                      else:
                          if pattern[i][j]==1:
                                  if (i1,i,j) not in P:
                              
                                      P.append((i1,i,j)) 
                              
                          else:
                                          if (i,i1,j) not in P:
                                              P.append((i,i1,j))
  
      pd.DataFrame(P).to_csv("test1.csv" ,index=False)
      pd.DataFrame(pattern).to_csv("test2.csv" ,index=False)               
                    
      return P


def main():
        import concurrent.futures
     
        for i in range(a1):
            with concurrent.futures.ProcessPoolExecutor(max_workers=61) as executor:
                f1=executor.submit(CreateP,( Pbig1[i],1))
                f2=executor.submit(CreateP,( Pbig2[i],2))


if __name__ == "__main__":
    main()
4

0 回答 0