在python里协程使用同步锁Lock的实例-6ren

在python里协程使用同步锁Lock的实例

转载作者：qq735679552 更新时间：2022-09-28 22:32:09

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章在python里协程使用同步锁Lock的实例由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

尽管asyncio库是使用单线程来实现协程的，但是它还是并发的，乱序执行的。可以说是单线程的调度系统，并且由于执行时有延时或者I/O中断等因素，每个协程如果同步时，还是得使用一些同步对象来实现.

比如asyncio就定义了一个锁对象Lock，它一次只允许一个协程来访问共享的资源，如果多协程想访问就会阻塞起来，也就是说如果一个协程没有释放这个锁，别的协程是没有办法访问共享的资源.

例子:

 
    ? 
   
         import 
         asyncio 
        
         import 
         functools 
        
         def 
         unlock(lock): 
        
         print 
         ( 
         'callback releasing lock' 
         ) 
        
         lock.release() 
        
         async  
         def 
         coro1(lock): 
        
         print 
         ( 
         'coro1 waiting for the lock' 
         ) 
        
         with await lock: 
        
         print 
         ( 
         'coro1 acquired lock' 
         ) 
        
         print 
         ( 
         'coro1 released lock' 
         ) 
        
         async  
         def 
         coro2(lock): 
        
         print 
         ( 
         'coro2 waiting for the lock' 
         ) 
        
         await lock 
        
         try 
         : 
        
         print 
         ( 
         'coro2 acquired lock' 
         ) 
        
         finally 
         : 
        
         print 
         ( 
         'coro2 released lock' 
         ) 
        
         lock.release() 
        
         async  
         def 
         main(loop): 
        
         # Create and acquire a shared lock. 
        
         lock  
         = 
         asyncio.Lock() 
        
         print 
         ( 
         'acquiring the lock before starting coroutines' 
         ) 
        
         await lock.acquire() 
        
         print 
         ( 
         'lock acquired: {}' 
         . 
         format 
         (lock.locked())) 
        
         # Schedule a callback to unlock the lock. 
        
         loop.call_later( 
         0.1 
         , functools.partial(unlock, lock)) 
        
         # Run the coroutines that want to use the lock. 
        
         print 
         ( 
         'waiting for coroutines' 
         ) 
        
         await asyncio.wait([coro1(lock), coro2(lock)]), 
        
         event_loop  
         = 
         asyncio.get_event_loop() 
        
         try 
         : 
        
         event_loop.run_until_complete(main(event_loop)) 
        
         finally 
         : 
        
         event_loop.close()

输出结果如下:

 
    ? 
   
         acquiring the lock before starting coroutines 
        
         lock acquired:  
         True 
        
         waiting  
         for 
         coroutines 
        
         coro1 waiting  
         for 
         the lock 
        
         coro2 waiting  
         for 
         the lock 
        
         callback releasing lock 
        
         coro1 acquired lock 
        
         coro1 released lock 
        
         coro2 acquired lock 
        
         coro2 released lock

以上这篇在python里协程使用同步锁Lock的实例就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持我.

原文链接：https://blog.csdn.net/caimouse/article/details/77912534 。

最后此篇关于在python里协程使用同步锁Lock的实例的文章就讲到这里了,如果你想了解更多关于在python里协程使用同步锁Lock的实例的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！。

文章推荐：写给运维的Nginx秘籍

文章推荐： Javascript 中的 CJS、AMD、UMD 和 ESM 是什么？

文章推荐：对python 通过ssh访问数据库的实例详解

文章推荐：在 Golang 中实现一个简单的Http中间件过程详解

Java Lock.lock() 和 Lock.lockInterruptibly()
我想知道锁是如何在 Java 中实现的。在一些教程中，我发现它们应该使用 wait() 和 notify()/notifyAll() 以及一些 boolean 标志来实现(它可能比那复杂得多，但基本上
android - RocksDB IO 错误 : lock db/LOCK: No locks available
我正在开发一个多线程服务器，用于存储和读取来自数据库的信息。数据库是用 RocksDB 实现的。我遇到的问题是，当我一次从多个线程访问数据库时，我得到了那个错误。通常是说db在usign后没有被删
c++ - 如何以编程方式打开/关闭 Caps Lock、Scroll Lock、Num Lock 键
例如，这里有一些 linux 中的代码: void set_leds(int val) { int fd = open ("/dev/console", O_WRONLY); // argumen
java - 如何以编程方式打开/关闭 Caps Lock、Scroll Lock 和 Num Lock
关闭。这个问题需要更多focused .它目前不接受答案。想改进这个问题吗？更新问题，使其只关注一个问题 editing this post . 关闭 9 年前。 Improve this qu
java - 我们如何将 try finally 用于 Lock.lock 和 Lock.unlock
考虑以下代码。为了防止IndexOutOfBoundsException打电话时 listIterator ，我们使用读取器锁来检索基于索引的 iteartor，并在对 stockCodes 进行写操
java - lock.lock() 尝试前
这个问题在这里已经有了答案: Java locking structure best pattern (2 个答案) 关闭 6 年前。有什么区别: private Lock lock = new
javascript - 在页面加载时检查 JavaScript 中的 Scroll Lock、Num Lock 和 Caps Lock
是否可以在网页加载时检查 Scroll Lock、Num Lock 和 Caps Lock 的状态？我找到了使用 JavaScript 在按键后进行检查的方法，但这不是我要问的。最佳答案 2019
javascript - 在页面加载时检查 JavaScript 中的 Scroll Lock、Num Lock 和 Caps Lock
是否可以在网页加载时检查 Scroll Lock、Num Lock 和 Caps Lock 的状态？我找到了使用 JavaScript 在按键后进行检查的方法，但这不是我要问的。最佳答案 2019
linux - 在Ubuntu中安装应用程序时出现错误 "Waiting for cache lock: Could not get lock/var/lib/dpkg/lock-frontend"
在Ubuntu中安装某些东西时出现错误。我尝试了一些命令来杀死正在运行的进程，但仍然遇到相同的错误。最佳答案根据文章How to Fix “Waiting for cache lock: Coul
gradle - 如何使用Gradle 5和GradleBuild任务修复错误 'Cannot lock buildSrc build lock as it has already been locked by this process.'
我们有一个gradle构建，它可以动态创建GradleBuild类型的多个任务，以与不同的客户端库版本一起运行以测试其兼容性。在Gradle4上可以正常工作，但是在移至Gradle5后，执行第一项任务
database - Vertica DB 抛出不可用 : initiator locks for query - Locking failure: Timed out X locking
我在尝试运行在 vertica 数据库表上运行查询的客户端应用程序时反复遇到此错误。有人可以帮助解决这个问题吗？最佳答案我想知道您的客户端应用程序向 Vertica 发送了哪种“查询”(以 RE
java - 我可以将 java.util.concurrent.locks.Lock 更改为 java.util.concurrent.locks.ReentrantReadWriteLock;
我有一个创建锁的方法。 ReadWriteLock lock = new ReentrantReadWriteLock(); 然后我使用 Lock Interface 将该对象传递到一个方法中。 m
Python 3.x - 在 Windows 上获取 caps-lock/num-lock/scroll-lock 的状态
正如问题所问，我知道这是可能的on Linux ，但我找不到任何适用于 Windows 的最新信息。有可能吗？最佳答案您可以使用 ctypes 加载 user32.dll 然后调用 GetKeyS
python - 在 Python 中，有没有办法以编程方式更改 hidraw 设备上的 CAPS LOCK/NUM LOCK/SCROLL LOCK 状态
这是同一个问题 Change keyboard locks in Python或者 How to change caps lock status without key press . 但还是有区别的
locking - 为什么 Java 8 没有在 `withLock` 接口(interface)中添加 `java.util.concurrent.locks.Lock` 默认方法？
与 this question 相同，不知道为什么Java团队没有在Lock中添加一些默认方法界面，类似这样: public default void withLock(Runnable r) {
npm - 如何将package-lock.json转换为yarn.lock？
我有一个带有package-lock.json文件的项目。现在，我想基于yarn.lock文件或项目的现有package-lock.json生成node_modules文件。我怎样才能做到这一点？
locking - pthread_mutex_t 结构 : What does lock stand for?
我正在查看 pthreadtypes.h 文件中的 pthread_mutex_t 结构。 “__lock”代表什么？它就像分配给互斥锁的锁号吗？ typedef union { struct _
java - 使用 java.util.concurrent.locks.Lock 而不是同步的 : can my code avoid dead-lock in a bank transfer scenario?
我正在研究避免死锁的措施，其中一种可能的方法是通过强制线程放弃它在访问另一个锁但无法访问该锁时已经持有的锁来打破循环等待。以最简单的银行账户转账为例: class Account { priva
c++ - CMutex::Lock 与 CSingleLock::Lock
我被要求支持一些遗留代码，我看到了一些让我摸不着头脑的事情。在某些代码段中，我看到类实例使用 CMutex 实例来同步方法执行。例如 class CClassA : public CObject {
java - synchronized 是否像 Lock.lock() 那样停放并发线程？
当我们调用 lock.lock() 或尝试进入一个 synchronized block 时，如果其他线程已经获取了该锁，我们的线程就会阻塞。现在我的问题是，当我们查看 lock.lock() 的实现

qq735679552

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

在python里协程使用同步锁Lock的实例