我正在尝试以异步方式从一组URL中提取数据。我希望每10秒(或多或少)按URL组执行请求。/python3.5/asyncio/futures.py", line 293, in result executor = concurrent.futures.ThreadPoolExecutor()__init__() missing 1 required
浏览 25提问于2017-08-08得票数 1
回答已采纳
2回答
我需要一个项目使用几百个线程，每个线程都应该运行一个异步函数。最后，我需要收集所有线程的结果。我有下面的例子，但它同步工作。asyncio.sleep(2) return "some result"
futures = []
with concurrent.futures.ThreadPoolExecutor
浏览 7提问于2022-03-16得票数 1
在Python 中，它声明：
with concurrent.futures.ThreadPoolExecutor() as pool:
resultprint('custom thread pool', res
浏览 4提问于2019-12-05得票数 9
回答已采纳
2回答
对多个请求使用线程处理
、、、
为了测试我们的服务器，我们设计了一个用JSON有效负载发送大量请求的测试，并比较了它得到的响应。我有一个url地址和一堆JSON文件(这些文件包含请求，对于每个请求文件，都有一个“预期响应”JSON来比较响应)。我想使用多线程发送所有这些请求，并且仍然能够匹配返回到我发送的请求的响应。
浏览 1提问于2018-02-20得票数 0
回答已采纳
我用的是concurrent.futures.ThreadPoolExecutor。为了找到死锁的位置，我使用了来自ActiveState的ActiveState。下面是完整的堆栈跟踪：File: "c:\users\niklas\appdata\local\programs\python\python36\lib\threading.py_bootstrap_inner()
File: "c:\users\niklas\appdata\local\programs\pytho
浏览 0提问于2017-11-06得票数 13
如何在阻塞样式中运行异步函数？我不允许修改模拟函数f1()的签名，也不能轻松切换到异步def，因此不能使用等待表达式。回溯(最近一次调用)：文件“，第1行，在文件"/usr/lib/python3.9/asyncio/runners.py"，第44行，在运行返回loop.run_until_complete(主)文件”行，在f1文件“/usr/lib/python3.9/asyncio/base_vent
浏览 4提问于2020-11-24得票数 1
回答已采纳
1回答
由于我的应用程序需要一个阻塞特性，所以我正在尝试使用@return_future.I拥有time.sleep()来异步编写下面的代码。
浏览 3提问于2017-10-26得票数 0
回答已采纳
1回答
我使用asyncio (在python3.6中)来调度多个异步任务。long_task(t): time.sleep(1)executor = concurrent.futures.ThreadPoolExecutor
浏览 33提问于2019-07-03得票数 1
回答已采纳
我是Python新手，我想使用Python向cosmos DB发送异步HTTP请求以执行批量插入操作。我尝试使用多线程和asyncio来完成这个任务。ValidationException as e: async def save(self, users):
浏览 0提问于2019-10-31得票数 1
1回答
我想异步地运行阻塞和解除阻塞任务。显然，使用run_in_executor方法阻止来自异步的任务是必要的。tasks", datetime.datetime.now().time()) except (OSError) as exc:
sys.exit('Excepti
浏览 3提问于2020-09-02得票数 3
回答已采纳
1回答
Python 3.7非阻塞请求？
、、、、
我想在Python3.7中做一个非阻塞的http请求。我想要做的事情在中描述得很好，但是它还没有一个被接受的答案。print('cp #1') # <== `async.io` BLOCKS -- PRINT STATEMENT DOESN'T RUN UNTIL `asyncio.run` RETURNS
在Python
浏览 5提问于2019-11-08得票数 1
回答已采纳
我应该使用什么来代替异步复制？
我可以使用Gio.OutputStream.splice_async()，但这不能给我一个进度回调
浏览 0提问于2012-08-04得票数 4
回答已采纳
1回答
asyncio.get_event_loop().run_in_executor(None, foo) if future.done():问题是，未来的状态永远不会被改变，在循环中它总是挂起如果不是在循环中签入，而是手动检查未来的状态(在jupyter笔记本中)，它将被正确标记为已完成。
浏览 0提问于2019-04-14得票数 1
回答已采纳
1回答
loop.create_task(waiting())
loop.run_until_complete(main())我通过打开Python异步不是我想要做的事情的答案吗？
我的Python版本是3.6。
浏览 0提问于2019-01-30得票数 0
回答已采纳
1回答
我在python中使用Python Futures Concurrent获取结果的方法之一，当我在单独的文件上尝试它时，它工作得很好，但是当我将它与Flask Api集成时，结果是未定义的，我调试并发现我在由flask api调用的函数中的未来代码： with concurrent.futures.ThreadPoolExecutor() as executor:
futures_np1 =
浏览 13提问于2021-05-06得票数 0
我有一个想要运行的异步函数。然后我有了一个concurrent.futures.ThreadPoolExecutor，和我自己的“事件循环”，看起来像这样： executor = ThreadPoolExecutor(num_threads
浏览 10提问于2020-11-27得票数 0
1回答
for y in range(10): a = "Slow non-blocking function"我试图让函数t2运行异步我还在Python2.7中运行这段代码，这可能也是一个问题。我做错了什么？
注意:我也不想使用"concurrent.futures.ThreadPoolExecutor(8)“解决方案。
浏览 1提问于2015-09-12得票数 0
回答已采纳
Python中的实现接口在哪里，它允许异步循环运行程序(来自trio、异步、curio)启动整个系统？我们知道同步函数不能调用异步函数，但是异步实现有一个启动整个事件循环的神奇函数，例如：异步/trio/cur
浏览 0提问于2019-07-11得票数 1
如果我正确理解了Python3中的concurrent.futures模块是如何工作的，那么下面的代码如下：import threading
def test(i):
return a
output1 = list()
if
浏览 2提问于2020-04-19得票数 2
我正在尝试创建一个自动化，通过它的应用程序接口使用concurrent.futures.ThreadPoolExecutor异步注册Zabbix中的主机，就像你在这段代码中看到的那样： def zabbix_create_hostheaders, data=data) with concurrent.futures.ThreadPoolExecutorpd.concat(execu
浏览 31提问于2020-11-04得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
