asynchronous 相关问题

异步编程是用于推迟具有高延迟或低优先级的操作的策略,通常旨在提高软件的性能,响应性和/或可组合性。这些策略通常使用事件驱动编程和回调的某种组合来使用,并且可选地通过协同程序和/或线程来使用并发。

如何在asyncio中正确调用await函数?

我用asyncio创建了一个套接字服务器。从套接字读取是立即完成的,但写入套接字必须根据条件从另一个类调用。我的实现不起作用。

回答 1 投票 0

Node.js 中 Redis 的并发问题

问题 我的Redis中有一个名为stocks的键,其值为1000。假设有300个客户同时请求购买(每个客户100只股票)。最终,应该只有 10 位顾客能够购买。

回答 1 投票 0

如何使用 asyncio.to_thread 在单独的线程中运行 CPU 绑定的异步函数?

我正在使用异步任务多次调用第 3 方库,该任务包含在函数 run_task 中,该函数是 CPU 密集型的。 我尝试使用 asyncio.to_thread 在单独的线程中运行它,但我得到......

回答 1 投票 0

检查数据是否可在 ASIO 中读取

我正在使用 ASIO 将旧的 C++ 代码迁移到更现代的 C++,但我遇到了一个问题,我不确定如何使用 ASIO 解决。 总体思路是: 作为客户和 ...

回答 1 投票 0

异步关键字Future<dynamic>问题。我只是想知道下面的代码是如何生成错误的

我不知道这部分代码发生了什么: 未来 fnct() { print("fnct() 内部"); return Future.delayed(Duration(秒:4),()=>“你好”); } 未来的 fnct2() ...

回答 1 投票 0

NavLink 上的 fireEvent.click() 不会触发反应测试库中的 History.push()

我试图验证在单击异步 api 调用后生成的链接后是否调用了某个路由。我之前测试了链接的出现和正确的 href 属性...

回答 1 投票 0

用于流式传输请求正文内容的Python服务器

我正在尝试创建 python 智能代理服务器,它应该能够将大型请求正文内容从客户端流式传输到某些内部存储(可能是 amazon s3、swift、ftp 或

回答 3 投票 0

Swift CloudKit 和 CKQuery:当 queryResultBlock 返回查询游标时如何迭代检索记录

我正在使用 CloudKit 使用 CKQuery 从私有数据库检索记录,并在异步函数中使用 CKQueryOperation.queryResultBlock。我发现了几个使用

回答 3 投票 0

如何从Async Fetch函数中提取数据

这看起来应该非常简单和基本,但我无法从异步获取函数中获取数据。下面是我的代码。非常感谢任何对我可能做错的事情的洞察。 ...

回答 1 投票 0

NodeJS My SQL 查询与 Chain Promise

我有3个函数,我想逐步调用这个函数,例如当我调用第一个函数并得到结果时,我必须调用第二个函数并传递从第一个函数返回的参数...

回答 3 投票 0

java Selector 是异步或非阻塞架构

对我来说,以下是异步和非阻塞 I/O 最可能的定义: 异步 I/O:在异步 I/O 应用程序中立即返回,操作系统会让它们知道字节何时...

回答 2 投票 0

Python Asyncio - 等待一个特定的后台任务完成,然后再开始下一个

我有一个可以批量收集数据的应用程序。每次收集完一批数据后,它都会保存数据。为了加快速度,我一直在使用 asyncio,以便它可以继续收集数据...

回答 1 投票 0

如何从第一个任务获取结果,然后在循环中使用ContinueWith将其传递给第二个任务?

所以这就是我正在做的事情: var resultObj = GetFirstResultAsync() .ContinueWith(t => GetSecondResultAsync(resultObj)) 。等待(); 本质上告诉我我不能使用变量之前...

回答 2 投票 0

如何使用asyncio正确编写自定义套接字服务器?

Python 2 有一个带有 asyncore.dispatcher 的实现类 我需要在 Python 3 中实现相同的功能。 服务器类(asyncore.dispatcher): def __init__(自身、主机、端口、socketMap=None):

回答 1 投票 0

Rust 中有状态处理异步数据的模式

考虑以下 Rust 中的完整示例: 使用 async_stream::stream; 使用 futures::{pin_mut, StreamExt}; 使用 std::time::Duration; 使用 tokio::time::sleep; pub 结构处理器 { 酒吧状态:...

回答 1 投票 0

使用seastar库由fn arg引起的段错误

在下面的代码中,如果我使用名为 chunk 的本地变量,该程序将按预期工作,但如果我使用相同的变量类型但作为 fn arg 传递,则会出现段错误。 我正在移动那些物体,所以……

回答 1 投票 0

同时保存到文件 opcua 数据更改通知

我订阅了多个节点,这样只有当值发生变化时我才会收到通知。 我必须将数据保存到 csv 文件。这个想法是用时间戳+

回答 1 投票 0

Spring Boot中无法使用@Async

我想使用spring boot的异步机制,这是我的代码。 @Slf4j @配置 @EnableAsync 公共类 AsyncConfig 实现 AsyncConfigurer { 私有静态最终 int MAX_POOL...

回答 3 投票 0

setTimeout什么时候开始倒计时?

这是我现在正在使用的代码: setTimeout(() => console.log('第一'), 2000); for (令 i = 0; i < 5000; i++) { console.log("printing...") } setTimeout(() => conso...

回答 1 投票 0

我可以依靠垃圾收集器来关闭Python中的异步数据库连接吗?

我的团队正在开发一个用 Python 实现的异步 HTTP Web 服务器。我们使用 Redis 进行数据存储,并在 redis-py 库的帮助下连接到它。由于 HTTP 服务器是

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.