• ? 進程是操作系統分配內存的最小單位

• ? Python中進程用到的庫 multiprocessing

• ? 簡單的多進程示例

            
              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'下載結束,用時{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'下載結束，總用時{end_time-start_time}s')

if __name__ == '__main__':
    main()
            
          

• ?進程間的通信

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

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

   ?

5. Pipe 實現進程間通信，示例如下：

            
              from multiprocessing import Process,Pipe,current_process


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

def main():

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

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

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

    p.join()


if __name__ == '__main__':
    main()


            
          

好了 進程今天就復習到這兒。明晚復習線程。。。

?

?

加油！