• ? 進(jìn)程是操作系統(tǒng)分配內(nèi)存的最小單位

• ? Python中進(jìn)程用到的庫 multiprocessing

• ? 簡單的多進(jìn)程示例

            
              from multiprocessing import Process
from time import time,sleep
from random import randint

def download_task(task_name):
    print(task_name+'開始下載')
    time =randint(1,5)
    sleep(time)
    print(task_name+f'下載結(jié)束,用時{time}s')


def main():
    print('開始下載。。。')
    start_time = time()
    p1 = Process(target=download_task,args=('task_1',))
    p1.start()

    p2 = Process(target=download_task,args=('task_2',))
    p2.start()

    p1.join()
    p2.join()

    end_time = time()

    print(f'下載結(jié)束，總用時{end_time-start_time}s')

if __name__ == '__main__':
    main()
            
          

• ?進(jìn)程間的通信

1. 多進(jìn)程的內(nèi)存空間是獨(dú)立的不能使用普通的全局變量來傳遞信號
2. 可以使用multiprocessing 中的?Queue、Pipe、Manager、Event
3. 今天只復(fù)習(xí)queue和pipe
4. Queue 實現(xiàn)進(jìn)程間通信示例如下：要注意的是：Queue 是為進(jìn)程服務(wù)的而 queue中的Queue 是為線程服務(wù)的

                   
                     from multiprocessing import Process,Queue,current_process
   
   def add_task(q):
       print(f'子進(jìn)程{current_process().pid}操作')
   
       q.put('python')
   
   def main():
   
       #創(chuàng)建進(jìn)程通信的 Queue
       q = Queue()
   
       #創(chuàng)建子進(jìn)程
       p = Process(target=add_task,args=(q,))
   
       p.start()
   
       print(f'父進(jìn)程{current_process().pid}讀取')
   
       print(q.get())
   
       p.join()
   
   if __name__ == '__main__':
       main()
                   
                 

   ?

5. Pipe 實現(xiàn)進(jìn)程間通信，示例如下：

            
              from multiprocessing import Process,Pipe,current_process


def add_task(p_b):
    print(f"進(jìn)程 {current_process().pid} 寫入")
    p_b.send("python")

def main():

    #創(chuàng)建管道 ,返回管道兩端
    p_a ,p_b= Pipe()

    p =Process(target=add_task,args=(p_b,))

    p.start()
    print(f"進(jìn)程 {current_process().pid} 讀取")
    print(p_a.recv())

    p.join()


if __name__ == '__main__':
    main()


            
          

好了 進(jìn)程今天就復(fù)習(xí)到這兒。明晚復(fù)習(xí)線程。。。

?

?

加油！