asyncio.create_task vs await
asyncio.create_task和await都是Python中用于处理异步任务的关键字。
asyncio.create_task是一个函数，用于创建一个异步任务。它接受一个协程对象作为参数，并返回一个Task对象。Task对象可以用于管理和取消异步任务。
await是一个关键字，用于等待一个异步任务的完成。它只能在协程函数中使用，并且后面必须跟一个可等待对象，如协程、Future对象或其他实现了await方法的对象。当遇到await关键字时，协程会暂停执行，直到等待的任务完成。
asyncio.create_task和await都是用于实现异步编程的重要工具，它们可以帮助开发者更方便地处理并发任务和提高程序的性能。
推荐的腾讯云相关产品和产品介绍链接地址：
- 腾讯云函数（云原生Serverless计算服务）：https://cloud.tencent.com/product/scf
- 腾讯云容器服务（云原生容器化部署和管理服务）：https://cloud.tencent.com/product/tke
- 腾讯云数据库（包括云数据库MySQL、云数据库Redis等）：https://cloud.tencent.com/product/cdb
- 腾讯云CDN（内容分发网络服务）：https://cloud.tencent.com/product/cdn
- 腾讯云安全产品（包括DDoS防护、Web应用防火墙等）：https://cloud.tencent.com/product/ddos
相关·内容
1回答
我想返回异步生成器的第一个元素，并处理剩余的值，而不返回像fire和forget那样的值。如何在python中提前返回协程？在将迭代器传递给asyncio.create_task之后，它不会打印剩余值。
import asyncio
import time
async def async_iter(num):
for i in range(num):
await asyncio.sleep(0.5)
yield i
async def handle_remains(it):
async for i in it:
print(
浏览 2提问于2021-09-27得票数 0
在这里完成newb，阅读有关的信息，其中包含以下示例：
import asyncio
import time
async def say_after(delay, what):
await asyncio.sleep(delay)
print(what)
async def main():
task1 = asyncio.create_task(
say_after(1, 'hello'))
task2 = asyncio.create_task(
say_after(2, 'world'))
浏览 65提问于2019-05-23得票数 1
回答已采纳
我想写一个python程序，从rabbitmq服务器获取ip和tcp端口，并扫描以检查端口是否打开，因为这些扫描有时成批到来(可能是100个端口，ip对一次添加到队列中)。我需要异步执行扫描才能及时获得所有结果，即使我将超时降低到1秒，30个关闭的端口每次也会保持扫描30秒！我尝试了异步和aio_pika，以达到我的目标，但仍然是同步执行的扫描。
import asyncio
import aio_pika
import socket
async def tcp_check(host, port):
sock = socket.socket(socket.AF_INET, sock
浏览 0提问于2020-06-21得票数 0
2回答
我的问题是我有监听事件的脚本。事件侦听在连接到服务器后开始循环。所以在函数main中连接服务器之后，我创建了一个循环 loop = asyncio.get_event_loop()
asyncio.ensure_future(monitor(ts3conn, dbconn))
loop.run_forever() 现在，当我得到任何事件时，检查if语句，如果有True，我必须等待函数或创建新任务？我想异步3个功能，1主，侦听所有时间和其他什么将被创建时，有人写消息/加入通道，在此脚本异步仍然不工作，当30个用户加入通道777 (如果777 == int(事件‘
浏览 39提问于2019-09-01得票数 1
回答已采纳
1回答
如果任何人能帮助我使用Python和async/await，任何帮助都将不胜感激！ 我需要侦听websocket以获取消息，因此我设置了以下代码： import websockets
import asyncio
my_socket = "ws://......."
# I set a "while True" here to reconnect websocket if it stop for any reason
while True:
try:
async with websockets.connect(my_socket)
浏览 235提问于2021-02-27得票数 6
回答已采纳
我开始学习python asyncio模块。我正在写一个基本的程序，它基本上是等待一段时间，然后打印结果。
async def say_helloworld(wait:int)->None:
print(f"starting say_helloworld({wait})")
await asyncio.sleep(wait)
print(f"say_helloworld({wait}) says hello world!")
我编写了上面给出的协程，并创建了一些任务。
tasks = (asyncio.create_task(say
浏览 1提问于2019-12-29得票数 0
我已经阅读了很多不同的文章来解释Python中的async。但是他们都给出了一个asyncio.sleep(x)的例子，就像这样：
import asyncio
async def test1 ():
await asyncio.sleep(1)
print(1)
async def test2 ():
print(2)
async def main ():
await asyncio.gather(test1(), test2())
asyncio.run(main()) #prints 2, then 1
在这种情况下，对我来说一切都很清楚: awa
浏览 0提问于2020-10-25得票数 1
1回答
C#异步，无任务等待
、、、
通过创建一个或多个等待程序和等待对象，是否可以在C#中构建协程？
理想情况下，我希望能够写出如下内容：
void async Click() {
var mouse_position = await left_mouse_click();
await shoot_projectile();
}
然后从Click方法中获得一些东西，我可以在另一个异步方法中等待，或者可以使用某个MoveNext/GetResult方法显式迭代。
最终目标是我需要为游戏开发框架()集成C# async/await和F#单行协程。
浏览 1提问于2013-03-17得票数 11
回答已采纳
一个简单的生产者-消费者程序。代码每次都会在第三次迭代中抛出asyncio.exceptions.CancelledError。原因似乎是消费者没有得到await，而asyncio.sleep被取消了，从而丢掉了asyncio.exceptions.CancelledError。但最奇怪的是，谁总是在第三次迭代中取消asyncio.sleep？
import sys
import time
import asyncio
from queue import Queue
num = 11
pipe = asyncio.Queue()
async def producer(pipe):
浏览 1提问于2021-07-15得票数 0
3回答
所以我运行了一个asyncio示例：
import asyncio, time
async def say_after(delay, what):
await asyncio.sleep(delay)
print(what)
async def main():
task1 = asyncio.create_task(say_after(1, 'hello'))
task2 = asyncio.create_task(say_after(2, 'world'))
print(f"started at {tim
浏览 2提问于2020-12-11得票数 1
我有一个由HTTP请求触发的google云函数，它执行以下两个任务：
def task1():
do sth
return info
def task2(info):
do sth
def main(request)
info=task1()
if (info):
task2(info)
return info
我希望函数返回，而不是等待task2完成。因此，我做了以下更改：
import asyncio
def task1():
do sth
return info
async def task2(info):
do sth
asyn
浏览 12提问于2021-03-05得票数 0
回答已采纳
假设我有一个发布者发布消息，一个消费者使用它并调用数据库保存方法，那么我应该使用哪一个
await save(obj)
或
asyncio.create_task(save(obj))
为什么呢？
浏览 2提问于2020-09-05得票数 1
我有以下代码
import asyncio
loop = asyncio.get_event_loop()
async def while_loop():
n = 0
while True:
print(f"{n}")
await asyncio.sleep(2)
n = n+1
async def some_func():
await asyncio.sleep(5)
print("Some Func")
future = loop.create_task(while_lo
浏览 0提问于2018-05-30得票数 23
回答已采纳
目前，我有一个python脚本，它向微服务发出http请求。请求平均需要3秒。 这是我总结的python脚本。 def main():
response = request_to_MS(url)
# This process does not need the response of the microservice.
some_process()
# This is where i actually need a response from the microservice
do_something_with_response(response)
main()
浏览 22提问于2019-05-31得票数 0
回答已采纳
我想同时使用来自concurrent.futures和异步函数的ThreadPoolExecutor。
我的程序反复向线程池提交具有不同输入值的函数。在这个较大的函数中执行的任务的最终序列可以是任何顺序，我不关心返回值，只关心它们在未来的某个时候执行。
所以我试着这么做
async def startLoop():
while 1:
for item in clients:
arrayOfFutures.append(await config.threadPool.submit(threadWork, obj))
wait(a
浏览 1提问于2019-02-19得票数 7
回答已采纳
1回答
对异步函数的直觉
、、、
提前谢谢你，
假设你有一个异步函数：
async def create_list(num):
print("Creating a list that is length {}".format(num))
i = 0
list = []
While True:
i += 1
if i > 100000:
await asyncio.sleep(0.0001)
list.append(i)
if i == num:
浏览 4提问于2018-07-18得票数 0
我希望我的代码使用python logging来记录异常。在我常用的使用await的代码中，通常会引发异常，因此：
try: await code_that_can_raise() except Exception as e: logger.exception("Exception happended")
工作正常。
但是，在使用loop.create_task(coro())时
我不确定如何才能在这里捕获异常。
包装create_task()调用显然是行不通的。记录代码中的每个异常的最佳解决方案是什么？
浏览 0提问于2019-04-16得票数 5
我们在python中有一个使用asyncio的代码库，以及协程(async方法和await)，我想要做的是从一个C++类中调用其中一个方法，这个类已经被拉到python中(使用pybind11)。
假设有这样的代码：
class Foo:
async def bar(a, b, c):
# some stuff
return c * a
假设代码是从python中调用的，并且有一个io循环来处理这个问题，那么在某个时刻，代码会落入需要调用这个bar方法的C++区域--如何在C++中await这个结果呢？
浏览 4提问于2019-02-06得票数 12
我有一个包装器函数，它可能会多次运行courutine： async def _request_wraper(self, courutine, attempts=5):
for i in range(1, attempts):
try:
task_result = await asyncio.ensure_future(courutine)
return task_result
except SOME_ERRORS:
do_smth()
continue Corutine可以从不同的异步函
浏览 9提问于2020-03-18得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
