Python多線程編程之threading模塊詳解
更新時間：2021年04月25日 08:49:24 作者：汪醬努力提升打工ing
這篇文章主要介紹了Python多線程編程之threading模塊詳解,文中有非常詳細的代碼示例,對正在學習python的小伙伴們有非常好的幫助,需要的朋友可以參考下
一、介紹
線程是什么？線程有啥用？線程和進程的區(qū)別是什么？
線程是操作系統(tǒng)能夠進行運算調度的最小單位。被包含在進程中，是進程中的實際運作單位。一條線程指的是進程中一個單一順序的控制流，一個進程中可以并發(fā)多個線程，每條線程并行執(zhí)行不同的任務。
二、Python如何創(chuàng)建線程
2.1 方法一：
創(chuàng)建Thread對象
步驟：
1.目標函數(shù)
2.實例化Thread對象
3.調用start()方法
import threading
# 目標函數(shù)1
def fun1(num):
for i in range(num):
print('線程1: 第%d次循環(huán):' % i)
# 目標函數(shù)2
def fun2(lst):
for ele in lst:
print('線程2: lst列表中元素 %d' % ele)
def main():
num = 10
# 實例化Thread對象
# target參數(shù)一定為一個函數(shù)，且不帶括號
# args參數(shù)為元組類型，參數(shù)為一個時一定要加逗號
t1 = threading.Thread(target=fun1, args=(num,))
t2 = threading.Thread(target=fun2, args=([1, 2, 3, 4, 5],))
# 調用start方法
t1.start()
t2.start()
if __name__ == '__main__':
main()
2.2 方法二：
創(chuàng)建子類繼承threading.Thread類
import threading
import os
class Person(threading.Thread):
def run(self):
self.sing(5)
self.cook()
@staticmethod
def sing(num):
for i in range(num):
print('線程[%d]: The person sing %d song.' % (os.getpid(), i))
@staticmethod
def cook():
print('線程[%d]:The person has cooked breakfast.' % os.getpid())
def main():
p1 = Person()
p1.start()
p2 = Person()
p2.start()
if __name__ == '__main__':
main()
三、線程的用法
3.1 確定當前的線程
import threading
import time
import logging
def fun1():
print(threading.current_thread().getName(), 'starting')
time.sleep(0.2)
print(threading.current_thread().getName(), 'exiting')
def fun2():
# print(threading.current_thread().getName(), 'starting')
# time.sleep(0.3)
# print(threading.current_thread().getName(), 'exiting')
logging.debug('starting')
time.sleep(0.3)
logging.debug('exiting')
logging.basicConfig(
level=logging.DEBUG,
format='[%(levelname)s] (%(threadName)-10s) %(message)s'
)
def main():
t1 = threading.Thread(name='線程1', target=fun1)
t2 = threading.Thread(name='線程2', target=fun2)
t1.start()
t2.start()
if __name__ == '__main__':
main()
3.2 守護線程
區(qū)別
- 普通線程：主線程等待子線程關閉后關閉
- 守護線程：管你子線程關沒關，主線程到時間就關閉
守護線程如何搞
- 方法1：構造線程時傳入dameon=True
- 方法2：調用setDaemon()方法并提供參數(shù)True
import threading
import time
import logging
def daemon():
logging.debug('starting')
# 添加延時，此時主線程已經退出，exiting不會打印
time.sleep(0.2)
logging.debug('exiting')
def non_daemon():
logging.debug('starting')
logging.debug('exiting')
logging.basicConfig(
level=logging.DEBUG,
format='[%(levelname)s] (%(threadName)-10s) %(message)s'
)
def main():
# t1 = threading.Thread(name='線程1', target=daemon)
# t1.setDaemon(True)
t1 = threading.Thread(name='線程1', target=daemon, daemon=True)
t2 = threading.Thread(name='線程2', target=non_daemon)
t1.start()
t2.start()
# 等待守護線程完成工作需要調用join()方法，默認情況join會無限阻塞，可以傳入浮點值，表示超時時間
t1.join(0.2)
t2.join(0.1)
if __name__ == '__main__':
main()
3.3 控制資源訪問
目的：
Python線程中資源共享，如果不對資源加上互斥鎖，有可能導致數(shù)據不準確。
import threading
import time
g_num = 0
def fun1(num):
global g_num
for i in range(num):
g_num += 1
print('線程1 g_num = %d' % g_num)
def fun2(num):
global g_num
for i in range(num):
g_num += 1
print('線程2 g_num = %d' % g_num)
def main():
t1 = threading.Thread(target=fun1, args=(1000000,))
t2 = threading.Thread(target=fun1, args=(1000000,))
t1.start()
t2.start()
if __name__ == '__main__':
main()
time.sleep(1)
print('主線程 g_num = %d' % g_num)
互斥鎖
import threading
import time
g_num = 0
L = threading.Lock()
def fun1(num):
global g_num
L.acquire()
for i in range(num):
g_num += 1
L.release()
print('線程1 g_num = %d' % g_num)
def fun2(num):
global g_num
L.acquire()
for i in range(num):
g_num += 1
L.release()
print('線程2 g_num = %d' % g_num)
def main():
t1 = threading.Thread(target=fun1, args=(1000000,))
t2 = threading.Thread(target=fun1, args=(1000000,))
t1.start()
t2.start()
if __name__ == '__main__':
main()
time.sleep(1)
print('主線程 g_num = %d' % g_num)
互斥鎖引發(fā)的另一個問題：死鎖
死鎖產生的原理：
import threading
import time
g_num = 0
L1 = threading.Lock()
L2 = threading.Lock()
def fun1():
L1.acquire(timeout=5)
time.sleep(1)
L2.acquire()
print('產生死鎖，并不會打印信息')
L2.release()
L1.release()
def fun2():
L2.acquire(timeout=5)
time.sleep(1)
L1.acquire()
print('產生死鎖，并不會打印信息')
L1.release()
L2.release()
def main():
t1 = threading.Thread(target=fun1)
t2 = threading.Thread(target=fun2)
t1.start()
t2.start()
if __name__ == '__main__':
main()
time.sleep(1)
print('主線程 g_num = %d' % g_num)
如何避免產生死鎖：
鎖超時操作
import threading
import time
g_num = 0
L1 = threading.Lock()
L2 = threading.Lock()
def fun1():
L1.acquire()
time.sleep(1)
L2.acquire(timeout=5)
print('超時異常打印信息1')
L2.release()
L1.release()
def fun2():
L2.acquire()
time.sleep(1)
L1.acquire(timeout=5)
print('超時異常打印信息2')
L1.release()
L2.release()
def main():
t1 = threading.Thread(target=fun1)
t2 = threading.Thread(target=fun2)
t1.start()
t2.start()
if __name__ == '__main__':
main()
time.sleep(1)
print('主線程 g_num = %d' % g_num)
到此這篇關于Python多線程編程之threading模塊詳解的文章就介紹到這了,更多相關python threading模塊內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
Python3字符串的常用操作方法之修改方法與大小寫字母轉化
這篇文章主要介紹了Python3字符串的常用操作方法之修改方法與大小寫字母轉化，文章圍繞主題展開詳細的內容介紹，具有一定的參考價值，需要的小伙伴可以參考一下2022-09-09
本文主要介紹了Python隨機生成迷宮游戲的代碼示例，Python可以通過生成二維數(shù)組模擬迷宮的結構，使用深度優(yōu)先搜索和廣度優(yōu)先搜索等算法找到通路，文中通過示例代碼介紹的非常詳細，需要的朋友們下面隨著小編來一起學習學習吧2023-07-07
這篇文章主要介紹了Python對List中的元素排序 ,需要的朋友可以參考下2018-04-04
微信，一個日活10億的超級app，不僅在國內社交獨領風騷，在國外社交也同樣占有一席之地，今天我們要將便是如何用Python來生成一個微信機器人,感興趣的朋友跟隨小編一起看看吧2019-04-04
這篇文章主要介紹了python爬取音頻下載的示例代碼，幫助大家更好的理解和學習python爬蟲，感興趣的朋友可以了解下2020-10-10
這篇文章主要介紹了IT柏拉圖翻譯的python的lib目錄下this.py文件中的一首詩，蘊含了Python程序設計中很多哲理性的規(guī)律,需要的朋友可以參考下2014-06-06
文章介紹了Python中使用時間戳和時間模塊的操作,包括獲取當前時間、計算程序運行時間以及時間戳與時間字符串之間的轉換2025-02-02
到年底了，現(xiàn)在的時間適合寫點最近的小總結,所以下面這篇文章主要介紹了Python中遇到的一些小問題及解決方法,需要的朋友可以參考借鑒，下面來一起學習學習吧。2017-01-01
pytorch之inception_v3的實現(xiàn)案例
今天小編就為大家分享一篇pytorch之inception_v3的實現(xiàn)案例，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2020-01-01
通過shell+python實現(xiàn)企業(yè)微信預警
這篇文章主要介紹了通過shell+python實現(xiàn)企業(yè)微信預警，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2019-03-03