[已解决]python如何同时运行两个进程？

bigmaocxd

比如现在有一个程序，程序内分为A 和B两个功能。现在想要在0~20sec 时间内运行功能A， 在15~30sec 运行功能B， 这里面有 5 sec A和B是同时运行的。
以前没有接触过并行的这类编程，请问在python中要怎么实现呢
如果可以的话，计时这块也请帮忙分析一下，谢谢！

最佳答案

月排行榜 / 总排行榜

jerryxjr1220

2018-2-22 15:21:00

调用多线程咯

1. def A():
   
2.     print("I am function A, Start!")
   
3.     import time
   
4.     time.sleep(30)
   
5.     print("I am function A, Finished!")
   
6.    
   
7. def B():
   
8.     print("I am function B, Start!")
   
9.     import time
   
10.     time.sleep(30)
    
11.     print("I am function B, Finished!")
    
12.    
    
13. import threading   
    
14. tdA = threading.Thread(target=A)
    
15. tdB = threading.Thread(target=B)
    
16. 
    
17. def main():
    
18.     import time
    
19.     st = time.time()
    
20.     deltatime = -1
    
21.     while deltatime < 60:
    
22.         if 0<deltatime<20:
    
23.             if not tdA.isAlive():
    
24.                 tdA.start()
    
25.         if 15<deltatime<30:
    
26.             if not tdB.isAlive():
    
27.                 tdB.start()
    
28.         deltatime = time.time()-st
    
29.         print(int(deltatime),"second")
    
30.         time.sleep(1)
    
31. 
    
32. main()

复制代码

跳转到最佳答案楼层

ba21

time 模块咯。这是延时 不是两个进程

影-死神

Python官方文档就有关于并行的
->中文版点击这里<-

jerryxjr1220

调用多线程咯

1. def A():
   
2.     print("I am function A, Start!")
   
3.     import time
   
4.     time.sleep(30)
   
5.     print("I am function A, Finished!")
   
6.    
   
7. def B():
   
8.     print("I am function B, Start!")
   
9.     import time
   
10.     time.sleep(30)
    
11.     print("I am function B, Finished!")
    
12.    
    
13. import threading   
    
14. tdA = threading.Thread(target=A)
    
15. tdB = threading.Thread(target=B)
    
16. 
    
17. def main():
    
18.     import time
    
19.     st = time.time()
    
20.     deltatime = -1
    
21.     while deltatime < 60:
    
22.         if 0<deltatime<20:
    
23.             if not tdA.isAlive():
    
24.                 tdA.start()
    
25.         if 15<deltatime<30:
    
26.             if not tdB.isAlive():
    
27.                 tdB.start()
    
28.         deltatime = time.time()-st
    
29.         print(int(deltatime),"second")
    
30.         time.sleep(1)
    
31. 
    
32. main()

复制代码

LargeCat

2个进程开始, 其中第二个进程在第一个进程开始后等2秒再开始.
时间缩短为了节省时间,

1. from time import ctime, sleep
   
2. import multiprocessing
   
3. 
   
4. def a(msg):
   
5.     print('i am processing %s,started at '%msg, ctime())
   
6.     sleep(4)
   
7.     print('i am processing %s,ended at '%msg, ctime())
   
8. 
   
9. if __name__=="__main__":
   
10.     p1=multiprocessing.Process(target=a, args=('1'))
    
11.     p1.start()
    
12.     sleep(2)
    
13.     p2=multiprocessing.Process(target=a, args=('2'))
    
14.     p2.start()
    
15.     print('main end at '+ctime())

复制代码

LargeCat

使用进程池来管理进程, 可以更好的利用多核CPU的性能，

同时控制运行进程数是4个进程,
如下

1. from time import ctime, sleep
   
2. import multiprocessing
   
3. 
   
4. def a(msg):
   
5.     print('i am processing %s,started at '%msg, ctime())
   
6.     sleep(4)
   
7.     print('i am processing %s,ended at '%msg, ctime())
   
8. 
   
9. if __name__=="__main__":
   
10.     pool=multiprocessing.Pool(processes=4)
    
11.     for i in range(5):
    
12.         pool.apply_async(a, (str(i), ))
    
13.     pool.close()
    
14.     pool.join()
    
15.     print('main end at '+ctime())

复制代码