nonblocking

3热度

2回答

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

0热度

1回答

将同步方法转换为非阻塞算法

只需找到一些关于非阻塞算法的信息，所以想要在实践中使用它们。我将一些代码从同步更改为非阻塞，所以我想问一下我是否做得正确并保存了以前的功能。同步代码： protected AtomicReference<PersistentState> persistentState; protected ClassConstructor(final ID id) { supe

0热度

1回答

玩！框架：通过WS

限制并发非阻塞IO调用我一直在使用Play！Framework的WS来进行网络调用。假设我在范围内的自定义ExecutionContext中有5个线程。如果我要阻止网络呼叫，最多可以处理5个并行请求，因此我可以明确限制网络呼叫的数量。当使用WS时，情况并非如此。它将使网络调用超出5个线程，因为它不会阻塞进行WS请求的自定义池。我所观察到的是，我可以根据需要提出尽可能多的请求，并最终压倒OS资

2热度

2回答

连接到套接字时似乎无法获取超时工作

我试图提供connect（）的超时。我搜索了四处，发现了几篇与此相关的文章。我已经编写了我认为应该工作的内容，但不幸的是，我没有从getsockopt（）中报告错误。但是当我来写（）它失败，错误107 - ENOTCONN。几点。我正在Fedora 23上运行。connect（）的文档表示，它应该返回失败，并返回EINPROGRESS的errno，但对于尚未完成的连接，但是我遇到了EAGAIN，

0热度

2回答

nodeJS等待不能promisified的事件

我试图从我的nodejs文件中读取STDIN PIPE并发出一个POST请求到一个URL，每行给出fom STDIN然后等待响应，读取下一行，发送，等待等 'use strict'; const http = require('http'); const rl = require('readline').createInterface(process.stdin,null); rl.on('

0热度

1回答

使用系统调用选择与文件

我试着写与系统调用select单线程非阻塞程序。但是，使用文件处理程序不能很好地工作。下面是代码： import sys import select while True: file_handler = open('filename.txt') inputs = [file_handler, sys.stdin] try: _input, _out

0热度

1回答

为什么带有ZMQ_DONTWAIT的zmq_recv（）返回一个errno == 0而不是EAGAIN？

我正在使用ZeroMQ来编写一个小测试应用程序。我有一个测试场景是当没有服务器运行连接到。所以，我路过ZMQ_DONTWAIT到zmq_recv()在该方案中预期的EAGAIN一个错误，但不是获取的0 样品的客户端代码如下errno值： int rc; void *context = zmq_ctx_new(); void *requester = zmq_socket(context,

1热度

1回答

如何使用非阻塞套接字连接（）？

在Python中，我想在我设置为非阻塞的套接字上使用socket.connect()。当我尝试这样做时，该方法总是抛出一个BlockingIOError。当我忽略错误（如下）时，程序按预期执行。在连接后将套接字设置为非阻塞状态时，没有错误。当我使用select.select（）来确保套接字是可读或可写的时，我仍然得到错误。 testserver.py import socket import s

1热度

1回答

什么时候send（）会返回EWOULDBLOCK？

我正在使用主要使用select（）超时阻塞套接字的应用程序，但是使用Write函数，我正在使用send（）的非阻塞套接字。我只需要知道，在什么（和所有）情况下会发送（）返回EWOULDBLOCK/EAGAIN？

0热度

1回答

非阻塞套接字连接总是成功？

如果之前有人问过这个问题，我很抱歉。我正在编写一个使用选择多路复用的非阻塞套接字客户端。让我困惑的一件事是，无论服务器在线还是离线，无阻塞连接都会成功。我搜索了很多帖子，并遵循他们的解决方案，但没有一个在我的linux ubuntu机器上工作。 static void callback_on_select_write(int connect_fd) { // Client write