1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
#coding:utf-8
'''线程锁'''
import  threading
import  time
 
num  =  0  #全局变量
 
num2  =  0
 
def  runs():
     time.sleep( 1 )
     global  num  #在函数内部要对全局变量进行更改，需要进行声明
     global  num2
     lock.acquire()  #在操作时锁住，防止其他线程在同一时间对num变量进行加1，从而确保数据在同一时间确保只有一个线程对它进行更改，不然造成数据不正确
     num  + =  1
     lock.acquire()  #再获得一把锁
     num2  + =  2
 
     #在这里一个线程获得了2把锁，所以需要释放2次
     lock.release()   # 释放第1把锁，加1完之后释放锁，只有释放之后下一个线程才会开始对num进程操作，不释放的话否则会被该线程一直占用，导致程序不能继续执行下去，一直处于阻塞状态
     time.sleep( 0.01 )
     lock.release()  # 释放第2把锁，加完2后释放锁
     time.sleep( 0.01 )
     print ( "%s"  %  num)
 
 
 
lock  =  threading.RLock()  #RLock是允许同时获得好几把锁增加一把锁，如果只需一把锁，那么用threading.Lock()就可以
 
#启动一百个线程，也就是说这100个线程同时运行rusn函数
for  i  in  range ( 500 ):
     t  =  threading.Thread(target = runs,)
     t.start()