pythonマルチスレッドのロック()とRLock()ロック
4616 ワード
リソースは常に限られており、プログラムの実行によって同じオブジェクトが操作されると、リソースの競合が発生し、デッドロックが発生したり、読み書きが混乱したりする可能性があります.
ロックは以下の方法を提供する:1.Lock.acquire([blocking]) 2.Lock.release() 3.threading.ロック()スレッドをロードするロックオブジェクトは、基本的なロックオブジェクトであり、一度に1つのロックしかできません.残りのロック要求は、ロックの解放を待つ必要があります.
4.threading.RLock()マルチロックは、同じスレッドで複数回acquireされることができる.RLockを使用する場合、acquireとreleaseがペアで表示され、n回のacquireロック要求が呼び出される必要があります.スレッド内でロックオブジェクトを解放するには、n回のreleaseを呼び出す必要があります.
例:ロックなし:
出力:
結果は混乱を示した
導入ロック:
結果:
そのうち:lock=threading.ロック()のロードロックの方法をlock=threadingに変更することもできる.RLock()
上のsum_をnumは次のように変更されました.
では、lock=threading.ロック()がロードするロックは、常に待機中であり、ロックは待機し、lock=threadingとなる.RLock()は正常に動作
ロックは以下の方法を提供する:1.Lock.acquire([blocking]) 2.Lock.release() 3.threading.ロック()スレッドをロードするロックオブジェクトは、基本的なロックオブジェクトであり、一度に1つのロックしかできません.残りのロック要求は、ロックの解放を待つ必要があります.
4.threading.RLock()マルチロックは、同じスレッドで複数回acquireされることができる.RLockを使用する場合、acquireとreleaseがペアで表示され、n回のacquireロック要求が呼び出される必要があります.スレッド内でロックオブジェクトを解放するには、n回のreleaseを呼び出す必要があります.
例:ロックなし:
#coding=utf8
import threading
import time
num = 0
def sum_num(i):
global num
time.sleep(1)
num +=i
print num
print '%s thread start!'%(time.ctime())
try:
for i in range(6):
t =threading.Thread(target=sum_num,args=(i,))
t.start()
except KeyboardInterrupt,e:
print "you stop the threading"
print '%s thread end!'%(time.ctime())
出力:
Sun May 28 20:54:59 2017 thread start!
Sun May 28 20:54:59 2017 thread end!
01
3
710
15
結果は混乱を示した
導入ロック:
#coding=utf8
import threading
import time
num = 0
def sum_num(i):
lock.acquire()
global num
time.sleep(1)
num +=i
print num
lock.release()
print '%s thread start!'%(time.ctime())
try:
lock=threading.Lock()
list = []
for i in range(6):
t =threading.Thread(target=sum_num,args=(i,))
list.append(t)
t.start()
for threadinglist in list:
threadinglist.join()
except KeyboardInterrupt,e:
print "you stop the threading"
print '%s thread end!'%(time.ctime())
結果:
Sun May 28 21:15:37 2017 thread start!
0
1
3
6
10
15
Sun May 28 21:15:43 2017 thread end!
そのうち:lock=threading.ロック()のロードロックの方法をlock=threadingに変更することもできる.RLock()
上のsum_をnumは次のように変更されました.
lock.acquire()
global num
lock.acquire()
time.sleep(1)
num +=i
lock.release()
print num
lock.release()
では、lock=threading.ロック()がロードするロックは、常に待機中であり、ロックは待機し、lock=threadingとなる.RLock()は正常に動作