因为python的GIL锁,queue这种结构体是线程安全的,因为它执行的是原子性操作
import threading
n = [0]
def foo():
n[0] = n[0] + 1
n[0] = n[0] + 1
threads = []
for i in range(5000):
t = threading.Thread(target=foo)
threads.append(t)
for t in threads:
t.start()
print(n)
大部分结果:[10000]。但其中出现了[9998]结果
这段代码并不是线程安全的,有些线程加1还没保存时候,它的这个结果被其他线程给覆盖了。
原子性操作线程安全,非原子性操作线程安全。
import dis
def update_list(L):
L[0] = 1 # 原子操作!不用担心线程安全问题
dis.dis(update_list)
# STORE_SUBSCR 赋值为1操作只有一次字节码操作,单字节码操作
“””
4 0 LOAD_CONST 1 (1)
2 LOAD_FAST 0 (L)
4 LOAD_CONST 2 (0)
6 STORE_SUBSCR # 单字节码操作,线程安全
8 LOAD_CONST 0 (None)
10 RETURN_VALUE
“””
import dis
def incr_list(L1):
L1[0] += 1 # 危险!!!不是原操作
dis.dis(incr_list)
# 需要多个字节码操作如BINARY_SUBSCR、INPLACE_ADD,
# 有可能在线程执行过程中切到其它线程
”’
19 0 LOAD_FAST 0 (L1)
2 LOAD_CONST 1 (0)
4 DUP_TOP_TWO
6 BINARY_SUBSCR
8 LOAD_CONST 2 (1)
10 INPLACE_ADD
12 ROT_THREE
14 STORE_SUBSCR
16 LOAD_CONST 0 (None)
18 RETURN_VALUE
”’