需求：做一個(gè)程序等待用戶輸入，3秒內(nèi)輸入則會(huì) echo 這個(gè)輸入并立即退出。3秒內(nèi)沒(méi)輸入則自動(dòng)退出。

實(shí)現(xiàn)方法：

1. 線程（錯(cuò)誤示范）

import

首先啟動(dòng)兩個(gè)線程，并把等待輸入的 get_input 設(shè)置成 daemon。于是 3 秒后，整個(gè)程序退出，3 秒內(nèi)可以獲得輸入。
這個(gè)程序最大的問(wèn)題在于，獲得輸入后并不會(huì)立即退出，而是無(wú)論如何都要等 3 秒。

2. 線程 + 隊(duì)列

import

這個(gè)程序完全實(shí)現(xiàn)了需求。原理在于給 q 設(shè)置超時(shí)退出。想要讓 wait 提前退出，則往隊(duì)列放東西。

3. 線程 + 事件

import

這個(gè)版本基本我能想到的線程版本的最優(yōu)版本了。代碼簡(jiǎn)潔且只需要一個(gè)庫(kù)。
Event() 對(duì)象可以用 wait 方法來(lái)阻塞。e.set() 的作用是解除阻塞。

4. 協(xié)程

import

ensure_future 表示把協(xié)程注冊(cè)到 event loop 里。
add_reader 表示把 sys.stdin 這個(gè)文件的輸入事件和函數(shù) echo 綁定，由于 echo 需要傳參，因此用到了 functools.partial。
loop.run_forever 不需要參數(shù)，因?yàn)榍懊鎯尚幸呀?jīng)注冊(cè)事件到 loop 了，就不用傳參了。
一旦兩個(gè)事件中任意一個(gè)完成，loop.close() 就觸發(fā)。

延伸（錯(cuò)誤示范）

import

這里，run_until_complete 必須傳入一個(gè) Future 對(duì)象作為參數(shù)。于是我把 timeout 傳入。
然而，這個(gè)程序有個(gè)問(wèn)題：
在 echo 中觸發(fā) loop.stop 會(huì)報(bào)錯(cuò)，說(shuō) Future 沒(méi)有完成就停止 loop 了。除非寫(xiě)成：

try

但是這樣不夠優(yōu)雅，建議用 run_forever。

總結(jié)

以上是生活随笔為你收集整理的input 输入事件_输入超时为例学习 Python 的线程和协程的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。