nonblocking 相关问题

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

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

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

spring spring-webflux nonblocking

回答 4 投票 0

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

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

c++ for-loop nonblocking

回答 1 投票 0

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

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

ruby-on-rails ruby http rest nonblocking

回答 3 投票 0

非阻塞 Jms 队列发送器

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

playframework playframework-2.0 jms nonblocking playframework-2.2

回答 2 投票 0

python 请求阻止发布 mqtt 消息

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

python request mqtt blocking nonblocking

回答 1 投票 0

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

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

kotlin asynchronous kotlin-coroutines blocking nonblocking

回答 1 投票 0

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

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

java inputstream nonblocking thread-local java-21

回答 1 投票 0

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

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

java asynchronous reactive-programming nio nonblocking

回答 2 投票 0

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

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

kotlin kotlin-coroutines nonblocking ktor ktor-client

回答 2 投票 0

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

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

c# multithreading concurrency nonblocking interlocked

回答 2 投票 0

Java NIO：如何多次读入缓冲区？

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

java nonblocking java-nio

回答 1 投票 0

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

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

go nonblocking

回答 0 投票 0

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

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

java project-reactor nonblocking reactive-streams

回答 1 投票 0

什么是 EOF 处的阻塞行为

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

sockets eof nonblocking file-descriptor

回答 1 投票 0

Java NIO 非阻塞读写操作

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

java multithreading nio nonblocking

回答 1 投票 0

如何在 Linux 上使用 C 实现非阻塞控制台 I/O？

你如何在 Linux/OS X 上使用 C 实现非阻塞控制台 IO？

c linux macos io nonblocking

回答 8 投票 0

IO#read blocks on non-blocking socket?

红宝石 1.8.7。我在已打开并连接到的套接字上调用 read： socket = Socket.new(AF_INET, SOCK_STREAM, 0) sockaddr = Socket.sockaddr_in(mp.port, mp.ip_address.ip) 开始插座。

ruby sockets nonblocking

回答 1 投票 0

如何在不阻塞输入的情况下使用 getline？

是否有任何方法可以调用 getline() 并且，如果没有给出输入，则不会阻塞和等待？我有以下代码：而（真）{ 如果（recv（sd，tBuffer，sizeof（tBuffer），MSG_PEEK |

c++ nonblocking getline

回答 4 投票 0

使用新的 atomic.Pointer 类型实现无锁无界队列

我正在尝试从 Michael 和 Scott 实现这个非阻塞队列。我正在尝试使用 Go 1.19 中引入的新 atomic.Pointer 类型，但我的应用程序中出现了数据竞争。我在这里...

go atomic nonblocking

回答 1 投票 0

如何使非阻塞 ReadLineAsync() 在 .NET 中并发运行？

我们如何使用非阻塞IO并发读取文件行？ BiggestLineSequential 中呈现的 async await 的直接使用会导致顺序执行：静态异步任务...

c# .net nonblocking

回答 1 投票 0

nonblocking 相关问题

最新问题