我有一个python3.6程序，其中我使用了asyncio包事件循环。我的一个数据源来自一个api，它不是基于异步构建的。我的connection对象包含一个名为_connection的成员，它只是一个python套接字。现在，我可以在select语句中使用它来判断数据何时准备就绪。async def run(self): if select.select([self._q.我试过了，但它会通过等待，我猜这是有意义的，因为我说的是0字节。_q.receive
浏览 0提问于2018-01-14得票数 10
回答已采纳
return data
def func2():如何在python中异步地创建最后一行？在我的例子中，所有class1.func1都需要发送，然后它们中的任何一个才能接收任何东西。我还看到需要实现__aiter__和__anext__，但我不知道如何在此上下文中使用它们。谢谢!
浏览 1提问于2020-05-20得票数 0
1回答
是否可以用Python异步地进行列表理解？我正在尝试对web进行多次调用，其中大部分等待时间是等待数据返回，我想异步地这样做。然后，在获取数据之后，我希望返回数据并将其存储在一个变量中。data_name_list): await asyncio.wait
浏览 0提问于2019-07-30得票数 0
为了模仿这一点，我将使用以下代码：tasks = [asyncio.create_task(asyncio.sleep(i)) for i in range(10)]
如果我像这样使用异步聚集API：awaitasyncio.gather(*tasks)，那么这个语句会阻塞事件循环，直到当前批处理中的所有任务完成为止。然而，问题是在我的程序中，我想使用一个ThreadPoolExecutor接口来执行那些任务，比如x数量的工人。这样可以更有效地执行任务(提前完成的任务将被另一个任务取代，而不是等待
浏览 9提问于2022-11-17得票数 0
回答已采纳
1回答
return total_result为了方便I/O操作，python引入了async / await关键字。关于python中</e
浏览 3提问于2020-09-25得票数 4
回答已采纳
这对于我如何在python3中使用异步非常清楚。import asyncio print(f"do something no.( do_something(2)但是，我不知道如何创建自己的“等待”-able对象，比如asyncio.slee
浏览 3提问于2021-05-17得票数 2
回答已采纳
如何在阻塞样式中运行异步函数？我不允许修改模拟函数f1()的签名，也不能轻松切换到异步def，因此不能使用等待表达式。回溯(最近一次调用)：文件“，第1行，在文件"/usr/lib/python3.9/asyncio/runners.py"，第44行，在运行返回loop.run_until_complete(主)文件”/usr/lib/python3.9/<em
浏览 4提问于2020-11-24得票数 1
回答已采纳
# Do stuff here
asyncio.run(main())我原以为在超时之后，我等待的任何东西都会被清理干净(因为我自己没有保留任何引用)。然而，事实证明并非如此。使用，我可以推断每次调用asyncio.wait(...)时，都会创建一个新任务，该任务包含对stop_event.wait()返回的对象的引用，并且该任务将永远保持在周围。只有在调用stop_
浏览 9提问于2022-10-06得票数 7
回答已采纳
2回答
因此，等待服务器会带来痛苦： #...await websocket.recv() # newer ends greeting = await websocket.recv() for seconds(10)
那么，如何在Python中只等待有限的时间呢？
浏览 0提问于2017-07-21得票数 5
回答已采纳
如何在Python中“等待”代码流？这是清除我问题的密码。import asyncio
print(f'{name} started')
await asyncio.gather(
io_rela
浏览 3提问于2020-03-19得票数 0
format(int(time()))) loop = asyncio.get_event_loop如您所见，调试环境变量是在上面代码的第5行中设置的，但是，跟踪仍然非常没有帮助，如下所示：
3.4.3rc1 (v3.4.3rc1:69dd528ca625+, Feb 8 2015, 11:01:19\lib\asyncio\base_events.py", line 304, in ru
浏览 4提问于2015-02-21得票数 4
回答已采纳
4回答
我正在使用Python3.4.2学习异步，我使用它在IPC总线上连续监听，而在DBus上闪烁。当我向运行底层代码的python进程发送SIGTERM时，脚本应该会优雅地终止。在等待yield from asyncio.sleep(0.1)时，信号处理程序捕获SIGTERM，并在此过程中调用task.cancel()。最后，调用loop.stop()，它停止循环，而不等待yield from asyncio.sleep(0.1)返回结果
浏览 4提问于2016-11-30得票数 57
回答已采纳
我想试用Python3.5.1中的新asyncio模块。\udp\client.py", line loop.run_forever() File "C:\Python35-32\lib\asyncio\base_events.py", line 1218
浏览 3提问于2016-06-30得票数 0
我是python异步模块的新手。asyncio.Future似乎提供了一种等待未来价值的机制，因此我尝试了一个玩具示例： def __init__(self): t1 = asyncio.create_task(random_reader.wait(3))我期望self.futures[k
浏览 0提问于2019-07-22得票数 4
回答已采纳
1回答
os.open('/var/mypipes/outgoing', os.O_RDONLY)list = {socket.here:'xmpp',os.open('/var/mypipes/outgoing', os.O_RDONLY):'mypipe'} (i, o, e) = select.select(list.keys(),[],[],1
浏览 2提问于2016-03-31得票数 1
回答已采纳
1回答
(即使发送/等待异步)。(main()) 但是这会抛出一个错误(休眠从来没有被等待过；但是如果我等待它，我就会得到从非异步函数调用的等待错误)。\PythonSoftwareFoundation.Python.3.8_3.8.1520.0_x64__qbz5n2kfra8p0\lib\asyncio\runners.py", line 43,Program Files\WindowsApps\PythonSoftwareFoundation.
浏览 21提问于2020-09-14得票数 0
回答已采纳
嗨，我想知道如何在Python中的for-循环中异步调用函数，从而使for-循环能够更快地执行。在本例中，bar()是一个时间密集型函数，因此我希望对它的调用是非阻塞的。return newItem
newItems = [bar(item) for item in items] return newItems
newIte
浏览 1提问于2022-07-14得票数 4
回答已采纳
2回答
我现在正试图做这样的事情： def method(self): def __str__(self(do_something())这表示我不能对coroutine对象调用我的方法。您不是在生成未来，而是等待
浏览 0提问于2020-06-28得票数 2
回答已采纳
是否有人知道一种更有效的方式来编写相同的东西，或者这仅仅是Python请求的基本速度？代码如下:)
PS:代码只花了5分钟就通过了600个帐户。
浏览 6提问于2020-11-05得票数 0
回答已采纳
我是一个新的python3.9用户，试图加强我的编码。我正在编写一个程序，它使用will循环，并将根据用户输入调用函数按键。问题是，time.sleep(1)不会暂停输入或代码中的那个点，它会暂停整个程序挂起while循环，这不是我希望它做的。搜索时间函数没有提供任何明确的解决方案，因为time.sleep()似乎是python中最流行的暂停函数。
浏览 3提问于2020-11-24得票数 2
回答已采纳
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
腾讯云开发者
