关于进程池下子进程无法运行的问题

fc5igm

1.     # processes=[]
   
2.     #
   
3.     # for index in range(start_index,end_index):
   
4.     #     if len(processes) < 4:
   
5.     #         processes.append(
   
6.     #             Process(target=analysis, args=(input_data,alldate,index,lock))
   
7.     #         )
   
8.     #     else:
   
9.     #         for process in processes:
   
10.     #             process.start()
    
11.     #         for process in processes:
    
12.     #             process.join()
    
13.     #         processes.clear()
    
14.     #         processes.append(
    
15.     #             Process(target=analysis, args=(input_data,alldate,index,lock))
    
16.     #         )
    
17.     # for process in processes:
    
18.     #     process.start()
    
19.     # for process in processes:
    
20.     #     process.join()
    
21.     # processes.clear()
    
22.     lock = multiprocessing.Manager().Lock()
    
23.     pool = multiprocessing.Pool(processes=4)
    
24.     for index in range(start_index, end_index):
    
25.         pool.apply_async(analysis, (input_data,alldate,index,lock))
    
26.     pool.close()
    
27.     pool.join()

复制代码

之前本来做的是多进程（以上代码被注释了的部分），可以成功运行，然后想要改为进程池，结果反馈都是这样的

1. D:\python\pypy\pypy3.exe D:/python/works/project3/analysis.py
   
2. start date: 2021-06-29
   
3. 8.153712034225464
   
4. 
   
5. Process finished with exit code 0

复制代码

程序内涉及了数据库的写入，原本用被注释了的多进程代码运行可以运行。改用进程池后，打开数据库一看，一条都没写入，显然是没有成功运行，但是也没有报错。
经查有的人说可以用cmd运行，结果cmd运行的结果也和pycharm的反馈相同。
analysis函数下的第一个参数input_data是个字典，第二个alldate是个列表，index是个数值，lock则是进程锁。
是不是我参数部分写的有问题啊？

fc5igm

编译器改回了python试了下，还是不可以

1. D:\python\python.exe D:/python/works/project3/analysis.py
   
2. start date: 2021-06-29
   
3. 3.161548614501953
   
4. 
   
5. Process finished with exit code 0

复制代码

fc5igm

顶帖

fc5igm

顶帖