在Python异步代码中，Promise.race的等价物是什么？
在Python异步代码中，Promise.race的等价物是asyncio.wait。
asyncio.wait是一个函数，用于等待一组协程对象完成，并返回一个包含已完成和未完成任务的元组。它类似于Promise.race，在一组协程对象中，只要有一个协程对象完成，就会立即返回。
asyncio.wait的语法如下：
done, pending = await asyncio.wait(coros, return_when=asyncio.FIRST_COMPLETED)其中，coros是一个协程对象的集合，return_when参数指定了返回条件，可以是asyncio.FIRST_COMPLETED（只要有一个协程对象完成就返回）、asyncio.ALL_COMPLETED（所有协程对象完成才返回）或者asyncio.FIRST_EXCEPTION（只要有一个协程对象抛出异常就返回）。
asyncio.wait的返回值是一个元组，包含已完成的协程对象集合和未完成的协程对象集合。可以通过done和pending来获取相应的协程对象。
在使用asyncio.wait时，可以结合asyncio.ensure_future将协程对象转换为Task对象，以便进行等待和管理。
以下是asyncio.wait的一些应用场景：
- 并发执行多个协程任务，只要有一个任务完成就进行下一步操作。
- 控制异步任务的超时时间，如果超过指定时间仍未完成，则进行相应的处理。
- 实现协程任务的优先级，根据任务的重要性或紧急程度进行处理。
腾讯云相关产品中，与Python异步代码和协程相关的服务是云函数 SCF（Serverless Cloud Function）。云函数 SCF 是一种事件驱动的无服务器计算服务，支持使用 Python 编写异步函数，可以方便地处理异步任务和事件触发。您可以通过以下链接了解更多关于云函数 SCF 的信息： 云函数 SCF 产品介绍
相关·内容
1回答
第一次完成后，取消两个异步协程
python、discord.py、python-asyncio
我正在用Python制作一个不和谐的机器人。我想要做的是等待两个协程，一旦第一个完成，运行其余的代码，但取消剩余的协程(不像here，我只有一个协程，并希望它在特定的时间后被取消)。 下面是可重现的最小示例： import asyncio
import discord
client = discord.Client()
async def testfunc():
await asyncio.sleep(10)
print("10 seconds.")
async def testfunc2():
await asyncio.sleep(15)
浏览 16提问于2020-09-25得票数 0
回答已采纳
1回答
asyncio.wait返回异常，即使在“尝试.除了`
python、python-3.x、exception、python-asyncio、discord.py
我在不和谐的机器人中有一个asyncio.wait语句，所以我可以一次等待多个事件。这样，机器人就不会随着时间的推移而陷入困境，我对这两个等待语句都有一个超时时间。即使代码在try ... except语句中，它仍然会引发错误。下面是导致错误的代码的一部分：
try:
def check(reaction: discord.Reaction, user):
if user != bot.user and message.id == reaction.message.id:
浏览 2提问于2020-06-26得票数 0
回答已采纳
1回答
在Python异步代码中，Promise.race的等价物是什么？
javascript、python、asynchronous、promise、python-asyncio
我想在Python代码中重现javascript的Promise.race行为。我希望同时运行一组协程，并在第一个协程完成时返回，获取其结果，并取消/丢弃仍在运行的协程的结果。
浏览 28提问于2018-12-29得票数 5
回答已采纳
1回答
如何在python中同时打开两个URLs
python、python-3.x、python-multithreading
我正在尝试找出一种同时打开两个URL的方法来节省时间。正如yu在这里看到的，如果10.10.10.2是可到达的，那么程序员就会关闭，如果192.168.100.5是可以到达的，那么程序员就会继续。对于这个业余的问题，我很抱歉，伙计们，我对编程非常陌生，所以不要对我太苛刻。我下面的解决方案花了很多时间，因为它一个接一个地发生。我正在用python编写一个小的检查工具，看看设备是否有正确的IP地址。因此，包含10.10.10.2的设备是有故障的，这是正确的IP地址192.168.100.5。有超过8000个设备需要测试，因此为每个设备等待10秒会花费太多时间。你们知道有什么其他的方法可以同时调用
浏览 29提问于2021-05-03得票数 0
回答已采纳
1回答
如何正确使用asyncio.FIRST_COMPLETED
python、python-asyncio、aiohttp
问题是，即使我在RuntimeError: Event loop is closed中使用return_when=asyncio.FIRST_COMPLETED，也会不断地得到await asyncio.wait()错误。
我的代码：
async def task_manager():
tasks = [grab_proxy() for _ in range(10)]
finished, unfinished = await asyncio.wait(tasks, return_when=asyncio.FIRST_COMPLETED)
for x in finish
浏览 0提问于2019-02-20得票数 6
回答已采纳
1回答
如何检查asyncio.wait之后完成了哪些协同工作
python、python-asyncio
考虑以下代码：
import random
import asyncio
class RandomLife(object):
def __init__(self, name: str):
self.name = name
self.coro = asyncio.sleep(random.randrange(0, 5))
def __await__(self):
return self.coro.__await__()
async def main():
objects = [RandomLife("one&
浏览 4提问于2021-08-23得票数 0
回答已采纳
1回答
当我明确表示只希望完成第一个任务时，为什么所有的任务都是用asyncio.wait()完成的？
python-3.x、asynchronous、python-asyncio
我试图使用异步从OpenSubtitles中获取一些数据，然后下载包含在该数据中的信息的文件。我想获取该数据并同时使用异步下载该文件。
问题是，我希望等待列表tasks中的1个任务完成，然后再开始列表或download_tasks中的其余任务。原因是，在self._perform_query()中，我将信息写入一个文件，而在self._download_and_save_file()中，我从该文件中读取相同的信息。因此，换句话说，download_tasks需要等待tasks中至少一个任务才能启动。
我发现我可以在asyncio.wait(return_when=FIRST_COMPLETED
浏览 0提问于2019-04-14得票数 0
回答已采纳
1回答
对异步函数的直觉
python、function、asynchronous、coroutine
提前谢谢你，
假设你有一个异步函数：
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
1回答
asyncio.wait订单有保证吗？
python、python-asyncio
我试图在我的库中实现基于异步的公平队列。
在某些函数中，我有一个类似于(假设socketX是任务)的语句：
done, pending = asyncio.wait(
[socket1, socket2, socket3],
return_when=asyncio.FIRST_COMPLETED,
)
现在，我多次阅读的文档，但是它不包含我想要的信息。主要是，我想知道：
当我发出电话时，socket1、socket2和socket3碰巧已经准备好了。它是否保证done将全部包含它们，或者它是否只返回一个(或两个)？
在第二种情况下，传递给wait()的任务顺序重要吗？
浏览 4提问于2016-05-18得票数 2
回答已采纳
1回答
异步等待-进程结果出现时
python-3.x、python-asyncio、aiohttp
这个脚本应该包含一个初始任务(URL)的列表，并使用aiohttp异步地发出请求。这部分做得很正确。问题是，由于asyncio wait不返回实际结果，而只返回done/pending task set，所以我无法确定在什么地方和如何处理结果，以便提出更多请求并将数据写入DB。在这个变体中，我创建了一个新的task (发出更多的请求.)在第一个里面，它不起作用。PS。我使用wait是因为我正在读的一本书建议使用wait来更多地控制已完成和挂起的任务和异常。(感谢任何帮助：)
async def fetch_content_2(session, url):
async with sess
浏览 4提问于2022-04-21得票数 0
回答已采纳
1回答
Discord.py -同步超时不能正常工作
python-3.x、discord.py
预期输出和我的代码是什么：
我的机器人应该发送一条消息，然后检查发送命令的用户是否用:arrow_left:、:arrow_right:或:wastebasket:对该消息做出反应，如果他们这样做了，则应该更改消息的“页面”。该部分工作正常，但我也希望消息在7秒的不活动后超时。
embed = await self.get_member_list(ctx, member, page)
msg = await ctx.send(embed=embed)
reactions = ["⬅️", "➡️", "
浏览 3提问于2021-02-20得票数 2
回答已采纳
1回答
从标准输入和其他源异步写入控制台
python-3.x、python-asyncio、python-blessings
我尝试为命令行编写某种渲染器，它应该能够使用asyncio和blessed打印来自stdin和其他数据源的数据，这是python-blessings的改进版本。
这是我到目前为止所知道的：
import asyncio
from blessed import Terminal
@asyncio.coroutine
def render(term):
while True:
received = yield
if received:
print(term.bold + received + term.normal)
async
浏览 3提问于2017-04-01得票数 0
1回答
如何像围棋中的等待组一样，在lua中等待所有的协程完成？
lua、synchronization、coroutine
如何像围棋中的等待组一样，在lua中等待所有的协程完成？使用Semaphobe完成了go中的Waitgroup。但是如何在lua中完成它呢？或者其他更好的方案？
浏览 2提问于2020-01-28得票数 1
2回答
如何检测和快速处理响应时间过长的lua函数？
multithreading、lua、coronasdk、luasocket、lua-lanes
我正在使用Corona SDK制作一个需要luasocket的简单应用程序。Corona SDK支持luasocket做异步http请求。
但我想使用luasocket中的UDP。来自luasocket的UDP接收()方法被阻塞，直到它接收到一条消息。
Corona SDK不支持LuaLanes。所以在另一个线程中监听udp消息是非常不可能的。
所以我在想，如果一个函数(在本例中是udp.receive() )响应时间太长，lua中是否有什么方法/技巧/变通方法可以检测和取消？
提前感谢
浏览 1提问于2011-06-22得票数 1
回答已采纳
1回答
如何在Python 3中将async-await与线程池正确结合使用
python-3.x、python-asyncio
我想要达到同样的效果
# Code 1
from multiprocessing.pool import ThreadPool as Pool
from time import sleep, time
def square(a):
print('start', a)
sleep(a)
print('end', a)
return a * a
def main():
p = Pool(2)
queue = list(range(4))
start = time()
results = p.map(
浏览 0提问于2018-11-07得票数 0
2回答
Python中的异步异常处理
python、python-3.x、python-asyncio
下面的代码使用asyncio和aiohttp发出异步HTTP请求。
import sys
import asyncio
import aiohttp
@asyncio.coroutine
def get(url):
try:
print('GET %s' % url)
resp = yield from aiohttp.request('GET', url)
except Exception as e:
raise Exception("%s has error '%s'&
浏览 0提问于2015-05-21得票数 60
回答已采纳
1回答
Python:在按完成对任务排序之后获取对原始任务的引用
python-asyncio
问:在asyncio.as_completed产生结果之后，如何获得对原始任务的引用？
基本上和这个C#问题是一样的，除了Python：
示例问题：
# Takes a list of WebClient objects,
# calls each one simultaneously,
# and yields the results immediately as they arrive
# to a synchronous caller.
def yieldThingsAsTheyArrive(webClients):
tasks = []
for webClient
浏览 0提问于2018-04-25得票数 3
回答已采纳
2回答
如何使用asyncio.gather立即解析响应？
python、python-3.x、multithreading、asynchronous、python-asyncio
async def main():
uuids = await get_uuids_from_text_file()
tasks = []
# create a task for each uuid
# and add it to the list of tasks
for uuid in uuids:
task = asyncio.create_task(make_hypixel_request(uuid))
tasks.append(task)
# wait for all the tasks to finis
浏览 4提问于2022-04-30得票数 -1
回答已采纳
1回答
等待中的ayncio超时方法解释
python、python-3.x、python-asyncio、aiohttp
>>> import asyncio
>>> help(asyncio.wait)
。。
Help on function wait in module asyncio.tasks:
wait(fs, *, loop=None, timeout=None, return_when='ALL_COMPLETED')
Wait for the Futures and coroutines given by fs to complete.
Coroutines will be wrapped in Tasks.
Ret
浏览 0提问于2015-03-03得票数 3
1回答
C++20协程:为什么promise类型与协程对象分离？
c++、c++20、c++-coroutine
典型的协程对象如下所示：
struct Coroutine
{
struct promise_type
{
int value;
Coroutine get_return_object() {return this; }
std::suspend_never initial_suspend() { return {}; }
std::suspend_never final_suspend() noexcept { return {}; }
void return_value(int v) {
浏览 0提问于2021-06-29得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
