二十二、 深入Python的進程和線程(上篇)
@Author: Runsen

進程(Process)和線程(Thread)都是操作系統中的基本概念,它們之間有一些優劣和差異,那麼在Python中如何使用進程和線程?
@[TOC]
CPU
計算機的核心是CPU,它承擔了計算機的所有計算任務,CPU就像一個工廠,時刻在運行着,而操作系統管理着計算機,負責任務的調度、資源的分配和管理。
進程
進程是指在系統中能獨立運行並作為資源分配的基本單位,它是由一組機器指令、數據和堆棧等組成的,是一個能獨立運行的活動實體。
我們打開我們的計算機就會看到進程和線程,點擊我的電腦就可以看到CPU的運算。

從如圖中,CPU一共運行着190個進程,2620個線程。比如,當我們再次點擊QQ,登陸另一個賬號的時候又會開啟另一個QQ進程。
因此,如果想在電腦登入多個微信。只需要找到你的微信快捷方式,單擊右鍵查看屬性,在目標中複製鏈接;新建一個記事本,隨便取個名字,雙擊打開後,在其中輸入 start ""(注意引號為英文狀態,且前後有空格),將剛剛複製的鏈接(也就是微信安裝的路徑)粘貼進去;然後複製整行,想開幾個微信就粘貼幾行;保存文件,更改後綴名為 bat。雙擊運行即可。

線程
線程(Thread)也叫輕量級進程,是操作系統能夠進行運算調度的最小單位,它被包涵在進程之中,是進程中的實際運作單位。
記得阮一峰寫過的博客:假定工廠的電力有限,一次只能供給一個車間使用。也就是說,一個車間開工的時候,其他車間都必須停工。背後的含義就是,單個CPU一次只能運行一個任務。

進程就好比工廠的車間,它代表CPU所能處理的單個任務。任一時刻,CPU總是運行一個進程,其他進程處於非運行狀態。
線程就好比車間里的工人。一個進程可以包括多個線程,協同完成一個任務。
總結來說:程序可以包含多個進程,多個進程並發執行,相互獨立,因此,進程也是系統進行資源分配和調度基本單位。專業化來說:進程是指程序執行時的一個實例。線程是最小的執行單元,而進程由至少一個線程組成。如何調度進程和線程,完全由操作系統決定。
在Python中線程和進程的使用
現在講下在Python線程和進程的使用。
在Python中,通過兩個標準庫 thread和 Threading提供對線程的支持,threading對 thread進行了封裝。threading模塊中提供了 Thread,Lock, RLOCK, Condition等組件
Thread
在Python中線程和進程的使用就是通過Thread這個類。這個類在我們的_thread和threading模塊中。我們一般通過threading導入。
默認情況下,只要在解釋器中,如果沒有報錯,則說明線程可用。
>> from threading import Thread
下面是Thread類的常用參數說明和實例方法。


我們看一個官方文檔中標準的多線程的例子。
import threading
import time
# 定義線程要運行的函數
def func(name):
# 為了便於觀察,睡眠2秒
time.sleep(2)
print("My name is %s\t" % name)
# 創建第一個線程的實例,args參數是一個元組,後面必須加逗號分隔
t1 = threading.Thread(target=func, args=("Runsen",))
# 創建第二個線程的實例
t2 = threading.Thread(target=func, args=("Maoli",))
t1.start()
t2.start()
# 先打印線程名
print(t1.getName())
print(t2.getName())
由於兩個線程是同時運行的,所以print打印處理的結果並沒有換行。

下面我寫了下面的代碼,加深threading模塊的使用。
# -*- coding:utf-8 -*-
# time :2019/4/9 21:52
# author: Runsen
import threading
import time
def fun1():
print('hello')
time.sleep(2)
print('Bye')
def fun2():
print('hi')
time.sleep(2)
print('OUT')
t1 = threading.Thread(target=fun1)
t2 = threading.Thread(target=fun2)
t1.start()
t2.start()
# t1.join()
# t2.join()
print('主線程完畢')
下面是輸出結果。
hello
hi
主線程完畢
Bye
OUT
我們先不加join()來阻塞,t1和t2兩個線程同時執行,由於位置關係先打印hello,再打印hi,這個時候都sleep2秒鐘,但是它sleep2秒鐘,主程序還是在執行,所以下面打印print('主線程完畢'),最後才打印Bye和OUT。
線程間變量的共享
在多線程中,所有變量對於所有線程都是共享的,因此,線程之間共享數據的最大危險在於多個線程同時修改一個變量,那就亂套了,所以我們需要互斥鎖,來鎖住數據。

代碼如上圖所示,上面代碼中打印的a是1還是2?
答案是:2。因為出現了global關鍵字,線程間變量的共享,在func函數中的a是全局變量。因此在函數中a的值發生了變化。
下面,我們提高一點點難度,代碼如下圖所示,還是猜一猜a是啥東西。注意:這裡出現了join來阻塞,並且增加了加和減的操作。

相信很多人都認為是0,其實這個a的值是變化的,可能這次是0 ,下次是1,還有可能是1000000,比如,我可以
a就是在[-1000000,1000000]中的一個隨機數。
為什麼呢?這是因為雖然他們是同時運行的,但是同時在修改我們的a,那就亂了。a在for i in range(1000000),就是遍歷了1000000,incr和decr的方法都加上一起了,在這1000000次遍歷中,不知道有多少加,多少減,比如,我1000000都是加,沒有減,a就是1000000,但是這種情況的概率很低。
如果你就是想出現0,其實只需要加一個互斥鎖就可以了。這樣你加多少次,我就減多少次,加減的次數不會疊加。因此來了lock的用法,具體代碼如下圖所示。

這個a怎麼運行都是 0。因為我們把這個a鎖上了,這樣就加1000000次,減1000000次,怎麼出來都是我們的0。
今天也學到了很多東西呢,明天有什麼新知識呢?真期待鴨如果喜歡文章可以關注我哦
本文已收錄 GitHub,傳送門~ ,裏面更有大廠面試完整考點,歡迎 Star。

