Python3 asyncio:并行协程意外阻塞

文章/答案/技术大牛

发布

1回答

python、python-asyncio

我正在尝试让两个函数(协程)与来自单个开放网络连接的共享读取器和写入器流并行工作，如下所示： while True: writer.write(data)loop = <e

浏览 14提问于2018-02-26得票数 2

1回答

以下是示例代码 async def washing(): print("All washed!")await asyncio.sleep(5) asyncio.run(myloop()) 很明显，我会被“洗刷干净！”然后“开始洗衣...”打印输出，因为await是阻塞的-它不会继续，直到命令被执行之后。但我想要的是另一种方式，先“开始洗”。我可以以非阻塞的方式启动洗衣协程，然后继续下一个命令

浏览 27提问于2021-07-07得票数 2

回答已采纳

5回答

Python协程在项目中实际使用了吗？

python、coroutine

不久前，我从David Beazley的协程程序上读到了，我想知道是否有实际的基于Python的软件使用它们？为什么协程看起来像是Python中最未使用的功能？

浏览 0提问于2011-04-23得票数 8

1回答

使用Python中的协程正确捕获语法错误

python、error-handling、async-await、python-asyncio

我正在试着写一个小的Python脚本，基本上可以并行运行两件事。我来自JavaScript，正在尝试使用Python的async/await协程特性，但我在让它按我期望的方式工作时遇到了一些问题。我试着用try/except包装整个令人不快的协程，但这似乎破坏了我的其他协程(似乎打破了我对协程如何工作的假设)。 #!/usr/bin/env python3 impo

浏览 67提问于2020-09-28得票数 0

1回答

检测作为子例程调用的python协程

python、coroutine

假设我有一堆协程。应该使用yield from调用这些协程。我如何发现我犯了一个错误，并像子例程一样直接调用协程？下面是一个示例代码：def A(msg): yield from asyncio.sleep(1) def B():

浏览 1提问于2015-08-17得票数 1

2回答

asyncio和协程vs任务队列

python、task、python-asyncio

我一直在阅读有关python3中的asyncio模块，以及更广泛的关于python中的协程的内容，但我不明白asyncio是什么让asyncio成为如此伟大的工具。我有一种感觉，使用协程可以做的所有事情，都可以通过使用基于多处理模块(例如芹菜)的任务队列来做得更好。有没有协程比任务队列更好的用例？

浏览 4提问于2015-12-23得票数 26

2回答

如何在asyncio中运行run loop.Python 3.5中其他协同例程中的独立协同例程

python-3.x、async-await、python-asyncio

必要时，使用主循环运行协程，表示将执行某些操作。从它开始，启动另一个协程，它不会阻塞。使用Python 3.5async def cor1(): await asyncio.sleepasyncio.ensure_future(cor2()) loop = asyncio</em

浏览 2提问于2016-12-21得票数 1

1回答

Python协程中的并行异步IO

python、python-asyncio、aiohttp

简单的示例:我需要并行发出两个不相关的HTTP请求。最简单的方法是什么？这有助于asyncio.ensure_future从由事件循环单独管理的协程中分离出任务： with aiohttp.ClientSession(coro_3_result = await coro_3为了在我的逻辑流程中使用协程实现<em

浏览 2提问于2017-11-08得票数 23

回答已采纳

1回答

asyncio从协程获取结果

python-3.x、python-asyncio

我有一个任务是在异步和python3帮助下在协程之间进行通信。请告诉我怎么做，如果一个协程，在while tru循环中，以不同的时间间隔返回值，而其他协程接收到这个数据。import asyncio def write(future): while True: yield from asyncio.sleepfuture.set_result('

浏览 2提问于2016-12-16得票数 1

2回答

Python类型和未来

python、future、python-asyncio、typing、concurrent.futures

我很高兴在Python3中使用模块，也很高兴使用而不是twisted、tornado和alternatives。我们应该说这只是一个协程吗？示例1： passdef request() -> asyncio.Future: f = <

浏览 14提问于2017-07-15得票数 2

回答已采纳

1回答

使用asyncore实现gethostbyaddr()

python、python-2.7、sockets、dns、asyncore

我很享受socket.gethostbyaddr()的乐趣，寻找如何加速一个真正简单的代码，随机生成一些IP地址，并试图解决它们。当找不到主机时，问题就出现了，超时可能会很长(大约10秒...)我想知道是否有可能使用Asyncore做一些等效的事情？这就是我首先尝试做的，但不幸失败了……import socket a = str(random.randint(140,150)) b = str(random.randint(145,15

浏览 32提问于2017-08-01得票数 1

回答已采纳

1回答

在python中套接字接收速度较慢

python、asynchronous、networking、python-asyncio

params) // makes rpc calls over tcp await rpc_call() loop = asyncio.get_event_loop() tasks.append(asyncio.ensure_future(test())) loop.run_until_complet

浏览 0提问于2018-04-22得票数 1

1回答

Asyncio任务与协程

python-asyncio

阅读异步文档，我意识到我不理解一个非常基本和基本的方面:直接等待协程和当它被包装在任务中时等待相同的协程之间的区别。在文档示例中，对协程在没有等待的情况下按顺序运行，并且当包装在 ..。然而，令我困惑的是，在示例代码中，我到处都在阅读(例如，展示如何使用 )，有许多地方等待(用户定义的)协程(通常在其他一些用户定义的协程的中间)而不被包装在任务中，我想知道为什么会这样。确定何时应该在任务中包装协程<

浏览 31提问于2019-09-17得票数 17

回答已采纳

3回答

使用asyncio的非阻塞I/O

python、python-3.x、pygame、python-asyncio

我正在尝试用Pygame和asyncio写一个网络游戏，但是我想不出如何避免挂起读取。下面是我的客户端代码：def handle_client(): while True: mouse_up我之前认为asyncio的要点是它是非

浏览 1提问于2014-12-28得票数 25

回答已采纳

1回答

如果使用了lock，为什么aiohttp请求会阻塞？

python-3.x、multithreading、multiprocessing、locking、python-asyncio

为什么这段代码： import asynciofrom multiprocessing import Pool, Manager async with ClientSession() as s: def run(lock: Lock)

浏览 63提问于2021-11-08得票数 0

回答已采纳

1回答

asyncio -函数按顺序运行，而不是并发运行

python、python-requests、python-asyncio

这是一个非常简单的函数： async def get_data(url):tasks = [asyncio.ensure_future(get_data(url)) for url in websites.split('\n')] group = asyncio.gather

浏览 22提问于2020-10-10得票数 0

1回答

在Python语言中等待vs asyncio.run()

python、async-await、coroutine

在Python语言中，await使用协程和使用asyncio.run()的实际区别是什么？它们似乎都在运行协程，我能看到的唯一区别是await只能在协程中使用。

浏览 12提问于2020-11-23得票数 7

回答已采纳

2回答

相当于Python的"async def“函数中的"yield”

python-asyncio

我听说@asyncio.coroutine版本的协程最终将在Python中被弃用(可能在3.8之后？)，并且只支持async def。今天，我使用装饰器版本是为了能够只使用yield (而不是yield from另一个协程)，因为我正在等待一些变化(例如while循环中的轮询)，或者将大部分耗时的阻塞代码拆分成更小的块(从而改善并发体验下面是一个最小的例子：def foo(l):

浏览 14提问于2018-08-23得票数 4

回答已采纳

1回答

Python 3:如何向threadPool提交异步函数？

python、python-3.x、multithreading、asynchronous、python-asyncio

我想同时使用来自concurrent.futures和异步函数的ThreadPoolExecutor。所以我试着这么做 for item in clients: wait(a

浏览 1提问于2019-02-19得票数 7

回答已采纳

1回答

Asyncio进程阻塞

python、asynchronous

所以我有一个基本的不一致机器人，它接受输入import asyncio asyncio.set_event_loop(loop) bot.loop.create_task(Hangman.main(message))

浏览 24提问于2017-08-09得票数 0

回答已采纳

点击加载更多