這篇文章主要為大家詳細(xì)介紹了python線(xiàn)程中同步鎖的相關(guān)資料，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

在使用多線(xiàn)程的應(yīng)用下，如何保證線(xiàn)程安全，以及線(xiàn)程之間的同步，或者訪問(wèn)共享變量等問(wèn)題是十分棘手的問(wèn)題，也是使用多線(xiàn)程下面臨的問(wèn)題，如果處理不好，會(huì)帶來(lái)較嚴(yán)重的后果，使用python多線(xiàn)程中提供Lock Rlock Semaphore Event Condition 用來(lái)保證線(xiàn)程之間的同步，后者保證訪問(wèn)共享變量的互斥問(wèn)題

Lock & RLock:互斥鎖 用來(lái)保證多線(xiàn)程訪問(wèn)共享變量的問(wèn)題

Semaphore對(duì)象：Lock互斥鎖的加強(qiáng)版，可以被多個(gè)線(xiàn)程同時(shí)擁有，而Lock只能被某一個(gè)線(xiàn)程同時(shí)擁有。

Event對(duì)象: 它是線(xiàn)程間通信的方式，相當(dāng)于信號(hào)，一個(gè)線(xiàn)程可以給另外一個(gè)線(xiàn)程發(fā)送信號(hào)后讓其執(zhí)行操作。

Condition對(duì)象：其可以在某些事件觸發(fā)或者達(dá)到特定的條件后才處理數(shù)據(jù)

1、Lock(互斥鎖)

請(qǐng)求鎖定 — 進(jìn)入鎖定池等待 — 獲取鎖 — 已鎖定 — 釋放鎖

Lock(指令鎖)是可用的最低級(jí)的同步指令。Lock處于鎖定狀態(tài)時(shí)，不被特定的線(xiàn)程擁有。Lock包含兩種狀態(tài)——鎖定和非鎖定，以及兩個(gè)基本的方法。

可以認(rèn)為L(zhǎng)ock有一個(gè)鎖定池，當(dāng)線(xiàn)程請(qǐng)求鎖定時(shí)，將線(xiàn)程至于池中，直到獲得鎖定后出池。池中的線(xiàn)程處于狀態(tài)圖中的同步阻塞狀態(tài)。

構(gòu)造方法：

Lock()

實(shí)例方法：

acquire([timeout]): 使線(xiàn)程進(jìn)入同步阻塞狀態(tài)，嘗試獲得鎖定。

release(): 釋放鎖。使用前線(xiàn)程必須已獲得鎖定，否則將拋出異常。

if mutex.acquire():

counter += 1

print "I am %s, set counter:%s" % (self.name, counter)

mutex.release()

2、RLock(可重入鎖)

RLock(可重入鎖)是一個(gè)可以被同一個(gè)線(xiàn)程請(qǐng)求多次的同步指令。RLock使用了“擁有的線(xiàn)程”和“遞歸等級(jí)”的概念，處于鎖定狀態(tài)時(shí)，RLock被某個(gè)線(xiàn)程擁有。擁有RLock的線(xiàn)程可以再次調(diào)用acquire()，釋放鎖時(shí)需要調(diào)用release()相同次數(shù)。

可以認(rèn)為RLock包含一個(gè)鎖定池和一個(gè)初始值為0的計(jì)數(shù)器，每次成功調(diào)用 acquire()/release()，計(jì)數(shù)器將+1/-1，為0時(shí)鎖處于未鎖定狀態(tài)。

構(gòu)造方法：

RLock()

實(shí)例方法：

acquire([timeout])/release(): 跟Lock差不多。

3、Semaphore(共享對(duì)象訪問(wèn))

咱們?cè)倭牧腟emaphore ，說(shuō)實(shí)話(huà)Semaphore是我最晚使用的同步鎖，以前類(lèi)似的實(shí)現(xiàn)，是我用Rlock實(shí)現(xiàn)的，相對(duì)來(lái)說(shuō)有些繞，畢竟Rlock 是需要成對(duì)的鎖定和開(kāi)鎖的》。。。

Semaphore管理一個(gè)內(nèi)置的計(jì)數(shù)器，

每當(dāng)調(diào)用acquire()時(shí)內(nèi)置計(jì)數(shù)器-1；

調(diào)用release() 時(shí)內(nèi)置計(jì)數(shù)器+1；

計(jì)數(shù)器不能小于0；當(dāng)計(jì)數(shù)器為0時(shí)，acquire()將阻塞線(xiàn)程直到其他線(xiàn)程調(diào)用release()。

直接上代碼，我們把semaphore控制為3，也就是說(shuō)，同時(shí)有3個(gè)線(xiàn)程可以用這個(gè)鎖，剩下的線(xiàn)程也之只能是阻塞等待了…

#coding:utf-8

#blog xiaorui.cc

import time

import threading

semaphore = threading.Semaphore(3)

def func():

if semaphore.acquire():

for i in range(3):

time.sleep(1)

print (threading.currentThread().getName() + '獲取鎖')

semaphore.release()

print (threading.currentThread().getName() + ' 釋放鎖')

for i in range(5):

t1 = threading.Thread(target=func)

t1.start()

4、Event(線(xiàn)程間通信)

Event內(nèi)部包含了一個(gè)標(biāo)志位，初始的時(shí)候?yàn)閒alse。

可以使用使用set()來(lái)將其設(shè)置為true；

或者使用clear()將其從新設(shè)置為false；

可以使用is_set()來(lái)檢查標(biāo)志位的狀態(tài)；

另一個(gè)最重要的函數(shù)就是wait(timeout=None)，用來(lái)阻塞當(dāng)前線(xiàn)程，直到event的內(nèi)部標(biāo)志位被設(shè)置為true或者timeout超時(shí)。如果內(nèi)部標(biāo)志位為true則wait()函數(shù)理解返回。

import threading

import time

class MyThread(threading.Thread):

def __init__(self, signal):

threading.Thread.__init__(self)

self.singal = signal

def run(self):

print "I am %s,I will sleep ..."%self.name

self.singal.wait()

print "I am %s, I awake..." %self.name

if __name__ == "__main__":

singal = threading.Event()

for t in range(0, 3):

thread = MyThread(singal)

thread.start()

print "main thread sleep 3 seconds... "

time.sleep(3)

singal.set()

5、Condition(線(xiàn)程同步)

可以把Condition理解為一把高級(jí)的瑣，它提供了比Lock, RLock更高級(jí)的功能，允許我們能夠控制復(fù)雜的線(xiàn)程同步問(wèn)題。threadiong.Condition在內(nèi)部維護(hù)一個(gè)瑣對(duì)象(默認(rèn)是RLock)，可以在創(chuàng)建Condigtion對(duì)象的時(shí)候把瑣對(duì)象作為參數(shù)傳入。Condition也提供了acquire, release方法，其含義與瑣的acquire, release方法一致，其實(shí)它只是簡(jiǎn)單的調(diào)用內(nèi)部瑣對(duì)象的對(duì)應(yīng)的方法而已。Condition還提供了如下方法(特別要注意：這些方法只有在占用瑣(acquire)之后才能調(diào)用，否則將會(huì)報(bào)RuntimeError異常。)：

Condition.wait([timeout]):

wait方法釋放內(nèi)部所占用的瑣，同時(shí)線(xiàn)程被掛起，直至接收到通知被喚醒或超時(shí)(如果提供了timeout參數(shù)的話(huà))。當(dāng)線(xiàn)程被喚醒并重新占有瑣的時(shí)候，程序才會(huì)繼續(xù)執(zhí)行下去。

Condition.notify():

喚醒一個(gè)掛起的線(xiàn)程(如果存在掛起的線(xiàn)程)。注意：notify()方法不會(huì)釋放所占用的瑣。

Condition.notify_all()

Condition.notifyAll()

喚醒所有掛起的線(xiàn)程(如果存在掛起的線(xiàn)程)。注意：這些方法不會(huì)釋放所占用的瑣。

對(duì)于Condition有個(gè)例子，大家可以觀摩下。

from threading import Thread, Condition

import time

import random

queue = []

MAX_NUM = 10

condition = Condition()

class ProducerThread(Thread):

def run(self):

nums = range(5)

global queue

while True:

condition.acquire()

if len(queue) == MAX_NUM:

print "Queue full, producer is waiting"

condition.wait()

print "Space in queue, Consumer notified the producer"

num = random.choice(nums)

queue.append(num)

print "Produced", num

condition.notify()

condition.release()

time.sleep(random.random())

class ConsumerThread(Thread):

def run(self):

global queue

while True:

condition.acquire()

if not queue:

print "Nothing in queue, consumer is waiting"

condition.wait()

print "Producer added something to queue and notified the consumer"

num = queue.pop(0)

print "Consumed", num

condition.notify()

condition.release()

time.sleep(random.random())

ProducerThread().start()

ConsumerThread().start()

相關(guān)推薦：

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎(jiǎng)勵(lì)來(lái)咯，堅(jiān)持創(chuàng)作打卡瓜分現(xiàn)金大獎(jiǎng)

總結(jié)

以上是生活随笔為你收集整理的同步锁 php,python线程中同步锁详解的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

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