nonblocking 相关问题

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

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

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

回答 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) 开始 插座。

回答 1 投票 0

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

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

回答 4 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

在非阻塞队列 c++ 中使用指针的最高有效位作为标记

我正在尝试实现一个并发非阻塞队列,其中标记位于指针的 16 个最高有效位中。它在这里遵循这个算法: http://www.cs.rochester.edu/research/

回答 1 投票 0

Python 套接字非阻塞 recv() 异常和 sendall() 异常

我正在编写一个简单的 TCP 中继服务器,它将部署在 Windows 和 Linux 机器上(相同的代码库)。 自然会有两个插座可以使用。 我想知道...

回答 1 投票 0

为Object Flux实现Upsert功能

我有一个包含对象的flux请求。任务是创建(如果不存在)或更新(如果存在)这些对象。我已经尝试过实现这个功能,如下所示: requestFlux.flatMap(entry -> { ...

回答 1 投票 0

如何在Javascript中制作一个精确的睡眠函数,可能使用承诺?

我正在尝试用Javascript做一个睡眠功能。函数drawLinesToHtmlCanvas()的目的是为了在HTML画布上画出随机的线条,而用户需要能够看到被画出的线条......。

回答 1 投票 0

在Nodejs上下文中,为什么存在 "Don't Block Event Loop "这句话,即使在开发中也无法避免?

想象一个简单的快递网络应用,就像下面这样。 const express = require('express')......

回答 1 投票 -1

单线程与非阻塞如何处理?

如果单线程调用非阻塞函数,非阻塞函数如何处理?创建一个新的线程,然后在该线程中执行返回的(但未结束)非阻塞函数?我的意思是......。

回答 1 投票 0

同步异步后端

我需要创建一个REST端点,它将 "同步 "来自JMS后台服务的请求和响应。换句话说,我的端点应该向JMS输入队列发送消息,等待......。

回答 1 投票 0

如何创建一个读取文件的非阻塞生成器?

我试图创建一个文件生成器,它可以让我逐行读取一个文件(CSV),并在新行添加到文件时继续运行(就像一个连续的日志),但也保持 ...

回答 1 投票 1

为什么异步AWS Java SDK要使用线程池?

现在已经是2016年了,Java AWS SDK还没有真正的非阻塞API,这就避免了线程池(我是说线程每API请求方案)!这对我来说有什么好处呢?但是为什么呢?如果我想创建一个大规模的消息应用或...

回答 1 投票 4

在Java中使用ByteBuffer处理交错读写的最佳方法是什么?

编辑:为了使问题不那么 "意见化",我想问一下在交错读写的情况下,使用字节缓冲的暗示方式。我的程序处理一个随机序列的NIO, ...

回答 1 投票 0

Haskell,消耗非阻塞的getLine。

我正在寻找一个从stdin读取的方法,过了一会儿,如果没有输入,我想跳过那个getLine。我有这样的代码,在3秒后跳过第一个getLine,但当它...

回答 1 投票 0

为什么我得到错误的 malloc(): invalid size (unsorted)?

我在https:/github.comJamesRead5737webcrawlerblobmastercrawler.c有一段网络爬虫代码 它产生了一些奇怪的错误,我无法解释。最常见的是它Aborts with error malloc():...

回答 1 投票 -1

MPI_IBcast是否能保证在某些队伍不参与的情况下也能发送?

我正在创建一个MPI程序,我试图在所有进程完成计算后立即向它们发送相同的数据。这些进程的计算时间可能有很大的差异,所以......。

回答 1 投票 0

结合非阻塞和阻塞调用,并在Spring Webflux中返回结果。

我在使用Spring Webflux和Spring boot 2,我的方案是这样的。Controller @GetMapping(path="products") public List getProducts(){ return serviceObj.getProducts()...。

回答 0 投票 0

用于监视子进程的select()的模拟?

在符合POSIX的系统中,select调用在执行非阻塞I / O时非常有用,它使文件描述符何时为I / O操作“就绪”。有什么类似的...

回答 1 投票 1

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