進(jìn)程與線程

進(jìn)程（process）就是任務(wù)，是計(jì)算機(jī)系統(tǒng)進(jìn)行資源分配和調(diào)度的基本單位[1]。比如，打開一個(gè)word文件就是啟動(dòng)了一個(gè)word進(jìn)程。

線程（thread）是進(jìn)程內(nèi)的子任務(wù)。比如word中可以進(jìn)行編輯、拼寫檢查和打印等子任務(wù)。

我們目前的操作系統(tǒng)都是多任務(wù)的操作系統(tǒng)，多任務(wù)的實(shí)現(xiàn)方式[2]：

• 多進(jìn)程
• 多線程
• 多進(jìn)程 + 多線程

多進(jìn)程：multiprocessing模塊

Unix Like[3]系統(tǒng)中，可以用python中os模塊的os.fork()方法，為當(dāng)前進(jìn)程創(chuàng)建一個(gè)“子進(jìn)程”[4]，當(dāng)前進(jìn)程稱作“父進(jìn)程”。

說的簡單一點(diǎn)，就是當(dāng)你調(diào)用os.fork()以后，會(huì)有兩個(gè)進(jìn)程運(yùn)行這之后的代碼，它們的pid（process id）不一樣。

由于一些玄學(xué)或是一些不知名的原因，用這個(gè)方法以后，我心愛的mbp風(fēng)扇呼呼響，所以只好作罷。

multiprocessing模塊比os.fork()好用的多，這個(gè)模塊也可以用于創(chuàng)建多進(jìn)程。而且它有一些基本的對象如Queue等支持進(jìn)程間通信。下面主要討論用multiprocessing模塊怎么實(shí)現(xiàn)多進(jìn)程。

• 創(chuàng)建一個(gè)子進(jìn)程

multiprocessing.Process類可以初始化一個(gè)子進(jìn)程，target參數(shù)傳入子進(jìn)程函數(shù)。

from multiprocessing import Process
import os, time# 子進(jìn)程函數(shù)
def sub_process():print('Sub Process (%s) Start!' % os.getpid())for i in reversed(range(3)):time.sleep(1)print(i+1)time.sleep(1)print('Over!')print('Main Prcess (%s) Start!' % os.getpid())
for i in reversed(range(3)):time.sleep(1)print(i+1)
time.sleep(1)
print('GO!')
time.sleep(1)
p = Process(target=sub_process)
# 子進(jìn)程開始
p.start()
# 等待子進(jìn)程結(jié)束
p.join()

代碼執(zhí)行的效果如下：

python創(chuàng)建一個(gè)進(jìn)程https://www.zhihu.com/video/1060526231002390528

• 創(chuàng)建多個(gè)子進(jìn)程

multiprocessing.Pool類可以創(chuàng)建一個(gè)進(jìn)程池，進(jìn)程吃通過調(diào)用apply_async函數(shù)來創(chuàng)建一個(gè)新的進(jìn)程。

from multiprocessing import Pool
import os,timedef sub_process(n):time.sleep(1)print('Process (%s) is running!' % os.getpid())# 指定同時(shí)運(yùn)行的進(jìn)程數(shù)
p = Pool(4)
for i in range(5):p.apply_async(sub_process,args=(i+1,))
# 不能繼續(xù)添加進(jìn)程了
p.close()
p.join()

python進(jìn)程池https://www.zhihu.com/video/1060539118525841408

可以清晰的看見，我們指定了同時(shí)運(yùn)行的進(jìn)程數(shù)為4，因此最開始添加的4個(gè)進(jìn)程都停了1秒就有了輸出，而最后一個(gè)進(jìn)程在1秒以后才有輸出。

多線程：threading模塊

多線程相比于多進(jìn)程的好處是能更快一點(diǎn)，但是也沒快多少。python中常用threading模塊實(shí)現(xiàn)多線程。

import threading, timedef thread():print('%s is running' % threading.current_thread().name)print('%s is running' % threading.current_thread().name)
time.sleep(1)
t = threading.Thread(target=thread, name='Sub_Thread')
t.start()
t.join()

后記

當(dāng)然多進(jìn)程和多線程的內(nèi)容遠(yuǎn)不止這些，其他的還有進(jìn)程間通信、線程中的鎖、ThreadLocal等。由于立下了一天寫一篇文章的flag，如果一開始就把這件事搞的非常復(fù)雜就會(huì)損失做這個(gè)事的樂趣。所以我打算偷點(diǎn)懶，少點(diǎn)寫，以后再增加工作量～

Ref.

[1] 百度百科：進(jìn)程

[2] 廖雪峰python教程：進(jìn)程與線程

[3] 《鳥哥的Linux私房菜》

[4] 廖雪峰python教程：多進(jìn)程

總結(jié)

以上是生活随笔為你收集整理的python廖雪峰_【Python】python中实现多进程与多线程的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。