[問題] 請問 Coroutine 怎麼解這個問題

看板Python作者HuangJC (吹笛牧童)時間1年前 (2023/02/05 12:58)推噓2(2推 0噓 7→)

留言9則, 5人參與討論串1/1

描述一下問題：目前的工作我可以用 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 正常的運作起來呢？謝謝 -- ※ 發信站: 批踢踢實業坊(ptt.cc), 來自: 123.204.157.162 (臺灣) ※ 文章網址: https://www.ptt.cc/bbs/Python/M.1675573110.A.ED1.html 看到 queue 好像想到解法了先在 task-2 裡建一個 asyncio 版本的 queue 然後 main-thread 可以把想做的事推進去 task-2 自己取出來就可以做了來試試.. 失敗，因為這樣 main-thread 也必需改寫成 asyncio 版本目前還是無解！！需要附上程式嗎？ ※ 編輯: HuangJC (123.204.157.162 臺灣), 02/05/2023 13:49:11

→

lycantrope

02/05 14:34, 1年前 , 1^F

02/05 14:34, 1^F

程式附上了，這個貼程式碼的空間真棒，免註冊但好像放久一點就會消失了 XD 我已經找到'堪用'的解法了就是在 task 中，多加一個 moniter task, 監視用一秒一次監視狀況如果狀況發生，就由 moniter task 代為發送我想要執行的指令 moniter task 是很浪費 cpu 效能的，但我也只寫得出這種東西了 https://paste.ee/p/mxM0q 本例中，task2 就是我所謂的 moniter task task 一定要位在同一個 loop，由根部往上長（至少目前我只寫得出這種）所以我只好先把 task2 寫出來而我所謂的，non asnyc 與 asnyc 之間的介面就是由 tellTask2 這個介面擔任 tellTask2 將被別人寫的模組用 call back 改變而 task2 是 asnyc 版本的，它只好用 polling 的方式去檢查不會即時，而且無法一次對一次為了避免 polling 太過頻繁，我只好加入 sleep 一秒爛架構，但有解決問題。

→

surimodo

02/05 15:36, 1年前 , 2^F

02/05 15:36, 2^F

→

surimodo

02/05 15:36, 1年前 , 3^F

02/05 15:36, 3^F

謙虛的說，我 python 才學兩年但 C 語言我有十年以上的底子有新東西就學一下看能不能用這時膨風更慘，會被人說都這麼資深了連這都不會 XD

→

s9041200

02/05 16:02, 1年前 , 4^F