最开始只是有这样一个想法,后来想实现一下
本文只是写一个例子,实现了开多个进程,每个进程下面开多线程,每个进程执行单独一个任务,并行执行,进程下的多线程执行任务,并发执行
import multiprocessing
import threading
import timedef m_test():for i in range(25):t=threading.Thread(target=t_test)t.setDaemon(True)t.start()t.join()def t_test():n=10while n>0:print('这是进程{0},线程{1}'.format(multiprocessing.current_process(),threading.current_thread()))n-=1print(n)# time.sleep(0.02)for i in range(4):p=multiprocessing.Process(target=m_test)print('第{}个进程'.format(i))p.start()
执行后:
进程和线程都是杂乱的,说明就是按照多个进程下多个线程执行的
存在的问题:
主进程结束后,子进程继续运行,有没有办法让主进程等待自子进程完后后结束呢?还在思考中…