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