nonblocking

首页 > TAG信息列表 > nonblocking

WebFlux block()/blockFirst()/blockLast() are blocking, which is not supported in thread reactor-http

block()报错 WebFlux中，如果是Mono/Flux.map()或者其他方法体是属于NonBlocking线程，如果在NonBlocking线程中再调用阻塞方法(block()等)会报错 static final class NonBlockingThread extends Thread implements NonBlocking { public NonBlockingThread(Runnable targ

非阻塞http服务器,java nio,python tornado eventlet

你好我试图了解基于龙卷风/ eventlet的http服务器是否优于线程服务器.在浏览主题时,我看到它们是单线程事件基础服务器,在套接字上执行select / poll / epoll之后运行单个处理程序功能. >我的第一个问题是,这个龙卷风/事件集是否类似于Java中的nio库,并且是非阻塞且快速的Java nio

java-如何在等待响应的同时实现请求响应协议而不会阻塞？

我需要实现一个使用(双向)请求-响应协议与多个客户端同时通信的应用程序.以前,我为每个客户端使用两个专用线程(一个读取器/反应器和一个写入器/发起器)来实现此目的.问题是线程管理变得非常复杂和丑陋.是否有任何标准的处理方式,甚至可能只有一个线程,或者至少有恒定数量的线程来

Linux-STDIN_FILENO和STDOUT_FILENO的非阻塞I / O行为很奇怪

我有以下代码： void set_fl(int fd, int flags) /* flags are file status flags to turn on */ { int val; if ((val = fcntl(fd, F_GETFL, 0)) < 0) err_sys("fcntl F_GETFL error"); val |= flags; /* turn on flags */ if (fcnt

Linux,串行端口,非缓冲模式

我正在尝试在Linux中使用串行端口来组织nob阻止读写功能.这是我的代码：http://pastebin.com/RSPw7HAi 一切正常,但已缓冲.这意味着,如果我通过控制台CR符号输入到串行,则select检测到新的输入,否则,如果我通过简单的python脚本输入,它将缓冲所有符号并等待,直到我发送回车符为止.因

Java缓存超时

我们有一个简单但非常常用的缓存,由ConcurrentHashMap实现.现在,我们要定期刷新所有值(例如,每15分钟刷新一次). 我想要这样的代码： private void regularCacheCleanup() { final long now = System.currentTimeMillis(); final long delta = now - cacheCleanupL

java-在Ldap搜索上设置方法超时

private Authentication authenticateUserPassword(UsernamePasswordAuthenticationToken token) throws NamingException { Object login = login(token); LOGGER.debug("Starting authentication login='{}'", login); Object password = t

java-具有非阻塞套接字的多线程

我正在尝试使用nio在Java中实现TCP服务器. 它只是使用选择器的选择方法来获取就绪键.然后处理这些密钥(如果它们是可接受的,可读的).服务器工作正常,直到即时消息使用单个线程为止.但是当我尝试使用更多线程来处理密钥时,服务器的响应变慢,最终停止响应,例如在4-5个请求之后.这就是

javascript-遇到脚本标记时的浏览器呈现页面

阅读how browser works和浏览器rendering process之后,遇到< script>脚本时,我仍然对浏览器解析过程感到困惑标签,这些帖子并未真正覆盖. 下图描述了主要过程：假设我们有一个简单的html <html> <head> <link rel="stylesheet" href="main.css"> <script src="main.js"><

python-如何从celery任务异步调用url

我将芹菜与龙卷风一起使用,我想知道如何在任务中异步调用url. 我正在寻找以下方面的东西： @celery.task def my_task(data): def handle_response(response): if response.error: print "error" else: print "success" http_clie

c-为什么在没有作者的无限命名管道上进行选择？

我用read_fds中的单个命名管道fd调用select.该命名管道没有编写器,仅以非阻塞只读模式打开.我希望select返回带有标记为准备读取的命名管道fd的尝试,并且尝试从该管道读取的结果返回0：从联机帮助页上阅读： When attempting to read from an empty pipe or FIFO: If no process ha

java-有没有人玩过NIO管道来过滤/拦截System.out？

如建议的here,我想在选择器循环内执行此操作.我真正想要的是在选择器循环中读取写入系统的内容. EDIT1：我编写了一个完整的解决方案,只是发现您无法使用System.setOut重定向GC日志.它直接进入FD之类.显示塞子！除非我重定向到文件并将该文件通过管道传递到选择器中.很多工作！参见here.

我无缘无故写信给接收器时,NIO Pipe抛出“ Broken Pipe”！如何调试？

我相信我做的一切正确.我创建一个管道,将接收器传递到编写器线程,使用OP_READ在选择器上注册源,启动选择器.一切正常,但是一旦我向接收器写入内容,就会出现管道异常的情况.为什么!!! ???这里没有破管.我烦了.我如何调试/了解这里发生了什么？有没有人有一个简单的管道示例,我可以运行

java-如何使用带有参数的exitValue()？

一篇很好的文章(当Runtime.exec()不会)说：您唯一可能使用exitValue()而不是waitFor()的时间是当您不希望您的程序阻塞在某个外部进程上等待时,可能永远不会完成.与其使用waitFor()方法,不如将一个名为waitFor的布尔参数传递给exitValue()方法,以确定当前线程是否应等待.布尔值会更有

java – 线程中断没有结束阻塞调用输入流读取

我正在使用RXTX从串口读取数据.读取是在以下列方式生成的线程内完成的： CommPortIdentifier portIdentifier = CommPortIdentifier.getPortIdentifier(port); CommPort comm = portIdentifier.open("Whatever", 2000); SerialPort serial = (SerialPort)comm; ...settings Thread t

wxPython非阻塞GUI线程和多处理？

Python 2.7.3 x64 wxPython 2.8 x64 已经阅读了很多关于python线程和多处理的内容,特别是Doug Hellmann撰写的一些文章,这些文章有很大的帮助.但是,我对一件事感到困惑…… 我认为Python多处理模块或多或少是线程模块的直接替代品,除了args必须是可选择的,但我发现为了不阻止我的GU

java – 在准备好读取的多个套接字中进行选择

我正在编写服务器 – 客户端应用程序.我有一个服务器,它拥有我从ServerSocket的accept()方法获得的几个套接字.我想从这些套接字读取,但我不知道哪个套接字可以读取.我需要某种选择器来选择一个可以读取的套接字,所以我可以读取它发送的数据. 谢谢.解决方法:您基本上有两个选项可以

java – Spring netFlux在使用Netty与Tomcat时的不同之处

我正在学习春天的webflux,我读过以下系列文章(first,second,third) 在第三条中,我面对以下案文： Remember the same application code runs on Tomcat, Jetty or Netty. Currently, the Tomcat and Jetty support is provided on top of Servlet 3.1 asynchronous processing

Linux阻塞与非阻塞串行读取

我有从Linux中的Serial读取this code,但我不知道在读取串口时阻塞和非阻塞有什么区别,哪一个在哪种情况下更好？解决方法:您提到的代码是IMO编码和评论不佳.该代码不符合POSIX实践中的可移植性,如Setting Terminal Modes Properly和Serial Programming Guide for POSIX Operating Sys

mysql – 重构非阻塞nodejs do..while循环

我正在node.js写一个api.第一个Web服务端点 – / create – 创建一个带有随机6字符哈希的新数据库条目,非常类似于bit.ly哈希. 在PHP中做了类似的事情之后,我编写了一个do..while循环,它生成一个随机字符串并检查我的mysql db(使用node-mysql)以确保它是免费的.我在那里也有一个

linux – 为什么必须在边缘触发的epoll函数中使用非阻塞fd？

我在网上读了文件abount edge触发的epoll函数,如下所示： 1. The file descriptor that represents the read side of a pipe (rfd) is registered on the epoll instance. 2. A pipe writer writes 2 kB of data on the write side of the pipe. 3. A call to epoll_wait(2) is don

使Javascript无阻塞

在以非阻塞方式呈现Javascript时,有哪些不同的方法(效率方面的比较)？我听说过可以与script标签一起使用的defer属性.还有其他这样的方法,如果有什么比推迟有什么优势？解决方法: I’ve heard about the defer attribute that can be used with the script tag. 是的,defer and async

java – 了解非阻塞Web服务调用与非阻塞JDBC之间的区别

我试图从概念上理解为什么在Play Framework 2.0中,为Web服务调用调用WS.url().get()被认为是最佳实践,但是如果你在其中包含任何其他阻塞调用(如JDBC调用)承诺,建议您在默认执行上下文以外的执行上下文中执行此操作？据我所知,默认情况下,Play Framework的线程池配置为每个核心有一

java – 在Spring 4中运行并行线程的优雅方式

我正在开发一个API.此API需要执行2次DB查询才能获得结果. 我尝试了以下策略： >在Controller中使用可调用作为返回类型. >在Service中创建2个线程(使用Callable和CoundownLatch)并行运行2个查询并检测结束时间. public class PetService { public Object getData() { Cou

C：如何测量非阻塞套接字上的实际上传速率

我正在使用带有epoll的非阻塞套接字在linux C上编写程序,等待EPOLLOUT以便对某些数据执行send(). 我的问题是：我已经读过,在非阻塞模式下,数据被复制到内核的缓冲区,因此send()调用可能会立即返回,表明所有数据都已发送,实际上它只被复制到内核的缓冲区. 为了知道实际传输速率,我怎