小编给大家分享一下python中怎么实现threading线程同步,希望大家阅读完这篇文章之后都有所收获,下面让我们一起去探讨吧!
说明
1、threading模块具有实现锁定的内置功能,允许同步线程。为了防止数据损坏或丢失,需要锁定来控制共享资源的访问。
2、可以调用Lock()方法来应用锁,它新的锁对象。然后,可以调用锁对象的获取(阻塞)方法来强制线程同步运行。
实例
#Python 多线程示例来演示锁定。 #1. 使用 threading.Thread 类定义子类。 #2. 实例化子类并触发线程。 #3. 在线程的 run 方法中实现锁。 import threading import datetime exitFlag = 0 class myThread (threading.Thread): def __init__(self, name, counter): threading.Thread.__init__(self) self.threadID = counter self.name = name self.counter = counter def run(self): print("\nStarting " + self.name) # 获取锁同步线程 threadLock.acquire() print_date(self.name, self.counter) # 为下一个线程释放锁 threadLock.release() print("Exiting " + self.name) def print_date(threadName, counter): datefields = [] today = datetime.date.today() datefields.append(today) print("{}[{}]: {}".format( threadName, counter, datefields[0] )) threadLock = threading.Lock() threads = [] # 创建新线程 thread1 = myThread("Thread", 1) thread2 = myThread("Thread", 2) # 启动新线程 thread1.start() thread2.start() # 添加线程到线程列表 threads.append(thread1) threads.append(thread2) # 等待所有线程完成 for thread in threads: thread.join() print("\nExiting the Program!!!")
看完了这篇文章,相信你对“python中怎么实现threading线程同步”有了一定的了解,如果想了解更多相关知识,欢迎关注亿速云行业资讯频道,感谢各位的阅读!
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。