python笔记10-多线程之线程同步（锁lock）
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了python笔记10-多线程之线程同步（锁lock），小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2633字，纯文字阅读大概需要4分钟。
内容图文
前言
关于吃火锅的场景，小伙伴并不陌生，吃火锅的时候a同学往锅里下鱼丸，b同学同时去吃掉鱼丸，有可能会导致吃到生的鱼丸。
为了避免这种情况，在下鱼丸的过程中，先锁定操作，让吃火锅的小伙伴停一会，等鱼丸熟了再开吃，那么python如何模拟这种场景呢？
未锁定
1.如果多个线程同时操作某个数据，会出现不可预料的结果。比如以下场景：当小伙伴a在往火锅里面添加鱼丸的时候，小伙伴b在同时吃掉鱼丸，这很有可能导致刚下锅的鱼丸被夹出来了（没有熟），或者还没下锅，就去夹鱼丸（夹不到）。
#
coding=utf-8
import
threading
import
time
def
chiHuoGuo(people, do):
print("%s 吃火锅的小伙伴：%s" % (time.ctime(),people))
time.sleep(1)
for i in range(3):
time.sleep(1)
print("%s %s正在 %s 鱼丸"% (time.ctime(), people, do))
print("%s 吃火锅的小伙伴：%s" % (time.ctime(),people))
class myThread (threading.Thread): # 继承父类threading.Threaddef__init__(self, people, name, do):
‘‘‘重写threading.Thread初始化内容‘‘‘
threading.Thread.__init__(self)
self.threadName = name
self.people = people
self.do = do
def run(self): # 把要执行的代码写到run函数里面 线程在创建后会直接运行run函数‘‘‘重写run方法‘‘‘print("开始线程: " + self.threadName)
chiHuoGuo(self.people, self.do) # 执行任务print("qq交流群：226296743")
print("结束线程: " + self.name)
print("yoyo请小伙伴开始吃火锅：！！！")
# 设置线程组
threads = []
# 创建新线程
thread1 = myThread("xiaoming", "Thread-1", "添加")
thread2 = myThread("xiaowang", "Thread-2", "吃掉")
# 添加到线程组threads.append(thread1)
threads.append(thread2)
# 开启线程for thread in threads:
thread.start()
# 阻塞主线程，等子线程结束for thread in threads:
thread.join()
time.sleep(0.1)
print("退出主线程：吃火锅结束，结账走人")
运行结果：
线程同步（锁lock)
1.为了避免以上这种情况发生，就引入锁的概念，锁有两种状态：锁定和未锁定
2.每当一个线程a要访问共享数据时，必须先获得锁定；如果已经有别的线程b获得锁定了，那么就让线程a暂停，也就是同步阻塞；等到线程b访问完毕，释放锁以后，再让线程a继续。
3.用threading.Lock()这个类里面的两个方法
- acquire() 锁住
- release() 释放锁
#
coding=utf-8
import
threading
import
time
def
chiHuoGuo(people, do):
print("%s 吃火锅的小伙伴：%s" % (time.ctime(),people))
time.sleep(1)
for i in range(3):
time.sleep(1)
print("%s %s正在 %s 鱼丸"% (time.ctime(), people, do))
print("%s 吃火锅的小伙伴：%s" % (time.ctime(),people))
class myThread (threading.Thread): # 继承父类threading.Thread
lock = threading.Lock() # 线程锁def__init__(self, people, name, do):
‘‘‘重写threading.Thread初始化内容‘‘‘
threading.Thread.__init__(self)
self.threadName = name
self.people = people
self.do = do
def run(self): # 把要执行的代码写到run函数里面 线程在创建后会直接运行run函数‘‘‘重写run方法‘‘‘print("开始线程: " + self.threadName)
# 执行任务之前锁定线程 self.lock.acquire()
chiHuoGuo(self.people, self.do) # 执行任务# 执行完之后，释放锁 self.lock.release()
print("qq交流群：226296743")
print("结束线程: " + self.name)
print("yoyo请小伙伴开始吃火锅：！！！")
# 设置线程组
threads = []
# 创建新线程
thread1 = myThread("xiaoming", "Thread-1", "添加")
thread2 = myThread("xiaowang", "Thread-2", "吃掉")
# 添加到线程组threads.append(thread1)
threads.append(thread2)
# 开启线程for thread in threads:
thread.start()
# 阻塞主线程，等子线程结束for thread in threads:
thread.join()
time.sleep(0.1)
print("退出主线程：吃火锅结束，结账走人")
运行结果：
原文：https://www.cnblogs.com/jason89/p/8998314.html
内容总结
以上是互联网集市为您收集整理的python笔记10-多线程之线程同步（锁lock）全部内容，希望文章能够帮你解决python笔记10-多线程之线程同步（锁lock）所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。