试图为自己总结这两个概念之间的区别(因为当我看到人们在一个句子中同时使用这两个概念时，我真的很困惑，比如“非阻塞异步IO”，我试图弄清楚这意味着什么)。
因此，在我的理解中，非阻塞IO是处理IO的主要OS机制，如果有任何数据准备就绪，否则只需返回error/什么都不做。
在异步IO中，您只需提供一个回调，当数据可用时，应用程序将被通知。
那么什么是“非阻塞异步IO”呢？以及如何在Java (标准JDK，没有外部库的情况下，我知道有java.nio.channels.{Channels, Selector, SelectorKey}和java.nio.channels.{Asynchronous
浏览 5提问于2014-08-02得票数 86
回答已采纳
2012年，在Haskell eXchange做了一次演讲。由于时间限制，他跳过了简单并发聊天服务器上的部分。出于对被删除内容的好奇，一项网络搜索发现了类似的和。
读取
回话…
talk :：服务器->句柄-> IO () talk server@ Server {..}句柄=做hSetNewlineMode句柄universalNewlineMode hSetBuffering句柄LineBuffering readName，其中readName = do hPutStrLn句柄“您的名字是什么？”名称<- hGetLine句柄m <- checkAddClient
浏览 3提问于2013-01-26得票数 7
回答已采纳
1回答
我想在webpack生产模式中使用缓存，这样如果不做任何更改，重建工作会更快。这种方式起到了作用，它将webpack的运行时间从20秒减少到5秒，只是为了扩大规模。但是当我跑第三次时，它卡住了很长一段时间-它需要大约1+分钟。我有18核cpu和m2固态硬盘，3gbps的读/写速度，我不知道它能做什么？ 那么为什么第一次运行是20秒，第二次运行是5秒，第三次运行是1分钟？ 我在webpack的配置中添加了如下内容： cache: {
type: 'filesystem',
compression: false,
profile: false,
浏览 55提问于2021-10-02得票数 0
我有一个定制的ASP.NET路由，其中包含IO操作。现在，假设这些IO操作不能缓存(即太大)。
在某种程度上，我正在寻找一个AsyncRouteBase类
public async override Task<RouteData> GetRouteDataAsync(HttpContextBase httpContext)
public async override Task<VirtualPathData> GetVirtualPathAsync(RequestContext requestContext, RouteValueDictionary routeValu
浏览 3提问于2015-07-18得票数 10
以下使用io_service接受tcp连接的方法是否有效，也可以作为为连接客户端服务的线程池使用，还是有一些警告？
io_service svc;
io_service::work work(svc);
// define the three threads in the io_service thread pool
thread t1( [&svc]() { svc.run(); } );
thread t2( [&svc]() { svc.run(); } );
thread t3( [&svc]() { svc.run(); } );
endpoint ep(
浏览 4提问于2015-02-01得票数 1
回答已采纳
1回答
Netty数据包和设置帧
、、、、
目前，我正在开发一个PacketSystem。通过该机制，我创建了一个身份验证系统，并创建了一个密钥，该密钥作为字符串从客户机发送到服务器，如下所示：
protected void channelRead0(ChannelHandlerContext ctx, Packet p) throws Exception {
if(p instanceof PacketInServerAuthRequest) {
System.out.println("Sending WrapperAuthKey. Waiting for answer...");
浏览 1提问于2017-11-19得票数 0
回答已采纳
我正在阅读Java中的多线程服务器和其中的通信。我有一个以上的疑问：“同步与异步和阻塞与非阻塞IO之间有什么区别。它们都谈到相同的概念吗？”
浏览 4提问于2021-04-05得票数 0
回答已采纳
想知道有没有人知道WriteFile() (这里的存储团队)的内部设计？磁盘驱动器/文件系统上的文件具有重叠的IO。显然，当使用系统缓冲区和标准同步WriteFile()时，它会检查整个磁盘并在返回之前分配空间，因为保存实际数据的系统缓存稍后会被写入(一个问题会导致操作系统的延迟写入错误)。
所以问题是:当使用OVERLAPPED结构来扩展文件超出空闲空间的异步WriteFile()时，情况是否也是如此？例如，它将在挂起IO之前立即返回ERROR_DISK_FULL？
需要知道的原因是恢复释放磁盘空间，或插入新媒体，并恢复写入。如果这样做，它是相当直接的，如果在挂起IO之后，您可以有一堆排队的
浏览 0提问于2019-07-10得票数 0
回答已采纳
我使用libev开发我的事件驱动应用程序。我喜欢在事件内部查询远程mysql服务器。那么，mysql_real_connect是阻塞整个应用程序，还是只阻塞my_read_cb？
按照下列代码
my_read_cb(EV_P_ ev_io *w, int revents) {
mysql_real_connect(*mysql, "host", "user", "pass", "db", 3306, NULL, 0);
}
struct ev_loop *loop = ev_default_loop(0);
ev_i
浏览 9提问于2017-03-09得票数 2
回答已采纳
我在tcp服务器上使用asio，我也计划对线程使用C++11 std。我的最后一个目标是在Linux上使用这个应用程序，但是我首先使用Visual 2015在Windows上测试它。
首先，我使用阻塞，所以我发现有关于如何停止线程等待接受的讨论。有预C++11的解决方案，如管道，并选择.我在找asio的方法。
asio::io_service io_service;
tcp::acceptor acceptor(io_service, tcp::endpoint(tcp::v4(), 13));
backAcceptor = &acceptor;
tcp
浏览 0提问于2015-11-01得票数 1
3回答
我有一个IO操作(每个Pandas行的POST请求)，我试图使用异步IO来加速这个操作。下面可以找到一个可供选择的最小示例。我想知道为什么第一个样本不并行运行，第二个样本运行得更快。
第一样本：
from time import sleep
import asyncio
import nest_asyncio
nest_asyncio.apply()
async def add(x: int, y: int, delay: int):
sleep(delay) #await asyncio.sleep(delay)
return x+y
async def get_resu
浏览 13提问于2022-10-18得票数 0
回答已采纳
我来自爪哇，习惯于习惯于
while (true) {
try {
someBlockingOperation();
} catch (InterruptedException e) {
Thread.currentThread.interrupt(); // re-set the interrupted flag
cleanup(); // whatever is necessary
break;
}
}
据我所知，这适用于任何可能阻塞的东西，比如从文件读取、从套接字读取、从队列读取甚至对Thread.sleep()。
读到在Rust中是如何做到这
浏览 2提问于2018-09-23得票数 6
回答已采纳
1回答
我试图阻止使用PorterStemmer标记数据后得到的记号这个词，但得到的结果是不正确的。哪种词干算法是最好的选择？
密码-
from nltk.stem import PorterStemmer
porter = PorterStemmer()
porter.stem("mobile")
代码输出-
mobil
预期产出-
mobile
浏览 5提问于2022-03-25得票数 0
如果我取消了我的一个项目中的注释，并注释掉了后面的那个，我偶尔会得到异常&堆栈跟踪：
System.InvalidOperationException: Operation is not valid due to the current state of the object
at System.IO.StreamWriter.CheckState () [0x00000] in <filename unknown>:0
at System.IO.StreamWriter.WriteLineAsync (System.String value) [0x00000]
浏览 2提问于2014-03-15得票数 0
回答已采纳
因此，我正在阅读我最喜欢的软件模式书籍之一(面向模式的软件体系结构-并发和网络对象的模式)，特别是关于Proactor/Reactor异步IO模式的章节。我可以看到，通过使用可选择的通道，我可以很容易地实现反应器风格的异步IO机制(并且已经做到了)。但是，我不知道如何使用非阻塞写入来实现适当的Proactor机制。这就是利用操作系统管理的非阻塞写入功能。
特定于操作系统的调用支持的功能，如win32下的。
我确实看到Java7为NIO带来了一些带有异步完成处理程序的更新(这似乎是在正确的方向上)。话虽如此..。考虑到对操作系统管理的异步操作(特别是异步写入)缺乏统一的跨平台支持，我假设这是一个
浏览 1提问于2011-04-03得票数 26
回答已采纳
2回答
当我在后台打开我的应用时，它收到了一个通知。为此，我使用了一个服务。每当我的应用程序在后台，新的通知到来时，应用程序将自动打开。它工作得很好。但是当应用程序在后台并且手机屏幕被锁定时，现在当通知到来时，它会显示在屏幕上(锁定屏幕)，当用户打开手机锁定时，我的应用程序的屏幕将可见，但屏幕将不会响应，屏幕颜色也会像灰色布局一样。 要打开我正在使用的服务的应用程序，代码是： Intent serviceIntent = new Intent(getApplicationContext(), NewTaskService.class);
if (Build.V
浏览 51提问于2021-10-26得票数 1
回答已采纳
我在几个应用程序源码中都看到了，比如“我的世界”和“JIrcs”，它们都使用java.io来实现反应器插件(如果我没有记错的话)，并且在这个中也是如此。那么，在实现反应器模式时，java.io和java.nio有什么不同呢？我的意思是，比如性能优势，进程效率等等，如果你认为java.io是实现反应器模式的好方案，我可以在哪里获得很好的教程(因为谷歌给了我大量的java.nio tuts，而不是我想要的java.io )
浏览 3提问于2012-03-30得票数 10
回答已采纳
抱歉，如果这听起来很蠢！我们正在与flink一起进行异步IO调用。很多时候，IO调用是重复的(相同的参数集)，我们调用的大约80%的API对相同的参数返回相同的响应。所以，我们不想再打电话了。我们认为我们可以使用状态来存储先前的响应并再次使用它们。问题是，尽管我们的响应可以再次使用，但此类响应的数量很大，因此需要大量的内存。是否有一种方法可以在需要时将其持久化以驱动和查询？
浏览 7提问于2020-02-03得票数 2
回答已采纳
2回答
我很想知道客户端是如何工作的，比如Java的AsyncHttp客户端或C#的异步Web请求特性，基本上，底层代码是如何确保线程不会仅仅等待IO操作的结果的。
我猜是机器中断了。但我不知道它们在C#或Java等高级语言中是如何工作的。
浏览 0提问于2013-07-04得票数 2
回答已采纳
1回答
我一直在研究boost asio库，其中大多数对象都需要io_context对象作为构造函数的参数。我读过什么io_context对象，根据它声明的文档
io_context类为异步I/O对象的用户提供核心I/O功能
这让我感到困惑，因为这不是iostream所做的事情吗?我真的确定我遗漏了什么，请帮我澄清一下，而且我也没有看到I/O对象和套接字之间有什么区别，除了套接字可以用来在两个设备之间交换数据之外，而I/O对象使我们能够与计算机交换数据。我现在真的很困惑！
浏览 1提问于2020-04-02得票数 13
回答已采纳
当使用http客户端库向服务发出同步请求时，线程会被阻塞，直到返回数据为止。那么，在同步http请求中使用非阻塞io有什么好处吗？
用例:使用Spring开发的Web应用程序。对于某些请求，对REST服务进行同步调用。使用使用NIO调用服务的HttpClient库是否有利？使用非阻塞IO。我不清楚来自的HttpComponents是否支持NIO。
浏览 2提问于2012-07-14得票数 2
我想在从同步函数返回之前调用并等待异步函数完成
// async function
Future<User> getUser(String username) async {
...
}
在dart中，我可以使用等待异步函数，然后再转到下一条语句。
bool checkUser(String username, String encodedPwd) {
var user = waitFor<User>(getUser(username));
if (user.pwd == encodedPwd)
return true;
e
浏览 7提问于2020-11-29得票数 1
1回答
用阻塞程序语言进行异步操作吗？
、、、、
同步方式
例如，红宝石：
con = Mysql.new('localhost')
rs1 = con.query('select * from test01') # A
rs2 = con.query('select * from test02') # B
rs = getResult(rs1, rs2) # C
con.close
因此，A将阻止执行。B将被执行，直到A完成为止。C也是
异步方式
例如，nodejs
var mysql = require('mysql');
var
浏览 1提问于2017-05-15得票数 0
回答已采纳
我想以异步方式读取C++中的一个大文件。我已经使用boost::asio从网络套接字执行异步读取，我想知道是否可以扩展boost::asio来对常规文件进行非阻塞读取。
我可以使用单独的线程来完成这项工作，但是有没有更本机的解决方案，可以很好地适合asio::io_service？
我正在使用Linux，但我不会拒绝使用std::ifstream的便携解决方案;)
浏览 6提问于2015-08-06得票数 3
1回答
我试图理解如何增强Asio的实现和限制。据我所知-
当您对套接字执行async_receive_from调用时，会发生以下情况
套接字将请求转发给I/O执行上下文。 I/O执行上下文向操作系统发出信号，表示它应该启动异步连接。操作系统指示连接操作已经完成，方法是将结果放在队列上，准备由I/O执行上下文来获取。当使用io_context作为I/O执行上下文时，程序必须调用io_context：：run(或类似的io_context成员函数之一)，以便检索结果。当有未完成的异步操作时，对io_context::run()的调用会阻塞，因此您通常会在启动第一个异步操作后立即调用它。
假设我有很高的
浏览 4提问于2021-03-09得票数 1
回答已采纳
我一直在做基于网络的Javascript (香草JS，jQuery，主干等)几年来，我一直在使用Node.js做一些工作。我花了一段时间才掌握了“非阻塞”编程的诀窍，但我现在已经习惯了在IO操作等方面使用回调。
我知道Javascript本质上是单线程的。我理解节点“事件队列”的概念。我不明白的是，是什么决定了单独的javascript操作是“阻塞”还是“非阻塞”。我如何知道我可以依赖哪些操作来同步生成输出，以便在以后的代码中使用，以及我需要向哪些操作传递回调，以便在初始操作完成后处理输出？是否有异步/非阻塞的Javascript函数列表，以及同步/非阻塞的Javascript函数列表？是什么
浏览 0提问于2013-06-19得票数 29
回答已采纳
我正在使用OkHttp来发出同步http请求。为了避免阻塞主线程，我用挂起函数和withContext(Dispatchers.IO)包装阻塞网络调用。
suspend fun run(): String {
val client = OkHttpClient()
val request = Request.Builder()
.url("https://publicobject.com/helloworld.txt")
.build()
return withContext
浏览 2提问于2021-07-22得票数 2
回答已采纳
我读到过select和多线程编程是低性能的IO模型，例如这个。
我不明白同步/同步:阻塞/非阻塞是如何提高性能的。为什么AIO是这里的最佳选择？
浏览 0提问于2012-01-04得票数 5
回答已采纳
5回答
假设我们从1到5，最短的路线是1-4-3-5 (总计: 60公里)。
📷
我们可以使用迪克斯特拉算法来做到这一点。
现在的问题是，由于交通堵塞或其他因素，最短的路线并不总是最快的。
例如：
众所周知，1-2有频繁的交通堵塞，所以应该避免。
突然，一场车祸发生在4-3，所以它也应该避免。
等等..。
所以也许我们可以在1-4-5号公路上行驶，因为没有交通堵塞/事故，所以我们可以在5点到达。
这是一般的想法，我还没有想过更多的细节。
有什么算法可以解决这个问题吗？
浏览 0提问于2011-12-19得票数 17
回答已采纳
我正在开发一个带有async控制器的ASP.NET Core web应用程序。我正在引用和调用ASP.NET Core项目中的方法，该项目不使用执行IO绑定工作的异步编程(无async)。
理想的解决方案是重构引用的项目以使用异步编程。然而，我面临着严重的时间限制。
Microsoft documentation 使用Task.Run创建任务以执行IO限制的工作。它还立即等待来自Task.Run的结果。
我的问题是-在这种情况下，有没有其他选择，我可以在不重构和不创建线程的情况下调用非异步方法，同时保持高可用性？
浏览 4提问于2021-04-20得票数 0
1回答
非阻塞IO是如何实现的？
、、、
在Java或C#或一些其他语言中，存在非阻塞IO设施，例如，用于套接字。
因此，我可以将回调函数提供给非阻塞IO，一旦非阻塞IO接收到任何内容，它就会调用我的回调函数。
我想知道它们是如何实现的。如果我在后台创建非阻塞IO，Java或C#会为它们创建后台线程吗？或者底层的操作系统对它们有本机支持？
浏览 3提问于2012-05-11得票数 18
回答已采纳
2回答
我在玩IOCP。我正在尝试写一个简单的应用程序，它异步地从主线程的文件中读取数据。然而，我在ReadFileEx函数中得到了错误(ERROR_INVALID_PARAMETER)，但看起来我做得很好。我做错了什么？下面是我的示例：
#include "stdafx.h"
#include <windows.h>
#include <assert.h>
#include <stdint.h>
VOID CALLBACK ReadCb(DWORD dwErrorCode,DWORD dwNumberOfBytesTransfered,LPOVE
浏览 1提问于2012-03-13得票数 1
回答已采纳
如果一个线程在向IO写入数据时被阻塞，CPU是否需要在此IO操作完成之前随时给予该线程？
如果是的话，为什么CPU要放弃呢？
如果没有，除了“每个线程堆栈”之外，还有什么东西使得“每个线程的请求”在重载下不像“共享线程的非阻塞IO”那样好呢？
PS:我读过很多关于这个话题的问题&我找不到一个能解决这个问题的答案。
浏览 1提问于2018-05-29得票数 5
回答已采纳
我正在尝试开发一个应用程序，其中多个用户登录并同时完成投票。
在这种情况下，一旦用户提交答案，事务就会运行以递增给定答案的计数器
try {
DocumentSnapshot freshsnap = await tx.get(reff);
try {
await tx.update(reff, <String, dynamic>{
'$i': freshsnap['$i'] + 1,
});
} catch (error) {
浏览 30提问于2019-11-26得票数 2
2回答
将查询与领域链接
、、
我有以下几个类：
import io.realm.RealmList;
import io.realm.RealmObject;
import io.realm.annotations.PrimaryKey;
public class A extends RealmObject {
@PrimaryKey
private String id;
private String name;
private RealmList<AB> relations = new RealmList<>();
...
}
public class
浏览 0提问于2016-03-29得票数 0
1回答
你好，我在运行modelsim时有问题。我创建的16位计算器，可以操作加，减，倍，除法计算。输入和输出是20位bcd代码。首先，我将输入的bcd代码转换为二进制代码.经过二进制计算后，我将二进制代码转换为bcd代码。我不应该在verilog代码中使用*‘’、‘/’、‘%’、‘<’、‘>’、‘<<’和‘>>>’.这是我的计算器代码
module calculator_p(
input wire [3:0] a,
input wire clk,
input wire rst, //key0
input wire result, //sw9
inpu
浏览 6提问于2021-12-05得票数 0
在这种Vert.x (生成的)服务代理测试中，我做错了什么：
@RunWith(VertxUnitRunner.class)
public class MinecraftTest {
@Rule public RunTestOnContext contextRule = new RunTestOnContext();
@Rule public Timeout timeoutRule = Timeout.seconds(7);
@Test
public void testWhenCommand(TestContext testContext) {
浏览 1提问于2018-06-06得票数 1
1回答
如果Node还使用libuv中的I/O线程来执行IO，那么当它收到简单I/O请求时，该线程与IIS创建的线程有什么不同？
浏览 2提问于2016-12-15得票数 0
回答已采纳
1回答
Introduction
为了实现分布式系统，我正在学习c++和boost/asio，所以我需要创建一个异步的tcp服务器。服务器的工作方式类似于回显服务器，但是您需要首先发出请求(例如，通过套接字发送文本)，而服务器只需要响应pi号。
Tcp-用于主服务器类的连接类
class tcp_connection
: public boost::enable_shared_from_this <tcp_connection> {
public:
typedef boost::shared_ptr<tcp_connection>
浏览 1提问于2015-07-23得票数 0
回答已采纳
下面的Google参考页面说：“如果消息不能传递，就不会返回错误”：
相反，Socket.IO对消息进行了ack回调，以便您可以处理成功/错误：。
有人建议使用通道API来达到同样的目标吗？否则，Channel API只对易失性消息很有用。我也不愿重新发明轮子，试图通过为消息传递编写事务性系统来实现这一效果。
浏览 1提问于2014-03-12得票数 1
回答已采纳
我正在学习perl中的非阻塞io。我有下面的脚本，我试图以非阻塞的方式写入文件。
这样做对吗？如果不是，正确的方法是什么？我很难模拟一个瞬间不会发生的写，所以我不能真正测试它是否有效。
use strict;
use warnings;
use POSIX qw(:errno_h);
open(my $fh, ">>", "b.txt") or die "$! \n";
my $buffer = "aaaaaaaaaaaaaaaaaaaaaaa\n";
my $rv = syswrite($fh, $buffe
浏览 6提问于2015-02-20得票数 1
回答已采纳
3回答
我正在测试作为分布式计算框架的可行性。这似乎是可行的，但我想知道如何在一个给定的筒仓中设置最大的活性谷物数量？
我的谷物将不完全是CPU绑定，并将执行一些IO和其他相关的任务。我担心，如果我任由它狂野，它会旋转大量的例子，这将使整个事情陷入泥潭。
像这样的筒仓配置可能吗？
浏览 0提问于2015-07-10得票数 3
回答已采纳
我想通过boost::asio原始套接字发送TCP消息。我的数据包基于以下来源：
我检查了IP和TCP数据包生成器的二进制输出，这些消息看起来是有效的。此外，TCP的原始套接字函数看起来也不错。
45 10 00 28 00 00 40 00
40 06 A5 18 08 08 08 08
0B 0B 07 01 11 AD 15 B3
00 00 17 AA 00 00 00 00
50 02 10 00 3E BD 00 00
无论如何，如果我通过send_to函数将其发送到套接字，则会收到以下错误：
send_to: Einültiges的论点
英文翻译：“使用无效的论点”
我不
浏览 2提问于2016-06-13得票数 0
回答已采纳
1回答
在Rust中，似乎有一种常见的成语是生成一个线程来阻止IO，这样您就可以使用非阻塞通道了：
use std::sync::mpsc::channel;
use std::thread;
use std::net::TcpListener;
fn main() {
let (accept_tx, accept_rx) = channel();
let listener_thread = thread::spawn(move || {
let listener = TcpListener::bind(":::0").unwrap();
浏览 2提问于2015-06-18得票数 10
我有这样的代码：
await Task.Factory.StartNew(
() => Parallel.ForEach(
urls,
new ParallelOptions { MaxDegreeOfParallelism = 2 },
async url =>
{
Uri uri = new Uri(url);
string filename = System.IO.Path.GetFileName(uri.LocalPath);
usin
浏览 2提问于2016-01-17得票数 4
回答已采纳
1回答
我计划开发一个有很多属性的模型的应用程序。这些属性将是应用程序中最重要的部分之一，因此用户将在大多数时间触发搜索查询，以找到他们正在寻找的结果。
我的问题是，是否可以在mysql或postgres上转发它，还是应该从solr、elasticsearch之类的东西开始。
我希望这个应用程序在执行这些搜索时不要占用大量内存，。这是我想要的第一件事，因为我将从一个2核和4gb内存的基本服务器设置开始。
浏览 1提问于2015-04-05得票数 0
回答已采纳
1回答
cpp_netlib文档包含示例HTTP客户端，但我看到它只在阻塞模式中工作。
http_client::response response = client.get(request);
--这(我猜)将在等待服务器响应时停止程序执行。我可以使用执行多个并发请求而不产生多个线程吗？我指的是一种非阻塞方式，类似于io_service.poll()的周期性调用和使用回调处理程序来捕获响应，以及等待响应时的一些额外处理。
浏览 4提问于2010-11-11得票数 0
回答已采纳
我正在使用一个简单的web客户端从web服务中检索一些XML，我将其封装在一个简单的try，catch块中(捕获WebException)。如下所示；
try
{
WebClient client = new WebClient();
client.DownloadStringCompleted += new DownloadStringCompletedEventHandler(client_DownloadStringCompleted);
client.DownloadStringAsync(new
浏览 0提问于2011-11-03得票数 6
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
