task2 = visit_url('http://another.com', 3)
asynicio.run(task2)

import asyncio
import time
async def visit_url(url, response_time):
  """訪問(wèn) url"""
  await asyncio.sleep(response_time)
  return f"訪問(wèn){url}, 已得到返回結(jié)果"

async def run_task():
  """收集子任務(wù)"""
  task = visit_url('http://wangzhen.com', 2)
  task_2 = visit_url('http://another', 3)
  await asyncio.run(task)
  await asyncio.run(task_2)
asyncio.run(run_task())
print(f"消耗時(shí)間：{time.perf_counter() - start_time}")

async def run_task():
  """收集子任務(wù)"""
  task = visit_url('http://wangzhen.com', 2)
  task_2 = visit_url('http://another', 3)
  await asynicio.gather(task1, task2)

import asyncio
from threading import Thread
 
 
async def production_task():
  i = 0
  while True:
    # 將consumption這個(gè)協(xié)程每秒注冊(cè)一個(gè)到運(yùn)行在線程中的循環(huán)，thread_loop每秒會(huì)獲得一個(gè)一直打印i的無(wú)限循環(huán)任務(wù)
    asyncio.run_coroutine_threadsafe(consumption(i),
                     thread_loop) # 注意：run_coroutine_threadsafe 這個(gè)方法只能用在運(yùn)行在線程中的循環(huán)事件使用
    await asyncio.sleep(1) # 必須加await
    i += 1
 
 
async def consumption(i):
  while True:
    print("我是第{}任務(wù)".format(i))
    await asyncio.sleep(1)
 
 
def start_loop(loop):
  # 運(yùn)行事件循環(huán)， loop以參數(shù)的形式傳遞進(jìn)來(lái)運(yùn)行
  asyncio.set_event_loop(loop)
  loop.run_forever()
 
 
thread_loop = asyncio.new_event_loop() # 獲取一個(gè)事件循環(huán)
run_loop_thread = Thread(target=start_loop, args=(thread_loop,)) # 將次事件循環(huán)運(yùn)行在一個(gè)線程中，防止阻塞當(dāng)前主線程
run_loop_thread.start() # 運(yùn)行線程，同時(shí)協(xié)程事件循環(huán)也會(huì)運(yùn)行
 
advocate_loop = asyncio.get_event_loop() # 將生產(chǎn)任務(wù)的協(xié)程注冊(cè)到這個(gè)循環(huán)中
advocate_loop.run_until_complete(production_task()) # 運(yùn)行次循環(huán)