目標
用一個等待過程理解,能夠實現一致的方便,70行代碼
例子說明
某方需要2,執行req2需要執行這個時間,最終執行時間是3秒,大約1秒,同時執行;如果最終時間是秒,如果執行的話,具體請參看,友情提示是,yield from 方法后面如果是它的工具,可以進入____
import time
from collections import deque
_delay = deque()
class FutureX:
def __init__(self, coro=None, delay_second=None):
self.coro = coro
if delay_second:
self.start = delay_second + time.time()
def step(self):
coro = self.coro
try:
result = coro.send(None)
except StopIteration as e:
print(e.value)
pass
else:
if isinstance(result, FutureX):
_delay.append((self._wakeup, result))
else:
pass
def _wakeup(self):
self.step()
def __iter__(self):
yield self
return None
def coroutine(func):
co = func.__code__
func.__code__ = co.replace(co_flags=co.co_flags | 0x100)
return func
@coroutine
def sleep0(seconds):
future = FutureX(delay_second=seconds)
b = yield from future
return seconds
async def req1(delay_seconds):
resp_time = await sleep0(delay_seconds)
return resp_time
async def req2(delay_seconds):
resp_time = await sleep0(delay_seconds)
return resp_time
t1 = time.time()
f1, f2 = FutureX(req1(2)), FutureX(req2(1))
f1.step()
f2.step()
while _delay:
callback, args = _delay.popleft()
start = args.start
if not start:
continue
while True:
end = time.time()
if start <= end:
try:
callback()
except StopIteration as e:
pass
break
print(f'花費的時間:{round(time.time() - t1,1)}')
'''
結果:
2
1
花費的時間:2.0
'''
審核編輯:劉清
-
python
+關注
關注
56文章
4825瀏覽量
86226
發布評論請先 登錄
請問NICE協處理器與傳統ocb外設相比的優勢有什么?
FX2LP如何在不重新插入USB電纜的情況下在dfu過程之后重新啟動設備?
10分鐘上手寫代碼,LuatOS協程輕松掌握!

三協電機沖刺北交所上市
進程、線程、協程傻傻分不清?一文帶你徹底扒光它們的\"底褲\"!
創建了用于OpenVINO?推理的自定義C++和Python代碼,從C++代碼中獲得的結果與Python代碼不同是為什么?
使用Python實現xgboost教程
使用TMS320C6416協處理器:Turbo協處理器(TCP)

使用TMS320C6416協處理器:Viterbi協處理器(VCP)

如何幫助孩子高效學習Python:開源硬件實踐是最優選擇
使用Python進行Ping測試

評論