python的多線程

来源:https://www.cnblogs.com/tuixiulaozhou/archive/2022/09/29/16737747.html
-Advertisement-
Play Games

一、線程的概念線程是CPU分配資源的基本單位。當一程式開始運行,這個程式就變成了一個進程,而一個進程相當於一個或者多個線程。當沒有多線程編程時,一個進程相當於一個主線程;當有多線程編程時,一個進程包含多個線程(含主線程)。使用線程可以實現程式大的開發。 多個線程可以在同一個程式中運行,並且每一個線程 ...


一、線程的概念
線程是CPU分配資源的基本單位。當一程式開始運行,這個程式就變成了一個進程,而一個進程相當於一個或者多個線程。當沒有多線程編程時,一個進程相當於一個主線程;當有多線程編程時,一個進程包含多個線程(含主線程)。使用線程可以實現程式大的開發。

多個線程可以在同一個程式中運行,並且每一個線程完成不同的任務。

多線程實現後臺服務程式可以同時處理多個任務,並不發生阻塞現象。

多線程的程式設計的特點就是能夠提高程式執行效率和處理速度。python程式可以同時並行運行多個相對獨立的線程。

二、創建多線程
python支持兩種創建多線程的方式:

~通過 threading.Thread () 創建。

~通過繼承 threading.Thread 類的繼承。

 

1.通過 threading.Thread () 創建


語法形式:

thread.Thread(group=Nore,targt=None,args=(),kwargs={},*,daemon=None)

參數解釋:

~group:必須為None,於ThreadGroup類相關,一般不使用。

~target:線程調用的對象,就是目標函數。

~name:為線程起這個名字。預設是Tread-x,x是序號,由1開始,第一個創建的線程名字就是Tread-1。

~args:為目標函數傳遞關鍵字參數,字典。

~daemon:用來設置線程是否隨主線程退出而退出。

示例:

import threading
def test (x,y):
 for i in range(x,y):
   print(i)
thread1 = threading.Thread(name='t1',target= test,args=(1,10))
thread2 = threading.Thread(name='t2',target= test,args=(11,20))
thread1.start()   #啟動線程1
thread2.start()   #啟動線程2
1
2
3
4
5
6
7
8
9
11
12
13
14
15
16
17
18
19

解釋:兩個程式會併發運行,所以結果不一定每次都是順序的1~10,這是根據CPU給兩個線程風馬分配的時間片段來決定。可以看到每次結果都不同。

 

2.通過繼承 threading.Thread 類的繼承

 

threading.Thread是一個類,可以繼承它。

 

示例:

import threading
class mythread(threading.Thread):
  def run(self):
    for i in range(1,10):
      print(i)
thread1 = mythread();
thread2 = mythread();
thread1.start()
thread2.start()

輸出:

1
2
3
4
5
6
7
8
9
1
2
3
4
5
6
7
8
9

解釋:自定義一個類繼承threading.Thread,然後重寫父類的run方法,線程啟動時(執行start())會自動執行該方法。

 

三、主線程

在python中,主線程是第一個啟動的線程。

~父線程:如果啟動線程A中啟動了一個線程B,A就是B的父線程。

~子線程:B就是A的子線程。

創建線程時有一個damon屬性,用它來判斷主線程。當daemon設置False時,線程不會隨主線程退出而退出,主線程會一直等著子線程執行完;。當daemon設置True時,線程會隨主線程退出而退出,主線程結束其他的子線程會強制退出。

使用daemon註意:

~daemon屬性必須在start( )之前設置,否則會引發RuntimeError異常

~每個線程都由daemon屬性,可以顯示設置也可以不設置,不設置則取預設值None

~如果子子線程不設置daemon屬性,就取當前線程的daemon來設置它。子子線程繼承子線程的daemon值,作用和設置None一樣。

~從主線程創建的所有線程不設置daemon屬性,則預設都是daemon=False。

示例:

import time
import threading
def test():
 time.sleep(10)
 for i in range(10):
  print(i)
thread1 = threading.Thread(target=test,daemon=False)
thread1.start()
print('主線程完成了')

輸出:

主線程完成了
0
1
2
3
4
5
6
7
8
9

解釋:當主線程運行完畢輸出完之後,等待一下後輸出0~9。如果將daemon=False該為daemon=True,則不會運行for i in range(10)語句。


四、阻塞線程

 

一個線程中調用另一個線程的join方法,調用者被阻塞,直到調用線程被終止。

語法形式:

join(timeout-=None)

timeout 參數指定調用者等待多久,沒有設置時,就一直等待被調用線程結束被調用線程結束。其中,一個線程可以被join多次調用。

 

示例:

import time
import threading
def test():
 time.sleep(5)
 for i in range(10):
  print(i)
thread1=threading.Thread(target=test)
thread1.start()
thread1.join()
print('主線程完成了')

 

輸出:

0
1
2
3
4
5
6
7
8
9
主線程完成了

解釋:在thread1.start()後加thread1.join()添加join方法,輸出時,主線程就會等待輸出完0~9後再執行自己的print輸出。

 

五、判斷線程是否活動的

 

~run():用以表示線程活動的方法

~start():啟動線程

~join():等待至線程終止

~isAlive():返回線程是否活動的

~getName():返回線程名稱

~setName() : 設置線程名稱

示例:

from threading import Thread, Event
import time
def countdown(n, started_evt):
    print('正在運行')
    started_evt.set()
    while n > 0:
        print('時間', n)
        n -= 1
        time.sleep(2)
started_evt = Event()
print('開始倒計時')
t = Thread(target=countdown, args=(10, started_evt))
t.start()
started_evt.wait()
print('倒計時運行')

輸出:

開始倒計時
正在運行
時間 10
倒計時運行
時間 9
時間 8
時間 7
時間 6
時間 5
時間 4
時間 3
時間 2
時間 1

Alive,顧名思義,它表示線程當前是否為可用狀態,如果線程已經啟動,並且當前沒有任何異常的話,則返回true,否則為false

Thread.isAlive() :顧名思義,是表示當前線程時候為可用狀態,即是否已經在啟動,並且在運行的狀態;

六、線程同步

1.同步概念

非同步模式的情況下,同時有一個線程在修改共用數據,另一個線程在讀取共用數據,當修改的共用數據的線程沒有處理完畢,讀取數據的線程肯定會得到錯誤的結果。如果採用多線程的同步控制機制,當處理共用數據的線程完成處理數據之後,讀取線程就讀取數據。

python的鎖就解決這一問題,鎖住線程,只允許一個線程操作,其他線程排隊等待,待當前線程操作完畢後,再按順序一個一個來運行。

2. python的鎖

 

python的threading模塊提供了RLock鎖解決方法。在某一時間只能讓一個線程操作的語句放到RLock的acquire方法和release方法之間,即acquire相當於給RLack上鎖,而release相當於解鎖。

示例:

import threading
class mythread(threading.Thread):
 def run(self):
  global x                   #聲明一個全局變數
  lock.acquire()             #上鎖
  x +=10
  print('%s:%d'%(self.name,x))
  lock.release()             #解鎖
x = 0                        #設置全局變數初始值
lock = threading.RLock()     #創建可重入鎖
list1 = []                   
for i in range(5):   
 list1.append(mythread())    #創建五個線程,放到同一列表中
for i in list1:
 i.start()                   #開啟列表線程

輸出:

Thread-1:10
Thread-2:20
Thread-3:30
Thread-4:40
Thread-5:50

解釋:

 

3. python中的條件鎖


條件鎖常用的方法:

~acquire([timeout]):調用關聯鎖的方法

~release():解鎖

~wait():使線程進入 Condition 的等待池等待通知並釋放解鎖。使用前線程必須已獲得鎖定,否則將拋出異常。

~notify():從等待池挑選一個線程並通知,收到通知的線程將自動調用 acquire() 嘗試獲得,其他線程仍然在等待池中等待通知,直到該線程收到通知 調用該方法,否則將會拋出異常。

~notify ALL():跟notify() 一樣,但這個方法對應的是所有的線程。

示例:

題目:有幾個生產車間生產,幾個消費者購買,當生產達到一定數量時,停止生產。

import threading
import time
condtion = threading.Condition()
sheep = ['1件產品','1件產品','1件產品','1件產品','1件產品']
class Producer(threading.Thread):
    def __init__(self, name):
        super().__init__(name=name)
        pass
    def run(self):
        global condtion, sheep
        while True:
            time.sleep(0.1)
            condtion.acquire()
            if len(sheep) < 10:
                print(self.name + "生產了1件產品")
                sheep.append('1件產品')
                condtion.notifyAll()
                pass
            else:
                print("倉庫滿了,停止生產!")
                condtion.wait()
                pass
            condtion.release()
        pass
    pass
class Customer(threading.Thread):
    def __init__(self, name):
        super().__init__(name=name)
        pass
    def run(self):
        global condtion, sheep
        while True:
            time.sleep(0.1)
            condtion.acquire()
            if len(sheep) > 0:
                meat = sheep.pop()
                print(self.name + "購買了" + meat + "還剩多少" + str(len(sheep)) + "")
                condtion.notifyAll()
                pass
            else:
                print("買光了,等待")
                condtion.wait()
                pass
            condtion.release()
        pass
    pass
if __name__ == "__main__":
    p1 = Producer("1號生產車間")
    p2 = Producer("2號生產車間")
    p3 = Producer("3號生產車間")
    p4 = Producer("4號生產車間")
    p5 = Producer("5號生產車間")
    p6 = Producer("6號生產車間")
    p1.start()
    p2.start()
    p4.start()
    p5.start()
    p6.start()
    c1 = Customer('小王')
    c2 = Customer('小李')
    c3 = Customer('小賈')
    c4 = Customer('小沈')
    c5 = Customer('小劉')
    c1.start()
    c2.start()
    c3.start()
    c4.start()
    c5.start()

 













您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 2022-09-29 shell操作: 我在使用中是pycharm與資料庫建立連接的一個工具。 使用的環境: 在此處是用在了虛擬環境中。 使用場景: 一般是在創建的表中插入數據後,進行查看,可以代替在“視圖”中——“創建一個函數用於請求指定表中的內容,在瀏覽器中返回”。 在插入表的過程中,有兩個新得 ...
  • 一、什麼是事務 事務就是一系列的業務邏輯的操作,必須要全部執行成功,否則每個操作所執行的內容都要撤銷。 二、事務的四大特性 1.原子性(atomicity):事務雖然有一系列的操作,但要把它看作一個整體(單一原子),要麼都成功,要麼都失敗; 2.一致性(consistency):事務必須是使資料庫從 ...
  • Nginx平滑升級版本 一,查看現目前版本,準備預升級版本的安裝包 #查看nginx版本 /usr/local/nginx/sbin/nginx -v #測試nginx訪問是否正常,此處開放的為19999埠 #新建下載目錄 mkdir -p /home/nginx #下載預升級版本的安裝包 wge ...
  • 在學習之前,我們先瞭解一個網站mybatis-spring,這是mybatis-spring整合的官方文檔,裡面有詳細的教程,網址如下: https://mybatis.org/spring/zh/index.html 一、什麼是mybatis-spring 以下是mybatis-spring官方給 ...
  • 2022-09-29 問題描述: 在“setting.py”的配置文件中修改資料庫引擎中,將系統預設的"sqlite3"尾碼改為了“sql”。出現問題。 原因分析: 問題查看: 修改後: 上述問題修改後,在“setting”中設置資料庫的其他內容(主機、埠、用戶、密碼、使用的指定數據名的資料庫), ...
  • 在Word中創建報告時,我們經常會遇到這樣的情況:我們需要將數據從Excel中複製和粘貼到Word中,這樣讀者就可以直接在Word中瀏覽數據,而不用打開Excel文檔 ...
  • 近期在處理一個將NVR錄像機上的錄像下載到伺服器並通過瀏覽器播放的需求。 梳理記錄下過程,做個備忘,同時遇到的一些細節問題解決,也供需要的同學參考。 需求比較簡單,就是把指定時間段的錄像上傳到伺服器保存,並且允許用戶通過web頁面web瀏覽器,進行播放, 並且可以拖動控制播放進度。效果如。 一、 視 ...
  • Python常用的英語單詞就那麼幾個,多打就熟悉了 說來好笑,我壓根就沒記英語單詞… 真的就是純靠多打多練, 畢竟打多了之後肌肉記憶就在那裡了 下麵就給大家帶來常用python清單彙總~ 一、互動式環境與print輸出(https://jq.qq.com/?_wv=1027&k=2Q3YTfym) ...
一周排行
    -Advertisement-
    Play Games
  • Timer是什麼 Timer 是一種用於創建定期粒度行為的機制。 與標準的 .NET System.Threading.Timer 類相似,Orleans 的 Timer 允許在一段時間後執行特定的操作,或者在特定的時間間隔內重覆執行操作。 它在分散式系統中具有重要作用,特別是在處理需要周期性執行的 ...
  • 前言 相信很多做WPF開發的小伙伴都遇到過表格類的需求,雖然現有的Grid控制項也能實現,但是使用起來的體驗感並不好,比如要實現一個Excel中的表格效果,估計你能想到的第一個方法就是套Border控制項,用這種方法你需要控制每個Border的邊框,並且在一堆Bordr中找到Grid.Row,Grid. ...
  • .NET C#程式啟動閃退,目錄導致的問題 這是第2次踩這個坑了,很小的編程細節,容易忽略,所以寫個博客,分享給大家。 1.第一次坑:是windows 系統把程式運行成服務,找不到配置文件,原因是以服務運行它的工作目錄是在C:\Windows\System32 2.本次坑:WPF桌面程式通過註冊表設 ...
  • 在分散式系統中,數據的持久化是至關重要的一環。 Orleans 7 引入了強大的持久化功能,使得在分散式環境下管理數據變得更加輕鬆和可靠。 本文將介紹什麼是 Orleans 7 的持久化,如何設置它以及相應的代碼示例。 什麼是 Orleans 7 的持久化? Orleans 7 的持久化是指將 Or ...
  • 前言 .NET Feature Management 是一個用於管理應用程式功能的庫,它可以幫助開發人員在應用程式中輕鬆地添加、移除和管理功能。使用 Feature Management,開發人員可以根據不同用戶、環境或其他條件來動態地控制應用程式中的功能。這使得開發人員可以更靈活地管理應用程式的功 ...
  • 在 WPF 應用程式中,拖放操作是實現用戶交互的重要組成部分。通過拖放操作,用戶可以輕鬆地將數據從一個位置移動到另一個位置,或者將控制項從一個容器移動到另一個容器。然而,WPF 中預設的拖放操作可能並不是那麼好用。為瞭解決這個問題,我們可以自定義一個 Panel 來實現更簡單的拖拽操作。 自定義 Pa ...
  • 在實際使用中,由於涉及到不同編程語言之間互相調用,導致C++ 中的OpenCV與C#中的OpenCvSharp 圖像數據在不同編程語言之間難以有效傳遞。在本文中我們將結合OpenCvSharp源碼實現原理,探究兩種數據之間的通信方式。 ...
  • 一、前言 這是一篇搭建許可權管理系統的系列文章。 隨著網路的發展,信息安全對應任何企業來說都越發的重要,而本系列文章將和大家一起一步一步搭建一個全新的許可權管理系統。 說明:由於搭建一個全新的項目過於繁瑣,所有作者將挑選核心代碼和核心思路進行分享。 二、技術選擇 三、開始設計 1、自主搭建vue前端和. ...
  • Csharper中的表達式樹 這節課來瞭解一下表示式樹是什麼? 在C#中,表達式樹是一種數據結構,它可以表示一些代碼塊,如Lambda表達式或查詢表達式。表達式樹使你能夠查看和操作數據,就像你可以查看和操作代碼一樣。它們通常用於創建動態查詢和解析表達式。 一、認識表達式樹 為什麼要這樣說?它和委托有 ...
  • 在使用Django等框架來操作MySQL時,實際上底層還是通過Python來操作的,首先需要安裝一個驅動程式,在Python3中,驅動程式有多種選擇,比如有pymysql以及mysqlclient等。使用pip命令安裝mysqlclient失敗應如何解決? 安裝的python版本說明 機器同時安裝了 ...