有一個(gè)任務(wù)，多次執(zhí)行一個(gè)函數(shù)，這個(gè)函數(shù)是阻塞的，阻塞原因是比如獲取網(wǎng)絡(luò)資源，這個(gè)時(shí)候該怎么辦，一般來講多線程是個(gè)不錯(cuò)的選擇，python3.5以后提供了async可以讓單線程達(dá)到相同效果。示例如下：

import threading import asyncioasync def hello():print('Hello world! (%s)' % threading.currentThread())await asyncio.sleep(10)print('Hello again! (%s)' % threading.currentThread())loop = asyncio.get_event_loop() tasks = [hello(), hello()] loop.run_until_complete(asyncio.wait(tasks)) loop.close()

值得注意的是這個(gè)異步的數(shù)量可以非常的龐大，上百萬都不會有什么問題，我們用下面的代碼進(jìn)行測試，

import threading import asyncioasync def hello():print('Hello world! (%s)' % threading.currentThread())await asyncio.sleep(1)print('Hello again! (%s)' % threading.currentThread())try:loop = asyncio.get_event_loop()tasks = [hello() for i in range(1000*1000*1)]loop.run_until_complete(asyncio.wait(tasks))# loop.close() except ValueError:print('Async Error')

?

總結(jié)

以上是生活随笔為你收集整理的python3 Async/Await入门指南的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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