一、示例代码:
from threading import Thread
from threading import Lock
import timen = 100 # 共100张票def task():global nmutex.acquire() # 上锁temp = ntime.sleep(0.1)n = temp - 1print('购票成功,剩余%d张余票!' % n)mutex.release() # 释放锁if __name__ == '__main__':mutex = Lock() # 实例化Lock类thread_list = [] # 初始化列表for i in range(100):t = Thread(target=task) # 实例化线程类thread_list.append(t) # 线程实例加入列表t.start() # 创建线程for t in thread_list:t.join() # 等待子线程结束
二、方法注释:
threading模块中使用Lock类方便的处理锁定。Lock类的两个方法:acquire()上锁与release()释放锁。
三、代码说明:
创建100个线程,全部执行task函数,为解决资源竞争问题,使用mutex.acquire()方法实现资源的锁定,第一个获取资源的线程锁定后,其他线程等待mutex.release()解锁释放资源。所以每次只有一个线程执行task()函数。
四、运行结果: