037多线程同步

##多线程资源共享使用问题

import threading
import time

def addNum():
    global num
    #num -= 1
    tmp = num
    time.sleep(0.00001)
    num = tmp-1

num = 100
thread_list = []
for i in range(100):
    t = threading.Thread(target=addNum)
    t.start()
    thread_list.append(t)

for t in thread_list:
    t.join()
print(num)

上面程序运行，num不会减到0。cpu执行了一个线程的tmp = num后，就切换到其他线程，有很多执行了tmp = num，所以所有线程的tmp大都是等于100的，执行num = tmp - 1的时候，num就可能等于99或者98之类的。

解决办法，加锁
步骤：1、新建锁
2、调用acquire()方法锁上，中间是执行代码
3、调用release()方法释放锁

import threading
import time

def addNum():
    global num
    # num -= 1
    r.acquire()          # 锁上
    tmp = num
    time.sleep(0.00001)
    num = tmp-1
    r.release()       # 释放锁

r = threading.Lock()         # 拿到锁对象
num = 100
thread_list = []
for i in range(100):
    t = threading.Thread(target=addNum)
    t.start()
    thread_list.append(t)

for t in thread_list:
    t.join()

print(num)

两个锁以上可能导致死锁，这里就不写例子了。
重用锁：threading.Rlock()，在对象里面的方法需要，比如下面这个取钱的例子

#01同步例子

import threading
import time
class Tickets:
    def __init__(self):
    self.ticket = 100

    def sell_ticket(self):
        while self.ticket > 0:
            loc.acquire()
            print('卖出',self.ticket,'票',threading.current_thread())
            self.ticket -= 1
            loc.release()
            time.sleep(0.0001)

if __name__ == '__main__':
    ticket = Tickets()
    t1 = threading.Thread(target=ticket.sell_ticket)
    t2 = threading.Thread(target=ticket.sell_ticket)
    t3 = threading.Thread(target=ticket.sell_ticket)
    loc = threading.Lock()
    t1.start()
    t2.start()
    t3.start()