版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/plychoz/article/details/86660043
进程、守护进程、消息队列
'''
#进程:进程中会有线程(主线程),cpu会调度线程,进程是为了分配资源
'''
import multiprocessing, time
def show():
for i in range(5):
print('show')
time.sleep(0.2)
def info():
for i in range(5):
print('info')
time.sleep(0.2)
if __name__ == '__main__':
ft = multiprocessing.Process(target=show)
#sc = multiprocessing.Process(target=info)
#设置守护进程
ft.daemon = True
ft.start()
#sc.start()
time.sleep(0.3)
#守护进程,让子进程终止,效果同ft.daemon = True
ft.terminate()
#主进程也会等待子进程结束后才结束
print(multiprocessing.current_process())
#进程之间不能共享全局变量
my_list = []
def add_data():
for i in range(3):
print(i)
my_list.append(i)
time.sleep(0.3)
print(my_list)
def read_data():
print('read', my_list)
if __name__ == '__main__':
add_m = multiprocessing.Process(target=add_data)
read_m = multiprocessing.Process(target=read_data)
add_m.start()
#进程等待,后面的代码要等这个进程执行完毕以后才执行
add_m.join()
read_m.start() #结果为[]
#进程之间通信,通过队列
import multiprocessing, time
#创建队列
queue = multiprocessing.Queue(3)
#添加
queue.put(1)
queue.put(2)
queue.put(3)
#queue.put(4)#如果队列已经满了,等待
#获取队列,队列先进先出
print(queue.get())
print(queue.get())
print(queue.get())
#进程使用队列通信
def add_data(queue):
for i in range(3):
# print(i)
queue.put(i)
time.sleep(0.3)
#print(my_list)
#解决一直等待的问题
queue.put(None) #等get掉一个之后,None就会添加进去
def read_data(queue):
# print('read', my_list)
while True:
value = queue.get()#队里空了,会等待
#解决等待问题
if value == None:
break
print(value)
if __name__ == '__main__':
queue = multiprocessing.Queue(3)
add = multiprocessing.Process(target=add_data,args=(queue,))
read = multiprocessing.Process(target=read_data, args=(queue,))
add.start()
read.start()