此标记用于asyncio Python包，它提供了编写单线程并发代码的机制。 asyncio包提供从Python 3.4开始的异步I / O，事件循环，协同程序和任务。
这在一般方面更多，但我最近需要通过python中的UNIX域套接字将通过WebSocket API接收的大量消息发送到多个子进程。纯线是......
我有一个程序，我需要发出大量的URL请求。我无法同时发出所有请求，因为总会有新的URL添加到队列中。我也不能运行它们......
我试图找出一种简单的方法来取消堆叠队列，方法是获取一块chunk_size和一个超时。例如，我希望get_chunks函数返回一个列表...
我是python中的新手，我必须创建一个程序，从Web套接字和管道保持linstening所以我需要两个异步函数。这些函数中的每一个都在不同的thrad中调用其他方法...
我一般都知道，不应该在多进程之间共享对象以及可能由此产生的问题。但我的要求是必须这样做。我有一个复杂的对象...
为什么asyncio call_later（）不能在python中工作？
这是我在python3.6中的代码import asyncio import time class A（）：def __init __（self）：print（“A init”）print（“actvating1”）loop = asyncio.get_event_loop（）loop ....
假设我有一个类，并希望并行读取磁盘中的几个文件，并参数化类参数。什么是最正确的方法（以及如何）？主线程应该等待......
是否有Pythonic方法在后台运行异步任务类似于使用上下文管理器？
最近我想在运行其他任务的同时在后台运行一些异步任务，但我认为代码不够Pythonic：task = asyncio.create_task（long_task（））await short_task（）...
基本上，有一个小的aiohttp应用程序，它接收Impala查询列表，然后发送它们Impala。但是有些查询可能需要很长时间才能完成，因此决定在异步/并行中进行...
假设我有以下代码：import asyncio import threading queue = asyncio.Queue（）def threaded（）：import time while True：time.sleep（2）queue.put_nowait（time ....
我有asyncio.Protocol子类MyProtocol（协议）：def __init __（self，exit_future）：self.exit_future = exit_future def connection_made（self，transport）：self ....
无法通过等待asyncio.run_coroutine_threadsafe
我观察到asyncio.run_coroutine_threadsafe函数不接受一般的等待对象，我不明白这种限制的原因。观察导入asyncio异步...
我正在尝试使用asyncio编写HTTP / 1服务器，我正在尝试让它处理HTTP keep-alives。我有以下一点代码。 import re import socket import asyncio async def ...
调试并列出将来在python asyncio中挂起的所有协同程序
我有一个生产代码，大量使用asyncio.semaphore模块，怀疑有死锁问题。我已经找到了一些如何使用unix信号附加到运行python代码的解决方案，...
Windows中的aiohttp Python库是否支持HTTPS？
当我在Windows 7中使用带有asyncio和Python 3.4的aiohttp库发出HTTPS请求时，请求失败，并在base_events.py的_make_ssl_transport函数中出现NotImplementedError，因为...
如果我从非异步函数调用它并且事件循环已经运行，是否可以从协程获得结果？
我一直无法将asyncio集成到较旧的代码库中。其中大部分是可管理的，但我遇到了麻烦，非同步函数需要调用协程。 ...
由于我的项目很大程度上依赖于异步网络I / O，我总是不得不期待一些奇怪的网络错误：它是我连接到API中断的服务，还是我自己的服务器......
我开始使用websockets和asyncio，并且很难理解背后的逻辑。我过去在Python上使用过线程以及在Javascript上使用AJAX调用（所以我对......有所了解）
＃！/ usr / bin / python3＃ - * - coding：utf-8 - * - import asyncio，time async def asleep（n）：time.sleep（n）#blocking method async def doAsync（n）：print（“ doAsync {}开始......“......
我正在尝试使用asyncio实现一个简单的echo服务器。这是我的尝试：导入asyncio async def process（reader，writer）：while True：data = await reader.readline（）...