针对特定用例的Python线程与asyncio
Python线程和asyncio是Python中用于处理并发编程的两种不同的机制。它们在处理特定用例时具有不同的优势和应用场景。
- Python线程：
- 概念：线程是操作系统能够进行运算调度的最小单位，可以理解为轻量级的子进程。线程之间共享同一个进程的内存空间，可以并行执行代码。
- 分类：Python中的线程分为CPU密集型线程和I/O密集型线程两种类型。CPU密集型线程主要消耗CPU资源，例如计算密集型任务。I/O密集型线程主要用于处理涉及输入/输出操作的任务，例如网络请求、文件读写等。
- 优势：线程在处理CPU密集型任务时能够充分利用多核CPU的优势，可以并行执行代码，提高程序的运行效率。此外，线程也可以用于处理需要实时响应的I/O操作，提高程序的性能。
- 应用场景：适用于需要利用多核CPU进行计算密集型任务的场景，以及需要并发处理多个I/O操作的场景。
- 推荐的腾讯云相关产品：腾讯云服务器（https://cloud.tencent.com/product/cvm）和腾讯云容器服务（https://cloud.tencent.com/product/ccs）。
- asyncio：
- 概念：asyncio是Python中用于编写异步代码的库，基于事件循环的机制，可以实现非阻塞式的异步编程。它利用协程（coroutine）和任务（task）来实现并发。
- 分类：asyncio主要用于处理I/O密集型任务，特别适合于网络编程和高并发的场景。
- 优势：asyncio采用事件循环模型，避免了线程切换和同步原语的开销，可以实现更高效的并发处理。它还提供了一些高级功能，如协程、异步上下文管理器等，简化了异步编程的复杂性。
- 应用场景：适用于需要处理大量I/O操作，例如网络通信、爬虫、服务器的高并发处理等。
- 推荐的腾讯云相关产品：腾讯云函数（https://cloud.tencent.com/product/scf）和腾讯云容器服务（https://cloud.tencent.com/product/ccs）。
总结： 根据特定用例的不同需求，可以选择使用Python线程或asyncio来实现并发编程。线程适用于处理CPU密集型任务和需要实时响应的I/O操作，而asyncio适用于处理I/O密集型任务和高并发场景。通过选择合适的机制，可以提高程序的性能和效率。
请注意，以上回答中没有提及亚马逊AWS、Azure、阿里云、华为云、天翼云、GoDaddy、Namecheap、Google等流行的云计算品牌商。
相关·内容
我试图理解异步模块，并花了大约一个小时使用run_coroutine_threadsafe函数，我甚至看了一下工作示例，它的工作原理与预期一样，但有几个限制。
首先，我不明白如何正确地调用主线程(任何其他线程)中的异步循环，在这个示例中，我用run_until_complete调用它，并给它一个协同线，让它忙着做某事，直到另一个线程不会给它一个协同线。我还有别的选择吗？
在现实生活中，当我必须混合异步和线程(在Python中)时，会发生什么情况？据我所知，异步应该代替Python中的线程(因为GIL不是IO操作)，如果我错了，请不要生气，并分享您的建议。
Python版本为3.7/3.8
im
浏览 2提问于2020-02-07得票数 12
回答已采纳
我试图通过python中的异步websockets将base64编码的PNG映像发送到JavaScript客户端。现在，我只是循环从内存中的图像创建一个“视频播放器”在JavaScript方面和它的工作.但是，第一个图像在我的python服务器上抛出一个RuntimeError。然后，它就像预期的那样，很难准确地找到问题。
ERROR:asyncio:Task exception was never retrieved
future: <Task finished coro=<WebSocketCommonProtocol.send() done, defined at /usr/
浏览 16提问于2020-10-29得票数 0
回答已采纳
2回答
何时使用多个事件循环？
、、、、
我有一个网络应用程序建立在一个Python 3.5+异步框架(apistar，sanic等)。该应用程序进行各种IO调用-对数据库、Redis等-也是异步的。
建议使用额外的事件循环：
import asyncio
import peewee
from peewee_async import Manager, PostgresqlDatabase
loop = asyncio.new_event_loop() # Note: custom loop!
database = PostgresqlDatabase('test')
objects = Manager(databas
浏览 2提问于2017-11-21得票数 15
我已经观察到，asyncio.run_coroutine_threadsafe函数不接受一般的可访问对象，我也不理解这种限制的原因。观察
import asyncio
async def native_coro():
return
@asyncio.coroutine
def generator_based_coro():
return
class Awaitable:
def __await__(self):
return asyncio.Future()
loop = asyncio.get_event_loop()
asyncio
浏览 0提问于2018-09-02得票数 4
回答已采纳
我在工作中遇到了一个问题，当InstrInstallSucceeded事件出现时，我必须等待10秒，在不阻塞主线程的情况下，我应该等待InstrInstallFailed的出现，换句话说，“ToolOn”、“ToolOn”、“ToolOn”不需要等待。
import asyncio
from threading import Thread
import time
FLAG = True
async def sleep_loop(t, event):
global FLAG
print(event)
if event == 'InstrInstallSucc
浏览 0提问于2019-10-03得票数 0
回答已采纳
1回答
我正在使用Docker，并且我试图在若干秒后与等待Docker容器完成的另一个任务进行竞争。实际上，我想知道给定的容器是否在我设置的超时内完成。
我有以下代码(改编自)：
container = # ... create container with Docker SDK
timeout = # ... some int
killed = None
# our tasks
async def __timeout():
await asyncio.sleep(timeout)
return True
async def __run():
container.wait()
r
浏览 0提问于2019-01-27得票数 3
回答已采纳
我一直在玩Python的asyncio。我想我现在已经有了一个合理的理解。但下面的行为让我困惑不解。
test.py
from threading import Thread
import asyncio
async def wait(t):
await asyncio.sleep(t)
print(f'waited {t} sec')
def run(loop):
loop.run_until_complete(wait(2))
loop = asyncio.get_event_loop()
t = Thread(target=run, args
浏览 0提问于2018-11-07得票数 1
我最近注意到在python的不同包中有两个不同的信号量实现，一个在threading包中，另一个在asyncio包中。我很好奇，这两种实现有什么区别？如果在异步函数中，我尝试使用threading包中的信号量，这会导致任何潜在的问题吗？
通过查看python官方文档，它编写了
asyncio primitives are not thread-safe, therefore they should not be used for OS thread synchronization (use threading for that)
但是说asyncio primitives are not th
浏览 2提问于2021-10-24得票数 0
回答已采纳
1回答
Python异步等待线程
、、、
我有一种情况，我有一个“服务器”线程，它应该监听来自其他服务器线程的调用/事件，同时执行一些其他代码。最近我使用Node.js做了很多工作，所以我认为使用async/await创建一个事件循环会很好，这样我就可以等待其他线程加入事件循环，并在它们最终加入时处理它们的响应。
为了测试这个想法，我用Python3.5编写了以下测试脚本：
# http://stackabuse.com/python-async-await-tutorial/
# Testing out Python's asynchronous features
import asyncio
from time impor
浏览 0提问于2016-05-14得票数 5
2回答
当我意识到同步版本比异步版本快20倍时，我正在将一个生产系统迁移到异步版本。我能够创建一个非常简单的例子，以一种可重复的方式演示这一点；
异步版
import asyncio, time
data = {}
async def process_usage(key):
data[key] = key
async def main():
await asyncio.gather(*(process_usage(key) for key in range(0,1000000)))
s = time.perf_counter()
results = asyncio.run(ma
浏览 0提问于2019-05-07得票数 3
回答已采纳
我很难理解Python3.7中引入的asyncio.create_task()函数是如何工作的。如果我这样做了：
import asyncio
async def helloworld():
print("Hello world from a coroutine!")
asyncio.create_task(helloworld())
def main():
loop = asyncio.get_event_loop()
loop.run_until_complete(helloworld())
if __name__ == "__
浏览 54提问于2018-08-04得票数 16
回答已采纳
我是Python和这些库/模块的新手。我正在编写一个简单的ping测试网络扫描仪作为一个学习项目。
我首先开发了一个使用异步到ping网络地址的脚本。
#ip_test.py
import asyncio
import ipaddress
async def ping(addr):
proc = await asyncio.create_subprocess_exec(
'ping','-W','1','-c','3',addr,
stdout=asyncio.subpro
浏览 2提问于2019-08-23得票数 3
回答已采纳
考虑以下简单的、独立的Python3程序：
import asyncio
import multiprocessing
import time
loop = asyncio.get_event_loop()
def sub_process(event, i):
async def async_function():
await loop.run_in_executor(None, event.wait) # <-- problematic line
print(f"successfully awaited on process {i}!
浏览 1提问于2020-09-14得票数 1
回答已采纳
我知道在python37中我们有一个新的接口asyncio.get_running_loop()，它很容易使用，让我们在调用协程时不需要显式地传递eventloop。 我想知道是否有什么方法可以让我们在python36中获得同样的效果？ # which allows us coding conveniently with this api:
import asyncio
async def test():
print("hello world !")
async def main():
loop = asyncio.get_running_loop()
浏览 33提问于2019-06-25得票数 4
回答已采纳
使用discord.py制作一个不和谐的机器人，这是我第一次使用异步操作，也可能是我第一次在Python中遇到令人沮丧的事情。
这个问题的重点不是教我如何使用异步，而是教我如何避免使用异步，即使这不是正确的方法。
因此，我需要运行来自常规def函数的不和谐客户端协同。经过几个小时的搜索，我发现了这个：asyncio.get_event_loop().run_until_complete(...)。我设置了一个小脚本来测试它：
import asyncio
async def test():
print('Success')
asyncio.get_event_loo
浏览 21提问于2017-10-21得票数 3
回答已采纳
1回答
我试图在python3.6中异步执行许多阻塞任务。所有阻塞任务都将在SQLITE3 (peewee )中存储数据。虽然这些任务的执行偶尔会给我一个DB块错误的sqlite3。我用的是sanic，Peewee和python3.6。
停止此DBBlock错误的代码的任何改进或改进。
#sqlite3_store_func is a blocking sqlite3 store function, which insert #data into the database
async def function_a(config, loop, executor):
ins = Somesyn
浏览 0提问于2019-07-13得票数 1
这段代码(在线程中运行的最小服务器，取自的代码)在Python3.8.3中工作得很好，但在Python3.9.0中引发了一条错误消息：
import asyncio
import threading
from aiohttp import web
def aiohttp_server():
def say_hello(request):
return web.Response(text='Hello, world')
app = web.Application()
app.add_routes([web.get('/'
浏览 1提问于2020-12-27得票数 1
2回答
我必须构建一个应用程序，在该应用程序中，我的计算机从不同的串口接收信息。
我的计划是每个端口使用一个线程来读取数据，使用另一个线程来解析和保存数据。线程之间的通信是通过async.queue完成的，但是我的实现有问题。
我用一个读线程做了一个简单的例子，当我尝试它时，我在实现中发现了一个问题。
import asyncio
import serial
from enum import Enum
EOL = b'\x17\x00'
class IdMessage(Enum):
ACK = 0xa0
PLS = 0xa1
async def read(port
浏览 7提问于2022-11-20得票数 0
我目前正在Python3.7中使用asyncio，并使用asyncio.start_server()函数编写了一个TCP服务器。请参阅此示例：
也可以尝试使用“I/O完成端口”(IOCP)的asyncio.ProactorEventLoop
根据微软官方文档，它提到使用I/O完成端口和预先分配的线程池，但我找不到哪里可以分配线程的数量
我可以在哪里分配线程池中的线程数量？有谁能帮帮我吗？非常感谢!
浏览 2提问于2020-06-14得票数 0
我有一个特定的场景(python 3.7+)： 我有一个python脚本，在执行过程中的某个时刻，我以守护程序模式(使用threading库)启动一个线程，以便在无限循环中向输出设备发送消息。现在，在此线程启动后，我希望定期更改正在发送的消息。另外，在某些情况下，我想“杀死”线程并停止消息发送循环。 因此，线程调用的函数基本上有一个while True:循环，它调用一些消息发送函数。在send_message(the_msg)中，the_msg是一个全局变量。然后，如果我想调整正在发送的内容，我只需更改the_msg的值。 这很好用，我想知道这种基于用例的方法是否可以。另外，我不太熟悉3.7
浏览 36提问于2019-06-08得票数 0
回答已采纳
如何从由reader, writer提供的异步asyncio.open_connection对并行读写
我在两个不同的循环上尝试了asyncio.open_connection，比如：
async def read():
reader, writer = await asyncio.open_connection('127.0.0.1', 5454)
while True:
readval = await reader.readline()
print(f"read {readval}")
async def w
浏览 7提问于2022-03-09得票数 0
问题
在我自己的项目中，我在线程中启动一个事件循环，然后取消任务并安全地关闭另一个线程中的循环。但我失败了。
在阅读了之后，我仍然无法理解如何等待Task.cancel之后真正取消的任务
Python版本:3.7.1
操作系统: windows
下面是我的调试过程。
import threading
import asyncio
import time
async def visit_sth():
print("start sleep")
await asyncio.sleep(3)
print("end sleep")
class
浏览 1提问于2018-12-18得票数 2
2回答
Python任务优化
、、、
我在Python中开发了一个简单的脚本，可以同时使用异步和tasks对多个目标执行一些随机操作。关于并发性和Python解释器在任务管理方面的优化，我有几个问题，因为我在并发编程方面有点新手。
我的主要问题是，Python在什么时候决定并发运行任务？这是Python解释器目前所做的优化吗？或者我是否应该使用线程或期货显式地按照代码编写
任何关于感兴趣的帖子、经验或文档的建议都将受到高度赞赏。
我附加了几个代码片段，用于比较它们：
# A Python3 example that uses tasks for concurrency
import asyncio
im
浏览 4提问于2021-01-08得票数 1
在我的用例中，当同步操作发生时，我向服务进行ping操作。完成同步操作后，我需要停止ping操作，但似乎run_in_executor无法cancel。
import asyncio
import threading
async def running_bg(loop, event):
await loop.run_in_executor(None, running, loop, event)
def running(loop, event):
while True:
if event.is_set():
print("can
浏览 5提问于2022-06-08得票数 0
回答已采纳
# !/usr/bin/python3
import asyncio
import aiohttp
from threading import Thread
event_loop = asyncio.get_event_loop() # getting the event_loop
Thread(target=event_loop.run_forever).start() # creating one more thread(to add and then to execute tasks when it is necessary)
async def fetch(session,
浏览 1提问于2020-07-17得票数 1
我用异步循环编写了一些代码：
loop = asyncio.get_event_loop()
# bla coroutines
loop.run_forever()
现在，有人用GObject.MainLoop()给了我一部分代码
l = GObject.MainLoop()
# functions using gi.repository I cannot modify, bla
l.run()
我应该将这些代码集成在与我的软件相同的软件中(使用异步)。这些代码必须同时运行。代码的各个部分必须交换对象。
我不确定哪一种解决方案会被占用，或者至少不会太难看？
ps:这段代码必须运行在window
浏览 0提问于2016-01-19得票数 5
回答已采纳
4回答
asyncio是否支持文件操作的异步I/O？如果是，我如何通过async/await语法代码在Python3.5中使用它？
浏览 1提问于2016-01-10得票数 49
我想使用Python中的异步模块来并行地完成请求任务，因为我当前的请求任务是按顺序工作的，这意味着它是阻塞的。
我用Python阅读了异步模块的文档，并编写了一些简单的代码，如下所示，但是它不像我想的那样工作。
import asyncio
class Demo(object):
def demo(self):
loop = asyncio.get_event_loop()
tasks = [task1.verison(), task2.verison()]
result = loop.run_until_complete(asynci
浏览 1提问于2016-03-08得票数 2
回答已采纳
我想在单独的线程中启动websocket服务器。我已经尝试实现如下，但得到运行时错误，因为它说附加到不同的循环 代码： #!/usr/bin/env python
# WS server example
import asyncio
import websockets
import threading
import time
async def hello(websocket, path):
name = await websocket.recv()
print(name)
greeting = "Hello " + name +"!&
浏览 263提问于2021-05-05得票数 2
1回答
我正在尝试创建两个线程，每个线程都有自己的异步事件循环。
我尝试了下面的代码，但它似乎不起作用：
import asyncio
from threading import Thread
def hello(thread_name):
print('hello from thread {}!'.format(thread_name))
event_loop_a = asyncio.new_event_loop()
event_loop_b = asyncio.new_event_loop()
def callback_a():
asyncio.set_eve
浏览 3提问于2018-09-12得票数 19
回答已采纳
1回答
我正在尝试使用asyncio编写一个并发Python程序，该程序也接受键盘输入。当我试图关闭我的程序时，问题出现了。因为键盘输入最终是用sys.stdin.readline完成的，所以该函数只有在我按下ENTER之后才会返回，无论我是stop()事件循环还是cancel()函数的Future。
有没有办法用asyncio提供可以取消的键盘输入？
这是我的MWE。它将接受键盘输入1秒，然后是stop()
import asyncio
import sys
async def console_input_loop():
while True:
inp = await lo
浏览 10提问于2019-10-22得票数 4
回答已采纳
1回答
使用Python 3.6.8
async def sleeper():
time.sleep(2)
async def asyncio_sleeper():
await asyncio.sleep(2)
await asyncio.wait_for(sleeper(), 1)
await asyncio.wait_for(asyncio_sleeper(), 1)
使用time.sleep不超时，asyncio.sleep执行超时。
我的直觉是，在协同线上调用wait_for将根据协同线所用的时间来确定超时时间，而不是基于协同线内的单个异步调用。究竟是什么在幕后导致了这种
浏览 2提问于2020-05-18得票数 3
回答已采纳
我正在尝试学习websockets客户端的异步操作。我尝试的每一段代码都会出现以下错误：
RuntimeError:无法从运行中的事件循环调用asyncio.run()
我尝试过最简单的代码，它总是给出RuntimeError。我试着重新安装完整的anaconda发行版，等等，但是找不到问题所在。
我使用Spyder 3.3.3和Python3.7.3
应该工作的代码示例：
import asyncio
async def main():
print('hello')
await asyncio.sleep(1)
print('worl
浏览 1提问于2019-05-15得票数 14
回答已采纳
1回答
我必须同时保持我的应用程序与Python 2和3兼容。
我有一些代码，如下面所示，我希望能够异步调用一个函数，然后等待我的未来得到解决。
代码：
import requests
# This would return a future
def get_xhr(url):
return requests.get('https://www.{}.com'.format(url))
# This would return an array of futures
def get_search_engines():
urls = ['google',
浏览 1提问于2019-01-13得票数 3
回答已采纳
3回答
是否可以从Python (3.4) (即在事件循环的上下文中)对Microsoft执行异步查询？
下面是一个框架异步程序，其中(异步) SQL查询应该安装到do_it函数中：
import asyncio
import contextlib
@asyncio.coroutine
def do_it():
# TODO: Make an asynchronous MS SQL query, but how??
fut = asyncio.Future()
fut.set_result(None)
return fut
with contextlib.clo
浏览 3提问于2014-07-18得票数 2
回答已采纳
1回答
我在python中与多进程和线程一起使用异步已经有一段时间了。但我不确定是否能看到AsyncIO和python中的线程之间的差异。
Python总是运行单个进程(除非使用多进程)，这正是异步和多线程很好的原因(两者都在任务之间切换)。多线程不能在python中同时执行，因此它们一直在被切换。这和异步是一样的，不是吗？
有谁能告诉我为什么在某些情况下他们可能会更好，为什么？
浏览 14提问于2022-11-24得票数 2
1回答
我有这个代码，理论上，它将检查一个通道中发送了多少条消息，并在每天的某个时间执行此操作。代码如下：
def checkTime():
# This function runs periodically every 1 second
threading.Timer(1, checkTime).start()
now = datetime.now()
current_time = now.strftime("%H:%M:%S")
print("Current Time =", current_time)
if(c
浏览 1提问于2021-03-28得票数 0
1回答
Python并发- CAN总线
、、、、
我正处于开发一个可扩展的基于CAN的硬件测试系统的初期阶段。测试系统的两个主要功能是记录总线上的所有流量并执行测试用例。测试用例主要由接收和发送CAN消息组成，同时评估消息数据有效载荷的内容。还将有一系列测试用例，这些测试用例必须与串行控制设备集成。
由于日志记录的重要性，我一直在考虑一个基于并发的程序。但我不确定我应该实现哪种形式的并发。我读过关于asyncIO、线程和多处理的文章。所以我对他们每个人都有一个高层次的看法。
我还在使用python库，这个库似乎内置了asyncIO，因此我相信asyncIO应该很好。我担心，如果测试用例协同处理不够快，我可能不得不使用asyncIO建立某种缓冲
浏览 2提问于2020-06-17得票数 1
回答已采纳
因此，我在摆弄Python的asyncio，并使用loop.create_task(myfunct())创建新的未来。当myfunct()完成时，它会返回。由于我使用loop.run_until_complete(..)创建了我的循环，所以我希望create_task创建的线程一旦函数完成就会被销毁。但是，当我在中查看process时，我看到线程从未被销毁。
进程启动时的线程:7
完成一些工作后的线程(并完成)：25
这里出什么问题了？
import sys
import asyncio
async def async_process_line(line):
print
浏览 0提问于2018-07-03得票数 0
回答已采纳
我编写的代码似乎可以做我想做的事情，但我不确定这是否是一个好主意，因为它混合了线程和事件循环，在主线程上运行一个无限循环。这是一个很小的代码片段，它捕获了我正在做的事情的想法：
import asyncio
import threading
msg = ""
async def infinite_loop():
global msg
while True:
msg += "x"
await asyncio.sleep(0.3)
def worker():
loop = asyncio.new_even
浏览 3提问于2018-03-31得票数 4
回答已采纳
来自python的asyncio示例： import asyncio
import time
def blocking_io():
print(f"start blocking_io at {time.strftime('%X')}")
# Note that time.sleep() can be replaced with any blocking
# IO-bound operation, such as file operations.
time.sleep(1)
print(f"blocking_io
浏览 161提问于2021-07-26得票数 1
回答已采纳
我的主Python线程不使用asyncio，但它创建了一个新线程，该线程的代码使用asyncio，在调用get_event_loop()时遇到错误 Traceback (most recent call last):
File "/usr/local/Cellar/python/3.7.5/Frameworks/Python.framework/Versions/3.7/lib/python3.7/threading.py", line 926, in _bootstrap_inner
self.run()
File "/usr/local/Cella
浏览 50提问于2020-01-17得票数 1
回答已采纳
2回答
有时，我的协程清理代码包括一些阻塞部分(在asyncio意义上，即它们可能会让步)。
我试着仔细地设计它们，这样它们就不会无限期地阻塞。所以“按照约定”，一旦协程进入它的清理片段，它就永远不会被中断。
不幸的是，我找不到一种方法来防止这种情况发生，当它发生时，糟糕的事情就会发生(无论它是由实际的double cancel调用引起的；或者当它自己接近完成时，正在进行清理，并且碰巧从其他地方被取消)。
理论上，我可以将清理任务委托给其他函数，用shield保护它，然后用try-except循环包围它，但它太难看了。
有没有Pythonic式的方法来做到这一点？
#!/usr/bin/env pyt
浏览 2提问于2016-09-25得票数 1
代码中的逻辑是通过(异步) HTTP请求提取数据，然后构建大量字典列表，其中一个值是随机生成的：
import asyncio
import random
import string
import time
from concurrent.futures import ProcessPoolExecutor
from itertools import cycle
from httpx import AsyncClient
URL = 'http://localhost:8080'
COUNT = 1_000_000
def rand_str(length=10):
浏览 1提问于2020-08-26得票数 0
回答已采纳
在python中，有：协同、任务和未来。
我可以await一个协同线，也可以一个tasks。
等待一条协同线
import asyncio
async def nested():
return 42
async def main():
print(await nested()) # will print "42".
asyncio.run(main())
等待一项任务
import asyncio
async def nested():
return 42
async def main():
task = asyncio.create
浏览 3提问于2021-04-08得票数 5
回答已采纳
1回答
我正在寻找一种方法来创建一个python websocket服务器。
我已经通读了asyncio教程。
这对我来说似乎相当复杂，我用kdb做过这件事，这是世界上最简单的事情。
为什么在python中它看起来异常复杂？
我真正想做的就是有一个python服务器，它会将数据推送到整个数据中所有连接的客户端。
然而，从asyncio教程来看，似乎每次从客户端收到消息时，连接都会关闭(他们到底为什么要这样做？)
我需要连接永远保持开放。我决定它什么时候关门。
服务器会在必要的时候推送数据(根据我的逻辑)
此外，客户端可以从服务器请求(其他类型的)数据
我会假设这是可行的？但从那个教程中看起来并非如此
浏览 2提问于2020-07-06得票数 2
在Python 中，它声明：
应用程序开发人员通常应该使用高级异步函数(如asyncio.run() )，并且很少需要引用循环对象或调用其方法。本节主要针对低级别代码、库和框架的作者，他们需要对事件循环行为进行更精细的控制。
当同时使用async和threadpoolexecutor时，如示例代码所示(来自文档)：
import asyncio
import concurrent.futures
def blocking_io():
# File operations (such as logging) can block the
# event loop: run
浏览 4提问于2019-12-05得票数 9
回答已采纳
我试图用stream编写一个并发流处理程序，我想知道这是否是Python协同最有效的使用。asyncio包有大量的选项，但是很难确定项目的正确方法，我认为这些文档在解释每个项目的优缺点方面做得并不好。
我认为这里不需要多个线程的开销，我需要异步循环之间的相互通信。我应该为我的每个函数创建一个单独的BaseEventLoop吗？
作为Python，我认为这个问题(There should be one-- and preferably only one --obvious way to do it)有一个近乎确定性的答案，但我担心，添加所有这些异步巡洋舰可能只会使我的代码比完全顺序的天真实现更低
浏览 2提问于2016-01-27得票数 4
我试图模拟NFC芯片的读取，方法是在一个充当socket服务器的python脚本中按下cmd键。它的工作是在按下cmd键后通知客户端。它可以工作，但是emulate_nfc_tag()需要很长时间才能在我按下cmd之后执行。我怀疑这与create_task的工作方式有关。我希望有人能发现我如何优化这段代码。
from aiohttp import web
import socketio
import asyncio
from pynput import keyboard
import random
import string
sio = socketio.AsyncServer(cors_
浏览 4提问于2022-08-07得票数 1
回答已采纳
我尝试从Qt应用程序运行一个python3异步外部命令。在没有冻结Qt之前，我使用了一个多处理线程来完成这个任务。但是现在，我想用一个QThread来实现它，以便能够对QtWindows进行筛选，并给出一个QtWindows作为其他函数的参数(这里没有给出)。我在我的Windows操作系统上成功地测试了它，但是我在Linux操作系统上尝试了这个应用程序，我得到了以下错误:RuntimeError: Cannot add child handler, the child watcher does not have a loop attached
从那时起，我试图隔离这个问题，并且我获得了下面的最
浏览 2提问于2018-12-19得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
