我有一个试图读取的客户机/服务器应用程序。从客户端读取数据时，它是异步完成的。客户端的async_read似乎正在失败。
我认为，在服务器执行相应的async_read之前，我的客户端正在尝试使用async_write (不完全确定)。我在这里的问题是概念性的：
在服务器端对套接字执行相应的async_read之前，我可以进行async_write吗？
我不确定(现在不能尝试)，但是这种套接字(阻塞/非阻塞)似乎改变了1的行为。
如果我想使用非阻塞套接字，我如何async_read当我知道有数据可用？bytes_readable或类似的是我正在寻找的？
非常感谢。我很想确认
浏览 3提问于2016-07-12得票数 0
1回答
我使用非阻塞发送和ReceiveAsync接收.
var r = new SocketAsyncEventArgs();
r.Completed += _receiveArgs_Completed;
r.SetBuffer(new byte[chunkSize], 0, chunkSize);
Client.Client.ReceiveAsync(r); // return value check omitted
void _receiveArgs_Completed(object sender, SocketAsyncEventArgs e)
{
if (e.SocketErro
浏览 3提问于2014-11-13得票数 0
回答已采纳
1回答
现在似乎每个人都在谈论反应性应用程序，而反应性宣言似乎鼓励非阻塞/异步代码。我在youtube上看到了很多视频，演讲者鼓励非阻塞代码，但是没有人说写非阻塞代码比阻止其他代码更有好处。
"using futures is good because it is not blocking your code" - some speaker
这只是让“阻塞代码”听起来像是个糟糕的词。
我的问题很简单：，如果我有一个任务，并且我运行它时：
阻塞代码-在其中运行一个线程上的任务
非阻塞代码-其中一个线程将任务委托给另一个线程。
事实上，在上述两种情况下，我要运行的实际任务总
浏览 3提问于2015-10-20得票数 5
回答已采纳
1回答
我有一个同步客户端，如何制作这个异步客户端？客户端正确连接，然后写入通道，然后等待(没有密钥准备好，因为没有任何东西可以从通道读取)，现在我希望它再次开始写入通道，如何实现这一点？谢谢
public class Client {
static class SocketTest implements Runnable {
private Selector selector;
private int sessionID = 0;
int port;
String address;
private List
浏览 0提问于2013-12-17得票数 0
试图为自己总结这两个概念之间的区别(因为当我看到人们在一个句子中同时使用这两个概念时，我真的很困惑，比如“非阻塞异步IO”，我试图弄清楚这意味着什么)。
因此，在我的理解中，非阻塞IO是处理IO的主要OS机制，如果有任何数据准备就绪，否则只需返回error/什么都不做。
在异步IO中，您只需提供一个回调，当数据可用时，应用程序将被通知。
那么什么是“非阻塞异步IO”呢？以及如何在Java (标准JDK，没有外部库的情况下，我知道有java.nio.channels.{Channels, Selector, SelectorKey}和java.nio.channels.{Asynchronous
浏览 5提问于2014-08-02得票数 86
回答已采纳
我在MSDN文档()上读到了这篇文章，这似乎意味着在我的代码中调用SendAsync方法之后，我仍然需要等待，下面粘贴了这个方法。这是对的吗?如果是的话，那么我最好使用同步方法发送而不是。我的目标是进入循环中的下一封电子邮件并发送它，而不等待上一封邮件被发送，这将使我能够更快地处理emailMessages集合，而不是使用send方法。但这似乎不是真的。
调用SendAsync后，必须等待电子邮件传输完成后，才能尝试使用send或SendAsync发送另一条电子邮件。
我正在使用C#和.Net框架4.5。在我的代码中，我试图在一个循环中发送多封电子邮件，如下面使用SendAsync方法
浏览 4提问于2012-12-08得票数 0
回答已采纳
在中，Haller谈到Scala异步。
在中，Rich谈到了Clojure的core.async。
两者似乎都是宏-但是Scala异步(如果我错了就纠正我)似乎没有CSP或通道的概念。
Scala异步和Clojure的core.async之间有什么区别？
浏览 4提问于2013-11-23得票数 6
回答已采纳
在介绍nio之前，我认为非阻塞和异步概念是相同的。
但是，如果在nio中它明确地分开，我认为它是不同的东西。现在我真的不明白区别了。我读过很多关于它的信息，但是这个信息使我感到困惑。
示例：
asynchronous -对堆栈溢出的标记描述：
异步编程只是允许在单独的线程上执行部分代码。它使您的应用程序执行得更好，响应性更强，并最大限度地使用它们正在运行的系统的资源。
这个概念在没有并发和多线程的情况下有意义吗？
在另一些地方，我发现线程和异步是不相关的东西--我的大脑是颠簸的。
因此，nonblocking标签还有另一个比我想的更有意义的东西(但我不确定)。
使用没有通常互斥原语的
浏览 2提问于2014-08-14得票数 2
我想澄清一下在Scala Play中使用Scala的未来进行异步/同步和阻塞/非阻塞操作意味着什么。
所以我们可以：
异步和非阻塞
异步阻塞
同步与非阻塞
同步与阻塞
在Play文档中，它说所有的操作都是异步的。但我想知道如何分类如下：
如果我调用了一个外部web服务，并且必须等待响应，那么这是否被认为是一个异步和阻塞操作？例如：
def externalWebCall(url : String): Future[SomeData]
def storeData(data : String) : Future[Unit]
for {
data <- externa
浏览 1提问于2019-08-25得票数 1
在使用asyncio.start_server()测试服务器程序时，该方法似乎没有调用第一个client_connected_cb方法。当程序在测试之外单独运行时，它将按预期的方式工作。我怀疑这与没有正确处理事件循环有关。
为了进行测试，我有一些非异步代码连接到套接字服务器，当侦听套接字时，套接字服务器将无限期挂起。
为什么事件循环不处理单元测试中的服务器代码？
测试：
@pytest.mark.asyncio
async def test_connect(server, connection):
await server.start()
connection.connect(
浏览 0提问于2018-03-21得票数 0
回答已采纳
2回答
有人能告诉我，在不阻塞/等待结果的情况下，使用Spring的@Async注释有什么方法吗？下面是一些代码来澄清我的问题：
@Service
public class AsyncServiceA {
@Autowired
private AsyncServiceB asyncServiceB;
@Async
public CompletableFuture<String> a() {
ThreadUtil.silentSleep(1000);
return asyncServiceB.b();
}
}
@
浏览 1提问于2017-03-29得票数 5
回答已采纳
5回答
从node.js的角度来看，所有代码都是非阻塞的。
在Go中，使用通道很容易实现非阻塞。
如果你正在用go编写一个node.js类型的服务器，让它成为非阻塞的有意义吗？例如，让数据库connect()函数返回一个通道，而不是在等待连接发生时阻塞。
在我看来，这似乎是正确的方法。
但是..。
浏览 2提问于2011-06-13得票数 45
回答已采纳
1回答
仅仅因为使用java.nio的优点，在下面这样的代码中，会有什么东西是完全不阻塞的吗？
def writeOutputFile(fileText: String, outDir: String, fileName: String) {
import java.nio.file.{Path, Paths, Files}
import java.nio.charset.StandardCharsets
Files.write(Paths.get(outDir + "/" + fileName), fileText.getBytes(StandardCharsets.
浏览 1提问于2015-03-13得票数 1
test = function(x){
if ( some conditions ) { return true; }
else { return false; }
}
if (test(y)) {document.write("You have done this before!")};
console.log("Checked!");
目的是检查用户过去是否执行了某些操作。这些只是模拟代码，并不能真正反映我实际上在做什么。
问题：
我是node.js的新手，所以如果这听起来微不足道，请原谅我。假设测试(Y)为真。我能确定co
浏览 3提问于2012-06-29得票数 1
回答已采纳
我正在阅读Java中的多线程服务器和其中的通信。我有一个以上的疑问：“同步与异步和阻塞与非阻塞IO之间有什么区别。它们都谈到相同的概念吗？”
浏览 4提问于2021-04-05得票数 0
回答已采纳
如果Node的密码模块是否被阻塞了，谁能给我一些澄清吗？据我所理解，一些核心模块可以在c++中生成一个单独的线程。
我主要感兴趣的是：
crypto.createHmac
crypto.createSign
crypto.createVerify
如果它确实在单独的线程上进行处理，那么就可以了。如果不是，那么我可能不得不考虑使用集群模块。我试图避免阻塞主事件循环。
下面是我如何实现crypto.createHmac的一个简单例子。
function createHmac(algo, secret, data, callback) {
var cryptoStream =
浏览 6提问于2014-12-20得票数 4
回答已采纳
当我运行以下代码时，它会运行并打印(“侦听，将您的应用程序连接到")，并作为web服务器等待请求。在web服务器模式下，我希望LED闪烁，这也是我应用asyncio的原因。
但是，除非它接收到任何请求(在web服务器中激活While True:循环)，否则它不会响应。我已经尝试了很多方法，但我无法找到一种方式切换LED在web服务器模式。您可以在下面的代码中看到关于await asyncio.sleep(20)的注释：
import uasyncio as asyncio
from machine import Pin
import time
LED_PIN = 13
led = P
浏览 1提问于2018-02-01得票数 3
回答已采纳
我看到集群方法在部署不同的整个过程时非常清楚。我想专业程序员制作"worker_threads“库是有原因的.但我仍然需要澄清这一点，让我理解：
在普通单线程进程事件循环线程的帮助下，默认工作池卸载其繁重的I/O任务，因此主线程不会被阻塞。
同时，用户定义的“工作线程”将基于相同的原因使用他们自己的事件循环和NodeJS实例。
当这些事件循环和Nodejs实例不是瓶颈时，产生这些事件循环和Nodejs实例的意义是什么，因为libuv的目的是设法生成工作人员。
这是否意味着默认的员工池可能不够？我指的是数量问题还是概念？
浏览 0提问于2020-04-21得票数 5
回答已采纳
当使用带有文件描述符的POSIX AIO时，是否需要在open()中使用O_NONBLOCK打开文件描述符
在APUE中，我没有明确地说是或不是，但在一个示例中，我没有发现在open()中使用O_NONBLOCK打开这样的文件描述符。
谢谢。
浏览 6提问于2018-09-01得票数 0
我刚刚学到了更多关于异步等待的知识。我以前认为异步任务方法中的所有东西都是在后台线程上执行的。现在我明白了，情况并非如此，我开始重构我的一些代码，以便减少对我的UIThread (WPF)的阻塞。
这是我的“正常”异步方法：
public async Task<List<Data>> DoSomethingAsync(){
var data = dbContext.Data.ToListAsync(); // <- Executes on a background thread internally
... // <- Executes on
浏览 5提问于2020-11-20得票数 0
1回答
ASP.NET异步等待
、、、
我有一个ASP.NET应用程序。我正在加载测试，并且通过使用外部工具运行并发请求来阻止线程池中的所有线程。由于网络上的I/O请求，所有线程都会被阻塞，并且这样做的方法是用异步和等待关键字实现的。我在另一个控制器中也有另一个方法，它只返回一个字符串，也就是说，第二个方法不执行I/O。
问题是:即使所有线程都在执行asyn /O，对这个非阻塞方法的所有请求不都应该被服务吗？
浏览 3提问于2015-09-17得票数 1
回答已采纳
问题1：
tornado.httpserver是一种非阻塞的http服务器。是否有阻塞的http服务器？
问题2：
异步总是意味着非阻塞吗？同步总是意味着阻塞吗？
问题3：
tornado.curl_httpclient和tornado.simple_httpclient是否是非阻塞的，也称为异步的？
浏览 1提问于2016-11-18得票数 0
我有一个程序，可以无限期地寻找我的问题的最佳解决方案。我让用户决定它可以运行什么时间来找到解决方案，一旦花费了这段时间，程序就会停止，创建一些日志文件，打印一些调试数据，并显示找到的最佳解决方案。
现在，如果用户不想等到终端结束，我希望允许他在终端中提示一些消息，让他提前停止程序。
多亏了，我在python中找到了如何做到这一点，并在考虑是否可以在OCaml中使用相同的体系结构。
理想情况下，我应该有两个线程：
(* ___ Main thread ___ *)
start_program_thread();
Printf.printf "prompt `kill` to stop t
浏览 3提问于2021-11-27得票数 2
回答已采纳
4回答
我正在读“使用Java的操作系统概念”。我被阻塞和同步的概念弄糊涂了，它们之间有什么区别？
浏览 1提问于2011-12-07得票数 31
回答已采纳
1回答
开始-接收没有看到到达的数据
、、、、
我的TCP客户端在接收数据时会阻塞。
建立联系
客户端发送21个字节。(见第5段)
接下来，客户端上的BeginReceive调用永远不会调用回调。当我强迫它调用EndReceive时，它永远挂起。IsCompleted = false。
有些数据是在#5之后到达的，但问题是它永远不会到达我的应用程序。TcpClient.Available返回135。
客户端可以发送数据，但没有从服务器接收任何信息。
客户端使用Mono2.6在Unity3D中运行。我只能通过第一次发布内部统一编辑器来复制它。第二次，它开始的很好，但却是随机的(外部编辑也是)。
为什么会发生这种事
浏览 1提问于2014-11-12得票数 1
回答已采纳
所以我对python非常陌生，我基本上是在尝试制作一个程序，用户输入一个目标IP，然后按下一个按钮来执行命令(启动点击过程)，这我已经成功地完成了，但是现在我想在下面添加一个退出按钮来停止点击过程，但是我遇到了一个问题。该按钮在您按execute之前工作正常(按预期工作，它关闭应用程序窗口)，但是当脚本运行时，该按钮根本不工作，只是使窗口崩溃，但使命令继续运行。如何使按钮在任何时候都能工作(在脚本运行时使其工作)。
import tkinter as tk #import tkinter and tkinter library
from tkinter import ttk #package
浏览 11提问于2022-09-07得票数 0
1回答
我一直在阅读，发现这句话令人困惑：
请注意，您可能因此受到诱惑，将阻塞代码包装在“期货”中。这并不使它成为非阻塞的，它只是意味着阻塞将发生在不同的线程中。您仍然需要确保所使用的线程池有足够的线程来处理阻塞。
我当时的印象是，所有这些非阻塞库都在自己的线程池中执行阻塞操作，并返回Future对象，这样客户端代码就不会阻塞。
但这句话说它并不能使它成为非阻塞的。我是不是遗漏了什么？有什么先进的魔法和非阻塞的唇语？
浏览 6提问于2016-12-19得票数 10
回答已采纳
当我尝试在该套接字中接收数据时，我似乎总是得到这种特殊情况。套接字是一个有效的套接字，并且也建立了连接，并且总是有一些数据周期性地进入特定的端口。但是一些recv函数是如何产生这个错误的。任何可能的原因。
下面是示例代码。
提前感谢
struct hostent *hdata; // Used when Node name is converted to IP-Address
struct sockaddr_in insock; // Socket address str
浏览 2提问于2009-09-01得票数 0
回答已采纳
1回答
通过管道将输入/输出传送到进程
、、、、
我有一些困难使我的管子工作。我有以下代码：
/* Set security attributes */
sa.nLength = sizeof(SECURITY_ATTRIBUTES);
sa.bInheritHandle = TRUE;
sa.lpSecurityDescriptor = NULL;
if (CreatePipe(&Rread, &Rwrite, &sa, 0) == 0 || SetHandleInformation(Rread, HANDLE_FLAG_INHERIT, 0) == 0 || CreatePipe(&Wread, &a
浏览 0提问于2012-08-16得票数 0
回答已采纳
rxjs转换方法在可观察到的运行中是同步的还是异步的？
例如，在角2中，http获取、req和map对JSON对象的响应：
this.http.get('some/url').map(res => res.json());
如果我必须解析2MiBJSON并存储它(例如Pouchdb)，该怎么办？这些操作是否以后台非阻塞方式运行？否则，如何实现这些操作的异步行为。
谢谢你的澄清！
浏览 10提问于2016-11-02得票数 0
回答已采纳
我如何做到这一点:我有一些潜在的长时间的计算(例如，要解析为http的大型JSON。)并且希望以一种非阻塞的方式来实现。
我尝试采用库来做后台工作，使用web worker。这个库要求JSON可序列化对象传递给不知道闭包、DOM或任何其他全局变量的执行函数。例如：MT.process(longRunningJob, doneCallback)(jsonSerializableArgForBGJob)。但是这个库太旧了(3年前的最后一次提交)。有没有更好的替代方案，更适合angular2？我需要瞄准最广泛的浏览器，包括较旧的浏览器(IE/Edge除外)，因此服务工作者或库可能不会使用它。
对于序
浏览 0提问于2016-11-08得票数 1
1回答
有人知道如何使Spring数据REST端点异步吗？
我看到我们可以在服务方法上添加带有CompletableFuture<?>的注释@Async作为返回对象。但这样做会使接口RepositoryRestResource的使用变得毫无意义，因为我们需要手动实现服务层和控制器层……
还是我错过了什么？
浏览 12提问于2020-05-12得票数 0
回答已采纳
据我所知，是同步的，并阻塞线程直到web客户端接收到响应，而Spring是异步和非阻塞的。
但是，如果我们在@异步带注释的方法中使用RestTemplate调用API呢？
它是否阻止了@异步创建的新线程？
最后，您对Rest的异步调用有什么建议(不使用WebClient，因为我使用的是早于5的Spring版本)。谢谢
浏览 5提问于2021-01-10得票数 2
回答已采纳
我试图理解HystrixCommand和HystrixObservableCommand之间的区别。我之所以感到困惑，是因为HysterixCommand还有一个toObservable()方法，它们分别发出可观察到的热和冷。那么，创建HystrixObservableCommand的必要性是什么呢？如果我要完全处理非阻塞电话，我应该使用哪一个？为什么？
浏览 5提问于2016-02-23得票数 8
回答已采纳
3回答
在对Java进行了大量搜索之后，我对以下问题感到非常困惑：
为什么我要选择异步方法而不是多线程方法？
Java 应该是非阻塞的.非阻塞是什么意思？当从Future中提取信息的方法--即get()--正在阻塞并且只会停止整个线程直到该方法完成处理时，为什么称之为非阻塞？也许是一种回调方法，当处理完成时，它会敲响完成的钟声？
如何使方法异步？方法签名是什么？
公共列表databaseQuery(字符串查询，String[] args){ String preparedQuery =QueryBaker(查询，args)；List listOfNumbers = DB_Exec(prep
浏览 8提问于2016-03-27得票数 7
回答已采纳
1回答
我想创建一个python套接字(或SocketServer)，一旦连接到单个设备，它就会维护一个打开的连接，以便定期检查是否发送了任何数据。套接字将只侦听一个连接。
例如：
def get_data(conn):
response='back atcha'
data = conn.recv(1024)
print 'get_data:',data
if data:
conn.send(response)
s = open_socket()
conn, addr = s.accept()
while True:
浏览 0提问于2013-03-14得票数 0
6回答
如果我以os.open( '/dev/ttyS2', O_RDWR | O_NDELAY )打开一个文件，有没有什么方法可以检查我的“write()”命令何时完成？或者，我可以打开一个非阻塞读但是阻塞写的文件吗？
浏览 0提问于2010-10-05得票数 0
回答已采纳
4回答
PHP可以异步使用套接字吗？
、、、、
典型的PHP套接字功能是同步的，并在等待传入的连接和数据时暂停线程。(例如，和)
我如何异步地做同样的事情？因此，我可以在数据接收事件中响应数据，而不是轮询数据，等等。
浏览 2提问于2009-09-16得票数 20
回答已采纳
1回答
我正在寻找apache中的解决方案，以解决下面代码中的问题。在完成上一次运行之前，无法再次启动路由。
@Override
public void configure() throws Exception {
from("timer://foo?fixedRate=true&period=3s")
.routeId("teste")
.log("INIT")
.delay(5000)
.log("DELAY-END")
浏览 2提问于2020-03-10得票数 1
2回答
解释python龙卷风异步
、、、、
因此，我一直在研究如何编写异步代码，并提出了以下代码：
我有以下两个问题：
我们如何假设这段代码是异步的？我们只是要依赖这样一个事实，即使用gen模块使其成为异步(当然，我们需要为gen coroutine编写异步模块)。
为什么龙卷风包含一条主线？我们能有一个主线程链接到一个线程池，该线程池链接到另一个线程池吗？这个问题更多的是我们用一条主线来实现什么？
from tornado import gen
import tornado.web
import tornado.ioloop
import motor
class MainHandler(tornado.web.Req
浏览 0提问于2015-01-18得票数 2
使用discord.py制作一个不和谐的机器人，这是我第一次使用异步操作，也可能是我第一次在Python中遇到令人沮丧的事情。
这个问题的重点不是教我如何使用异步，而是教我如何避免使用异步，即使这不是正确的方法。
因此，我需要运行来自常规def函数的不和谐客户端协同。经过几个小时的搜索，我发现了这个：asyncio.get_event_loop().run_until_complete(...)。我设置了一个小脚本来测试它：
import asyncio
async def test():
print('Success')
asyncio.get_event_loo
浏览 21提问于2017-10-21得票数 3
回答已采纳
如何访问Mono类型的RequestBody参数。Spring Boot Webflux reactive。 我想返回一个ResponseEntity，而不是Mono。 @RequestMapping(value = "/poststudentdata", method = RequestMethod.POST, headers={"content-type=application/json"})
public ResponseEntity<String> poststudentData(@Valid @RequestBody Mono<St
浏览 74提问于2019-04-01得票数 1
我有点搞不懂怎么玩！工作在它的控制器层。一些文档说明了这一点！始终是异步和非阻塞的。所以我被Action Action.async弄糊涂了。行动受阻了吗？如果是这样，并且docs说您应该始终保持异步和非阻塞，那么应该始终在所有控制器中使用Action.async吗？你为什么不选呢？我相信这里有一些我不明白的地方，你的任何专业知识都会非常感谢你对此的理解。
浏览 3提问于2013-12-13得票数 6
回答已采纳
5回答
Node.js，是异步I/O。这到底是什么意思？
我通过派生另一个线程来创建异步函数的过程有什么不同吗？
例如：
void asyncfuntion(){
Thread apple = new Thread(){
public void run(){
...do stuff
}
}
apple.start()
}
如果有区别，我可以在javascript中进行异步I/O吗？
浏览 1提问于2011-09-29得票数 13
回答已采纳
在我们的站点中，我们包含来自远程站点的javascript，用于在远程站点的某人启动时弹出紧急横幅/窗口。如果发生全校范围的紧急情况，这是提醒每个人的一种方法。远程站点不是我们的，我们只包含对他们的js的调用：
<script src="https://embanner.univcomm.cornell.edu/OWC-emergency-banner.js" type="text/javascript"> </script>
问题:无论出于什么原因，当远程站点宕机时，我们站点中使用我们自己开发的javascript/jquery的一些页
浏览 1提问于2013-04-13得票数 0
我很好奇什么被认为是更好的风格/做某事的正确方式。
在javascript中，我可以执行以下操作：
function one() {
two(param, function(ans){
// do more work
});
}
function two(param, callback) {
var answer;
//do work
callback(answer);
}
但只要简单地返回答案，我就可以得到一个类似的结果：
function one() {
var ans = two(param);
// do mor
浏览 0提问于2013-08-09得票数 9
回答已采纳
1回答
Datastax和驱动程序都支持异步写入。这两种方法都允许设置一致性级别。一致性级别对异步写入有任何影响吗？
浏览 0提问于2015-04-27得票数 0
回答已采纳
我想并行地在多个GPU上运行内核。为此，我使用cudaSetDevice()在设备之间切换，然后在相应的设备中启动内核。现在，通常一个流中的所有调用都按顺序执行，如果要并行执行，则必须使用不同的流。在使用不同的设备时也是这样吗?或者在本例中，我可以在两个设备上的默认流上运行内核调用，并且它们仍将并行运行吗？
浏览 5提问于2016-02-14得票数 4
回答已采纳
2回答
我从彭博API中检索数据，对速度之慢感到非常惊讶。我的计算是IO的，受此限制。
因此，我决定使用一些异步monad构建器来解除它的节气。在运行它时，结果没有那么好，这是显而易见的，因为我调用了一个函数NextEvent，它是线程阻塞。
let outerloop args dic =
...
let rec innerloop continuetoloop =
let eventObj = session.NextEvent(); //This blocks
...
let seqtab
浏览 0提问于2012-03-28得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
