1回答
Asyncio和线程
、、、、
我使用asyncio订阅了一个随机输出数据的套接字(在db变量更新时)，显然我只有在事件循环运行时才会收到这些更新。我想创建一个线程，它会定期(比如每3-5秒)轮询事件循环以获取更新，即使我没有对事件循环执行特定的操作。你会推荐threading/mp吗，或者有没有一个更好的选择，用于asyncio内置到lib中的后台轮询循环，我不知道？
浏览 21提问于2019-09-20得票数 0
1回答
我想在asyncio任务中使用消费者/生产者模式新建一个线程来执行io任务：import threadingimport queue
time.sleep(v)
await asyncio.sleepq.put(i)
浏览 9提问于2021-03-08得票数 0
1回答
我正在努力理解asyncio，并移植我对threading的未识别信息。我将以两个线程无限期运行和一个非线程循环(它们都输出到控制台)为例。Problem 1：我不知道如何添加非线程任务，因为我看到的所有示例都显示了程序末尾的一个正在进行的循环，该循环控制asyncio线程。然后，我希望至少有两个第一个线程(a和b)并行运行(最坏的情况是，将第三个c也添加为一个线程，放弃混合线程和
浏览 4提问于2017-08-20得票数 6
回答已采纳
我想同时使用来自concurrent.futures和异步函数的ThreadPoolExecutor。 if bool: do_b() # ^
在do_b和do_a我想我可以让所有东西都使用线程，但我真的不想这么做。
浏览 1提问于2019-02-19得票数 7
回答已采纳
1回答
我是异步函数和线程的新手，我正在尝试返回一系列从Web获得的值，以便传递给另一个正在执行同步代码的线程。在代码中，我还使用了多Web套接字方法。下面我将向您展示代码： """with asyncio in a separate thread.This allows mixing"&quo
浏览 74提问于2021-09-19得票数 0
我目前正在Python3.7中使用asyncio，并使用asyncio.start_server()函数编写了一个TCP服务器。请参阅此示例：根据微软官方文档，它提到使用I/O完成端口和预先分配的线程池，但我找不到哪里可以分配线程的数量我可以在哪里分配线程池中的线程数量？
浏览 2提问于2020-06-14得票数 0
1回答
似乎有几个异步函数，如，因为同步原语并不是线程安全的.考虑到例如asyncio.Lock，考虑到线程安全，我假设当我们在计算机中运行多个线程时，这个锁不会锁定全局变量，因此竞争条件是问题。
浏览 3提问于2022-11-04得票数 1
1回答
这是我第一次尝试在项目中使用asyncio。我希望我的类初始化并运行，它的几个函数定期“在后台”运行。我希望类‘init’在启动这些后台任务后返回，这样它就可以继续同时执行其同步任务。__init__(self)
asyncio.set_event_loop(self.loop)
asyncio.ensure_future(self.periodic(), lo
浏览 1提问于2017-12-12得票数 1
回答已采纳
我有一个调用asyncio循环的线程，但是这会导致前面提到的异常：def worker(ws): l1.run_until_complete(ws.start())l2 = asyncio.get_event_loop()
浏览 0提问于2018-02-11得票数 13
回答已采纳
在我工作的爬虫里。它使用pycurl进行多个请求。怀疑主义使我怀疑潜在的改进，因为python有GIL。大部分时间都是在等待请求(网络IO)，所以如果我能够以真正的并行方式处理它们，然后在它们进来时处理它们，我就可以得到一个很好的加速。谢谢
浏览 3提问于2019-06-01得票数 1
回答已采纳
我编写的代码似乎可以做我想做的事情，但我不确定这是否是一个好主意，因为它混合了线程和事件循环，在主线程上运行一个无限循环。= asyncio.new_event_loop() asyncio.get_event_loop().run_until_complete，这样我仍然可以访问主线程中的共享变量。这在jupyter中特别有用，因为如果我在主线程中调用run_until_com
浏览 3提问于2018-03-31得票数 4
回答已采纳
我只是简单地将tornado应用程序与线程结合使用，如下所示： return tornado.web.Application([(r"/websocket", EchoWebSocketIOLoop.current() loop = asyncio.get_event_loop()
File "D
浏览 1提问于2018-06-26得票数 3
这里的许多人都告诉你要使用线程，但你如何让程序的其余部分在线程休眠时运行，并重新运行，然后再休眠。我尝试过像while循环这样的普通线程，但这对我不起作用编辑3:修复了它，它已经工作了，但我没有看到它，因为打印不能跨线程工作…我真傻。
浏览 23提问于2017-03-12得票数 1
回答已采纳
嗨，我是异步和事件循环概念的新手(非阻塞IO)。 ...async def firstWorker():
await asyncio.sleep(1)loop = asyncio.get_event_loop()asyncio.ensure_future(secondWo
浏览 2提问于2018-08-20得票数 1
回答已采纳
我正在构建一个web抓取API，我的大部分抓取都是用AsyncIO协同器完成的，如下所示： do scraping
asyncio.run(b.parse_event())
这非常好，但由于我是同时刮多个网站，我最初是使用concurrent.futures.ThreadPoolExecutor来使用多个线程的擦拭但是，由于我已经实现了coroutine逻辑，所以现在不能在线程中直接使用asyncio.run方
浏览 3提问于2021-10-26得票数 4
我可以限制ThreadPoolExecutor同时只使用一个处理器核心，一个进程和一个线程，但异步运行一个函数吗？
浏览 47提问于2020-07-24得票数 0
回答已采纳
goroutines是否大致等同于python的asyncio任务，还有一个额外的特性，即任何CPU相关的任务都会被路由到ThreadPoolExecutor，而不是添加到事件循环中(当然，假设我们使用的是不带当然，除了并发是Go不可或缺的部分所带来的效率和代码清晰度之外。
浏览 1提问于2017-05-31得票数 5
1回答
/usr/bin/env python
import websocketsimport sysimport websocketsasyncio.get_ev
浏览 475提问于2020-12-15得票数 0
回答已采纳
1回答
下面我创建了一个非常简化的应用程序版本，它打算使用Python的异步和线程模块。总的结构如下：import threading
def __init__(self, loop): print("Node: computation called with input ", x)
await asyncio.sle
浏览 5提问于2022-09-02得票数 0
回答已采纳
我在工作中遇到了一个问题，当InstrInstallSucceeded事件出现时，我必须等待10秒，在不阻塞主线程的情况下，我应该等待InstrInstallFailed的出现，换句话说，“ToolOn(1))new_loop = asyncio.new_event_loop(xxx())
浏览 0提问于2019-10-03得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
