asyncio:异常时停止协程

文章/答案/技术大牛

发布

1回答

从同步代码中调度任务以运行事件循环

python、python-asyncio、coroutine

考虑这个程序，其中用于停止它的主循环和协程实际上是由我正在使用的一个库实现的。import asyncio global runningloop.run_until_complete(mainloop())当程序收到信号时，我需要调用stop协程来停止主循环。虽然在使用async

浏览 43提问于2018-01-28得票数 1

回答已采纳

1回答

正常关闭和信号处理

python、python-3.x、python-asyncio

我正在尝试编写一个asyncio脚本，它可以通过发送SIGHUP信号来正常关闭。import asyncio print("sighup received") while True: await asyncio.sleep(1) asyncio.run(main())

浏览 17提问于2019-07-30得票数 2

回答已采纳

1回答

如何让协程停止并打印错误消息

python、debugging、python-asyncio

我有两个协程，其中co_2有一些错误，当我运行它时，co_2只是停止打印，co_1将继续运行，没有错误消息。如何让程序在出现任何错误消息/警告时停止并打印消息，以便修复它。import asyncio while True: print('co1111111111111111111111111111111111111'

浏览 8提问于2020-06-04得票数 1

回答已采纳

1回答

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

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

我来自JavaScript，正在尝试使用Python的async/await协程特性，但我在让它按我期望的方式工作时遇到了一些问题。让前两个函数并行运行非常容易。我遇到的问题与捕获语法错误有关。我将我的问题追溯到语法异常没有像我预期的那样冒泡，特别是异步似乎隐藏了错误，如果它们发生在“期货”中。我认为这就是我的问题所在，但我花了很长时间才能像我预期的那样捕捉到错误。我试着用try/except包装整个令人不快的协程，但这似乎破坏了我的其他协

浏览 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

1回答

检测协程是否需要异步循环

python、asynchronous、twisted、python-asyncio、coroutine

我正在编写使用Twisted在用户提供的协程上等待的代码。在一个更简单的例子中，我所需要的就是使用defer.ensureDeferred将协程转换为延迟。但是，如果协程使用asyncio.sleep()，我需要使用asyncio.ensure_future将其包装到异步任务中，该任务将在异步循环中运行，这需要AsyncioSelectorReactor。我希望支持第一种情况，即使没有使用AsyncioSelectorReactor，因此我不想在所有<

浏览 13提问于2019-08-23得票数 4

1回答

python、asynchronous、async-await、python-asyncio

我正在写一个函数，它必须在捕捉到异常的情况下自动重启，但我不知道该怎么做。我有这段代码，但它不能工作。import asyncio while True: #REALLY huge amount of codeprint(f"Exception: {e}") return asyncio</em

浏览 27提问于2019-11-10得票数 0

1回答

python asyncio:异步任务函数的模式

python、python-3.x、task、coroutine、python-asyncio

我需要一种方法来启动它们，然后在事件发生时停止它们。(1) await asyncio.create_task(self.do_work()) await asyncio.create_task(self.do_work()) tasks = [MyFirstTask(S

浏览 20提问于2019-12-10得票数 0

1回答

对异步函数的直觉

python、function、asynchronous、coroutine

0 While True: if i > 100000: return list if __name__ == '

浏览 4提问于2018-07-18得票数 0

2回答

asyncio create_task将永远运行

python、python-3.x、python-asyncio

我有以下代码 n = 0 print(f"{n}") n = n+1 awaitasyncio.sleep(5) print("Some Func&quo

浏览 0提问于2018-05-30得票数 23

回答已采纳

3回答

Python asyncio强制超时

python、python-asyncio

使用asyncio，可以在超时的情况下执行协程，这样在超时之后它就会被取消：def coro():loop.run_until_complete(asyncio.wait_for(coro(), 5)) 上面的例子按照预期工作(5然而，当协程没有使用asy

浏览 2提问于2015-02-19得票数 10

回答已采纳

2回答

有没有可能限制异步中并发运行的协程的数量？

python、python-asyncio

我已经使用asyncio编写了我的脚本，但是我发现同时运行的协程的数量太大了，而且它经常会挂起。loop = asyncio.get_event_loop()result = loop.run_until_complete(async

浏览 2提问于2018-05-13得票数 20

1回答

如何控制多个计算？

python

我假设asyncio.sleep(0)是一个(标准？)协程让其他协程运行的方式。但似乎我的协程不能有任何子例程结构(并放弃对顶层以下的控制)。$ cat test.py def f(): pass File "test.py", line

浏览 0提问于2018-05-03得票数 0

2回答

Python3如何使用asyncio.gather()查看分部函数列表

python-3.x、python-asyncio

我正在尝试创建一个可以传递给asyncio.gather()的协程列表。我当前的方法如下所示，使用functools.partial。不幸的是，asyncio.gather不接受分部函数，这是有意义的。那么，如何将参数附加到函数，以便它仍然可以传递给asyncio.gather呢？我的解

浏览 3提问于2019-01-21得票数 17

回答已采纳

1回答

如何使用asyncio.Protocol子类定期发送数据

python-3.x、python-asyncio

我有asyncio.Protocol子类 def __init__(self, exit_future): transport.close() pass 现在的问题是:我如何在一些外部事件发生时发送一些数据例如，当asyncio.Queue不为空(queue.get不会阻塞)时，填充该队列的是

浏览 0提问于2018-09-03得票数 0

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

回答已采纳

2回答

递归函数的Asyncio* loop.run_until_complete()*

python、recursion、python-3.5、future、python-asyncio

get_soup(base_url) dest = link.get('href') in_fut = asyncio.ensure_futureset_result)

浏览 1提问于2016-11-29得票数 1

2回答

asyncio和协程vs任务队列

python、task、python-asyncio

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

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

1回答

在使用asyncio.wait_for和asyncio.Semaphore时，如何正确捕获concurrent.futures._base.TimeoutError？

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

首先，我需要警告你:我对asyncio是个新手，我现在就警告你，我对asyncio是个新手，我很难想象在引擎盖下面的库里有什么。(future)无论我没有尝试捕捉这个异常，不管剩下多少任务，程序都会崩溃。我需要，当到达超时，程序继续下一个任务请，教我

浏览 117提问于2020-05-20得票数 6

回答已采纳

点击加载更多

从同步代码中调度任务以运行事件循环

正常关闭和信号处理

如何让协程停止并打印错误消息

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

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

检测协程是否需要异步循环