nonblocking 相关问题

非阻塞模式I / O要么传输至少一个字节,要么立即返回错误或流结束。非阻塞算法是指在没有通常的互斥原语的情况下使用并发,保证线程操作不会无限期地阻塞。这通常通过原子值修改(递增/递减)和/或读取(比较和交换)操作来处理。不清楚这个标记的用途。

Python 的 `print()` 函数是阻塞函数还是非阻塞函数?

我正在尝试加快脚本的处理时间,在某些配置中可能会通过 print() 将大量输出转储到控制台。 Python的print()函数是阻塞还是非阻塞...

回答 2 投票 0

阻塞 IO 与非阻塞 IO [已关闭]

有一次,我偶然看到 Indy 简介文章,从那时起我就一直在思考阻塞 IO 与非阻塞 IO。 正在寻找一些描述优点和缺点的好文章...

回答 2 投票 0

为什么这个承诺永远无法兑现?

我正在测试将承诺添加到队列的代码,它们应该以非阻塞方式处理。我有一个代码可以按预期工作,但其他代码却不能,我不明白为什么。 代码...

回答 1 投票 0

Java:SelectionKey.attach() 损坏了吗?

在我的 Java NIO 实现中,我无法让 SelectionKey.attach() 工作。基本上,一旦客户端连接(OP_ACCEPT 兴趣操作),我会将它们添加到其 IP 地址映射的地图中...

回答 2 投票 0

java Selector 是异步或非阻塞架构

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

回答 2 投票 0

Webflux 使用 zip 传输 DataBuffer 导致文件损坏

目前,我正在使用 Spring Boot 2.7.12 和 Webflux 实现一个非阻塞 i/o 应用程序,以使用 Web 客户端下载文件,压缩它们并将 zip 文件流式传输到浏览器。 正在下载并zi...

回答 4 投票 0

纯C++设计模式非阻塞for循环

我尝试阅读有关我的问题的信息,但甚至找不到合适的词来谷歌它。 假设我有一个纯 C++ 中的函数(将在 ESP32 上运行,无线程): 无效 do_something_for_a_long_...

回答 1 投票 0

在 Rails 应用程序中发出非阻塞 HTTP 请求

有人知道如何从 Rails 中发出非阻塞 HTTP 请求吗?我最终将需要响应主体,并试图避免提出新的框架来保持一切正常......

回答 3 投票 0

非阻塞 Jms 队列发送器

我想将日志/审核事件发布到 JMS 队列服务器。我实现了“QueueConnectActor”,它使用以下代码构造消息、创建队列并发送消息。 这使得阻塞校准...

回答 2 投票 0

python 请求阻止发布 mqtt 消息

我正在开发一个从两个来源获取数据的程序: 来自前端的传入 mqtt 消息 (paho) 和 来自 RestAPI 的数据(请求) 传入的 mqtt 消息触发对 R 的请求...

回答 1 投票 0

在 Spring Boot 应用程序中使用网络请求功能将 Suspend 关键字视为多余

我一直在深入研究 Kotlin 协程,发现挂起函数可以简化使用 Kotlin 和协程时异步和非阻塞代码的创建。在 Android 中

回答 1 投票 0

用于从HTTP响应读取InputStream的虚拟线程

使用 java 21,只需在虚拟线程中执行即可将阻塞 IO 代码转换为非阻塞代码。 我是否应该简单地包装返回 InputStream 的 HTTP 调用(如方法 nonBlo...

回答 1 投票 0

Apache NIO HttpAsyncClient 如何执行非阻塞 HTTP 客户端

Apache NIO HttpAsyncClient 如何能够在不阻塞任何线程的情况下等待远程响应?它是否有办法与操作系统设置回调(我对此表示怀疑?)。否则它会执行一些...

回答 2 投票 0

非阻塞I/O和Kotlin协程有什么关系?

Kotlin 协程和非阻塞 I/O 之间有什么关系?其中之一是否暗示着另一个?如果我使用阻塞 I/O 会发生什么?这对性能有何影响?

回答 2 投票 0

互锁类:先读后写竞争条件问题

使用系统; 使用系统线程; 使用 System.Threading.Tasks; 命名空间 InterlockedLearning { 班级计划 { 静态 int 共享变量 = 0; 静态无效Main() ...

回答 2 投票 0

Java NIO:如何多次读入缓冲区?

我有以下代码,它是选择器的一部分。 响应应该小于 256,并且以换行符结束。 但据我了解,这是可能的(尽管我没有

回答 1 投票 0

如何在Golang中为io.PipeRaeder进行非阻塞Read()

我有以下代码。 5 秒后,可执行程序将向 stdout 发送一些文本。因此,in.ReadLine() 将阻塞直到接收到数据。如何为 ReadLine() 设置超时或在非

回答 0 投票 0

Mono.just() 在我的用例中当发出的元素挂起时仍然阻塞

我有两个测试使用 sleep() 模拟需要时间处理的 api 调用,并测试 Mono.just() 是否使其成为非阻塞。 在我的第一个测试中,我直接发出了一个字符串,但让它阻塞了......

回答 1 投票 0

什么是 EOF 处的阻塞行为

读取已达到 EOF 的文件描述符(在本例中为非阻塞套接字)是否有可能在检测到 EOF 之前阻塞? 如以下顺序: 阅读回报...

回答 1 投票 0

Java NIO 非阻塞读写操作

我正在为一个项目开发一个 NIO 服务器,该服务器将来自客户端的消息作为输入,其中包含读取和写入操作的运行时间。 我有一个问题,因为在第一个执行...

回答 1 投票 0

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