Python篇-多線程的使用

一 : 科普一分鐘

線程是操作系統(tǒng)能夠運(yùn)算調(diào)度的最小單位,它被包含在進(jìn)程中,是進(jìn)程中實(shí)際的運(yùn)作單位,一條線程指的是進(jìn)程中一個(gè)單一順序的控制流,一個(gè)進(jìn)程中可以并發(fā)多個(gè)線程,每條線程并行執(zhí)行不同的任務(wù).

  • 進(jìn)程 : 我們所用的應(yīng)該程序,在執(zhí)行時(shí)候可以簡(jiǎn)單理解為一個(gè)'進(jìn)程',也就是說,進(jìn)程就是一個(gè)暴露給操作系統(tǒng)管理,其包含對(duì)各種資源的調(diào)用.

  • 線程:是操作系統(tǒng)最小的調(diào)動(dòng)單位,是一串指令的集合

二 : 多線程創(chuàng)建和使用

  • 創(chuàng)建子線程
import  threading
import  time

# 子線程調(diào)用方法
def run:
    print("Run Start",n)
    time.sleep(1)
    print("Run done")

#創(chuàng)建子線程實(shí)例對(duì)象 
 t1 = threading.Thread(target=run, args=("TZ",))

#啟動(dòng)線程,執(zhí)行子線程任務(wù)
t1.start()
  • 守護(hù)線程
 #把當(dāng)前線程設(shè)置為守護(hù)線程 在start之前
    t1.setDaemon(True)
  • 用類實(shí)例化子線程
#創(chuàng)建自定義線程類
class MYThread(threading.Thread):
    def __init__(self,n):
        super(MYThread,self).__init__()
        self.n = n

    def run(self):
        print("runnint task : ",self.n)
        time.sleep(2)

#實(shí)例化類
t1 = MYThread("t1")
t2 = MYThread("t2")

#啟動(dòng)線程
t1.start()
t2.start()
  • join
    如果 我們?cè)趦蓚€(gè)字線程執(zhí)行時(shí)候 ,調(diào)用第一個(gè)線程的join方法 會(huì)有什么結(jié)果呢,相當(dāng)于兩個(gè)線程為串行線程,執(zhí)行完第一個(gè)再執(zhí)行第二個(gè)
t1.start()
t1.join() #等待t1結(jié)束 進(jìn)行t2  變成串行了
t2.start()
  • 信號(hào)量
    最大允許線程同時(shí)進(jìn)行的數(shù)量,當(dāng)一條線程結(jié)束,新的線程插入,保持子線程不超過規(guī)定的信號(hào)量.
import  threading,time

#執(zhí)行函數(shù)
def run(n):
    semaphore.acquire()
    time.sleep(1)
    print("run the thread : %s\n" %n)
    semaphore.release()

num = 0
#允許最多5個(gè)線程同時(shí)運(yùn)行
semaphore = threading.BoundedSemaphore(5)

#循環(huán)創(chuàng)建20條線程
for i in range(20):
    t = threading.Thread(target=run,args=(i,))
    t.start()

while threading.active_count() != 1:
        pass
else:
    print('------all threads done---')

三 : 線程鎖

意義: 在掛鎖時(shí)期,讓子線程串行執(zhí)行.
為什么要有線程鎖:當(dāng)多個(gè)線程執(zhí)行,并且訪問同一塊內(nèi)存num = 0,有兩個(gè)線程線程A,線程B執(zhí)行+1操作
變量時(shí)候,A線程讀取變量為0,并且放入緩存區(qū),當(dāng)A線程想執(zhí)行+1操作時(shí)候,線程B啟動(dòng),并且執(zhí)行完+1操作,num = 1回到線程A,此時(shí)讀取緩存區(qū)數(shù)據(jù) 0執(zhí)行+1操作,num = 1

所以便存在問題了,所以線程鎖的作用就是,讓鎖住部分串行執(zhí)行.

import  threading

#執(zhí)行函數(shù)
def run(n):

#獲取鎖
   lock.acquire()
   global num
   num += 1
#釋放鎖
   lock.release()

lock = threading.Lock()
num = 0

for i in range(50):
    t1 = threading.Thread(target=run, args=(i,))
    t1.start()
print("所有線程都執(zhí)行完了: ",num)

四 : 隊(duì)列

我們使用隊(duì)列來幫助我們自動(dòng)的處理任務(wù),只需要關(guān)注 取出放入即可,一定程度上解耦了冗余的操作流程

  • 基本操作
import queue


#存入
q = queue.Queue(maxsize=3)
q.put("d1")
q.put("d2")
q.put("d3")

#查看隊(duì)列成員大小
# q.qsize()

#取出
print(q.get())
print(q.get())
print(q.get())

結(jié)果 是 d1,d2,d3 先入先出

  • 后入先出
q1 = queue.LifoQueue()
q1.put(1)
q1.put(2)
q1.put(3)
print(q1.get())
print(q1.get())
print(q1.get())
  • 按照優(yōu)先級(jí)取出
q2 = queue.PriorityQueue()
q2.put(1,"tz")
q2.put(2,"雪芙")
q2.put(3,"百百")
print(q2.get())
print(q2.get())
print(q2.get())
  • 生產(chǎn)者消費(fèi)者模型

通過多線程和隊(duì)列創(chuàng)造 生產(chǎn)者,消費(fèi)者 模型
消費(fèi)者不必關(guān)系 生成者的變化和多少,只需要專注于自己的消費(fèi)行為,生產(chǎn)者也不必關(guān)注消費(fèi)者的變化,專注于自己的生產(chǎn)行為,是一種解耦合的模型

import  threading,time
import queue


q = queue.Queue(maxsize=10)

#生產(chǎn)者模型
def Producer(name):
    count = 1
    while True:
        q.put("饅頭%s" % count)
        print("生產(chǎn)了饅頭 :",count)
        count += 1
        time.sleep(0.5)

#消費(fèi)者模型
def Consumer(name):
    # while q.qsize() > 0:
    while True:
        print("%s 取到 %s 并且吃了它" %(name,q.get()))
        time.sleep(1)


p = threading.Thread(target=Producer,args=("TZ",))
C = threading.Thread(target=Consumer, args=("BAIBAI",))
C1 = threading.Thread(target=Consumer, args=("ZK",))

p.start()
C.start()
C1.start()

五 : 總結(jié)

python提供了兩個(gè)模塊來實(shí)現(xiàn)多線程threadthreadingthread 有些缺點(diǎn)缤骨,我們通常用 threading ,其實(shí)對(duì)于多線程,并行開發(fā) ,其實(shí)在python這只是一種假象,因?yàn)镃PU在快速的切換,似乎是并行的,即使是多核CPU在python中 在同一時(shí)間內(nèi)也只有一個(gè)線程在執(zhí)行,也許這是python 在初期設(shè)計(jì)開發(fā)上的缺陷.也有人嘗修改過,結(jié)果也差強(qiáng)人意,但是這比不妨礙這門優(yōu)秀的語言,被我們廣泛的使用.

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末山孔,一起剝皮案震驚了整個(gè)濱河市,隨后出現(xiàn)的幾起案子荷憋,更是在濱河造成了極大的恐慌台颠,老刑警劉巖,帶你破解...
    沈念sama閱讀 222,627評(píng)論 6 517
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件勒庄,死亡現(xiàn)場(chǎng)離奇詭異串前,居然都是意外死亡,警方通過查閱死者的電腦和手機(jī)实蔽,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,180評(píng)論 3 399
  • 文/潘曉璐 我一進(jìn)店門荡碾,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人局装,你說我怎么就攤上這事坛吁。” “怎么了铐尚?”我有些...
    開封第一講書人閱讀 169,346評(píng)論 0 362
  • 文/不壞的土叔 我叫張陵拨脉,是天一觀的道長。 經(jīng)常有香客問我宣增,道長玫膀,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 60,097評(píng)論 1 300
  • 正文 為了忘掉前任爹脾,我火速辦了婚禮帖旨,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘灵妨。我一直安慰自己解阅,他們只是感情好,可當(dāng)我...
    茶點(diǎn)故事閱讀 69,100評(píng)論 6 398
  • 文/花漫 我一把揭開白布泌霍。 她就那樣靜靜地躺著货抄,像睡著了一般。 火紅的嫁衣襯著肌膚如雪烹吵。 梳的紋絲不亂的頭發(fā)上碉熄,一...
    開封第一講書人閱讀 52,696評(píng)論 1 312
  • 那天,我揣著相機(jī)與錄音肋拔,去河邊找鬼锈津。 笑死,一個(gè)胖子當(dāng)著我的面吹牛凉蜂,可吹牛的內(nèi)容都是我干的琼梆。 我是一名探鬼主播性誉,決...
    沈念sama閱讀 41,165評(píng)論 3 422
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場(chǎng)噩夢(mèng)啊……” “哼茎杂!你這毒婦竟也來了错览?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 40,108評(píng)論 0 277
  • 序言:老撾萬榮一對(duì)情侶失蹤煌往,失蹤者是張志新(化名)和其女友劉穎倾哺,沒想到半個(gè)月后,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體刽脖,經(jīng)...
    沈念sama閱讀 46,646評(píng)論 1 319
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡羞海,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 38,709評(píng)論 3 342
  • 正文 我和宋清朗相戀三年,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了曲管。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片却邓。...
    茶點(diǎn)故事閱讀 40,861評(píng)論 1 353
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡,死狀恐怖院水,靈堂內(nèi)的尸體忽然破棺而出腊徙,到底是詐尸還是另有隱情,我是刑警寧澤檬某,帶...
    沈念sama閱讀 36,527評(píng)論 5 351
  • 正文 年R本政府宣布撬腾,位于F島的核電站,受9級(jí)特大地震影響橙喘,放射性物質(zhì)發(fā)生泄漏时鸵。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 42,196評(píng)論 3 336
  • 文/蒙蒙 一厅瞎、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧初坠,春花似錦和簸、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,698評(píng)論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至半沽,卻和暖如春爽柒,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背者填。 一陣腳步聲響...
    開封第一講書人閱讀 33,804評(píng)論 1 274
  • 我被黑心中介騙來泰國打工浩村, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人占哟。 一個(gè)月前我還...
    沈念sama閱讀 49,287評(píng)論 3 379
  • 正文 我出身青樓心墅,卻偏偏與公主長得像酿矢,于是被迫代替她去往敵國和親。 傳聞我的和親對(duì)象是個(gè)殘疾皇子怎燥,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,860評(píng)論 2 361

推薦閱讀更多精彩內(nèi)容

  • 線程的定義 線程是操作系統(tǒng)能夠進(jìn)行運(yùn)算調(diào)度的最小單位瘫筐。它被包含在進(jìn)程中。是進(jìn)程中的實(shí)際運(yùn)作單位铐姚。一條線程指的是進(jìn)程...
    So_ProbuING閱讀 339評(píng)論 0 0
  • 多線程 在iOS開發(fā)中為提高程序的運(yùn)行效率會(huì)將比較耗時(shí)的操作放在子線程中執(zhí)行策肝,iOS系統(tǒng)進(jìn)程默認(rèn)啟動(dòng)一個(gè)主線程,用...
    郭豪豪閱讀 2,602評(píng)論 0 4
  • 六月,一家歡喜一家憂的日子也已經(jīng)過去氢橙,有人實(shí)習(xí)酝枢,有人繼續(xù)學(xué)習(xí)。選擇去哪里也不過一個(gè)短暫的決定而已悍手,就像開學(xué)的九月帘睦,...
    失憶無效閱讀 388評(píng)論 2 3