python3 进程池

code

import multiprocessing
from multiprocessing import Pool
import time
import threading


g_num = 0
def test1():
    for i in range(10):
        time.sleep(1)
        print('test1',i)
def test2():
    for i in range(10):
        time.sleep(1)
        print('test2',i)
 
if __name__ == '__main__':
    pool = Pool(2)    # 允许进程池里同时放入2个进程 其他多余的进程处于挂起状态
    pool.apply_async(test1)      
    pool.apply_async(test2)
    pool.close()  # close() 必须在join()前被调用
    pool.join()    # 进程池中进程执行完毕后再关闭,如果注释,那么程序直接关闭。
    print("main")

 

 

 

 

 

 

 

 

 

 

 

 

上一篇:测试搜索同步-test2


下一篇:IDEA提示“错误运行Test2: 无法启动过程,工作目录D:\test2\test2不存在”