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