[问题] 请问 Coroutine & 一般 callback 合作的问题

楼主: HuangJC (吹笛牧童)   2023-02-05 12:58:28
描述一下问题:
目前的工作我可以用 multi-thread 做到
https://paste.ee/p/0oAqf
执行结果:
03:16:44: do 1
notify
03:16:45: do 2
do 1 是 thread1 会动的证明,然后用 condition 塞住自己
notify 代表 thread2 利用 condition 通知 thread1
然后 do 2 代表 thread1 果然解锁了,继续执行
如果要改成用 Coroutine 做,我也做得到
https://paste.ee/p/BiPJp
结果是一模一样的(除了时间不一样)
注意到,和 multi-thread 的版本相比
condition 不能在全域的地方产生了
不然会有一个错误讯息,说是不能使用不同 loop 的东西
改用 Coroutine 写也一样,只是 condition 改用 asyncio 的版本
这还难不倒我,也算一想就通
因为它们不是真正的 thread
我知道 python 的 multi-thread 不算真正的 thread
但不影响我讨论,对吧!
附上两支程式,代表这程度我懂
接下来要谈我不懂的
如果我在 task1 里用 thead 版的 condition 把 task1 塞住
那 task2 也会一并塞住! 因为它们其实是同一个 thread
但我若用 asyncio 版本的 condition, 那所谓的塞住就只是交回控制权给 loop
而 loop 会再次分配给 task-2 以达到 Coroutine 的伪多工;完美~
https://paste.ee/p/U7nzP
这是用 thread 版本的 condition 把整个 Coroutine 塞住的例子
执行结果:
03:24:09: do 1
连 notify 都不会印出了,因为 task1 塞住,task2 根本就不会去执行
现在问题在,我的 task-2 若不是 async 宣告
这就是个问题,因为它本来是另一个 thread,打算改写过来但不顺利
这不是什么简单复杂化,而是我必需把专案的情境模拟成这样
因为有某些部份是引用别人写的 lib, 我不想去全面改写
https://paste.ee/p/kgAsv
执行结果:
03:26:44: do 1
notify
do 1 有印出,然后 task1 塞住
thread2 要求解锁其实也做到了
注意到我的 thread2 是呼叫 asnyc 版本的 release()
要求是有要求,但 task1 不照办,根本不会收到 notify!!!!
所以现在是 task-1 & thread-2 之间的 condition 控制问题了
难道我必需全面弃用 thread, 一定要把 thread-2 改写成 task-2?
问题就在 condition.notify_all() 不会有预期的效果
但如果用 multi-thread, 我是轻易能做好这些事的
像这样要怎么让 condition 正常的运作起来呢?
谢谢
作者: lycantrope (阿宽)   2023-02-05 14:34:00
看不太懂你想要问什么...
作者: surimodo (好吃棉花糖)   2023-02-05 15:36:00
你进公司前都没碰python吗公司也很敢给你什么不会的弄主架构
作者: s9041200 (小明阿)   2023-02-05 16:02:00
epoll?
作者: Faker0613 (月巴月巴)   2023-02-05 16:09:00
Python的thread也不是真的multi啊 会有coroutine 就是要改善cpu 使用效率问题Async create_tash勒 我实在不知道你要干嘛
作者: TakiDog (多奇狗)   2023-02-05 18:49:00
简单复杂化? 看不懂了 建议你重学os
作者: lycantrope (阿宽)   2023-02-06 11:04:00
用asyncio.to_thread?
作者: gomi (勾亿郎)   2023-03-18 23:02:00
你是不是想用 multi processing?
作者: firejox (Tangent)   2023-04-18 13:00:00
loop.call_soon_threadsafe

Links booklink

Contact Us: admin [ a t ] ucptt.com