nonblocking

1热度

1回答

如何使用getline而不阻塞输入？

有没有方法可以调用getline()，如果没有给出输入，不要阻止和等待？ 我有以下代码： while(true){ if(recv(sd, tBuffer, sizeof(tBuffer), MSG_PEEK | MSG_DONTWAIT) > 0) break; getline(cin,send); } 我想等待输入，但如果我在sd插口接收的一些数据，我想停下等待数据并

c++ nonblocking getline 2017-01-09

---

1热度

1回答

在f中使用fgets（）作为非阻塞调用是否安全？

从这个post这听起来像fgets()意味着是一个阻塞调用，但是，this手册页显示，如果设置为非阻塞，它将返回NULL和errno将EWOULDBLOCK如果没有数据已准备好被读取，因此我的假设是，确实有可能将它用作非阻塞。 我知道select()和朋友，我只想知道它是否安全地使用它作为非阻塞？如果不是，这些原因是什么？

c fgets nonblocking 2017-02-28

---

0热度

1回答

NCURSES调用睡眠时的键盘输入

我试图使用ncurses来创建一个游戏。我把它设置成通过箭头键输入来移动角色，但是如果我按住箭头键一段时间，然后放开角色，在停止之前角色会继续移动一段时间。 这些都是我的初始化： initscr(); start_color(); cbreak(); noecho(); nodelay(stdscr,TRUE); keypad(stdscr, TRUE); 这是我的主循环： whil

c++ input sleep nonblocking ncurses 2017-01-15

---

5热度

1回答

无阻塞Scrapy管道到数据库

我有一个Scrapy中的网页抓取工具，可以获取数据项。我想异步地将它们插入到数据库中。 例如，我有一些插入项目到我的数据库使用SQLAlchemy的核心事务： def process_item(self, item, spider): with self.connection.begin() as conn: conn.execute(insert(table1).value

python sqlalchemy scrapy twisted nonblocking 2017-03-06

---

1热度

1回答

pipe2（...）vs pipe（）+ fcntl（...），为什么不同？

我正在尝试构建一个可重新分发的二进制文件，以便放在只有libc 2.3的旧NAS上。所以pipe2（）不可用这台机器上，但我试图建立的代码有以下行： if (pipe2(info_pipe, O_CLOEXEC | O_NONBLOCK) < 0) goto info_pipe_err; 我的理解是，之所以pipe2（）存在被采取避免竞争条件O_CLOEXEC | O_NONBLOC

c sockets pipe nonblocking 2017-02-01

---

0热度

2回答

在Netty/Ratpack中使用json流数据

我想使用Netty或Ratpack来使用json数据流。我的用例是请求主体将包含大型json数据（以MB为单位的json数组）。处理数据的一种方式是阻塞直到接收到完整的数据，然后开始处理。但是，只要接收到一个json对象块就可以对其进行异步处理。 我在Netty中遇到了JsonObjectDecoder，但是我没有使用它。 这里是我ChannelInitializer类： public class

stream netty nio nonblocking ratpack 2017-02-01

---

1热度

2回答

客户端如何在长时间运行的休息调用中处理延期结果

我正在学习使用spring mvc/boot进行休眠。我了解基本的休息电话，但我无法理解长时间运行/非阻塞休息电话。 据我所知，有长时间运行的REST调用我们启动一个单独的线程和服务器返回DeferredResult对象客户，但如何完成的处理线程时，会通知客户端？ 有人可以给我提供关于如何处理这种在客户端的例子吗？ 又如何非Java客户端可以处理这样的请求？

java spring rest nonblocking 2016-12-24

---

0热度

1回答

通过Java编写和读取对象NIO非阻塞SocketChannels

我是新来的Socket编程，我正在尝试编写一个简单的聊天应用程序。我的服务器利用字符串HashSet来存储用户名信息，我想通过HashSet从服务器到客户端。我可以在ObjectOutputStream和ObjectInputStream之前通过常规套接字进行此操作。不过，现在我使用SocketChannel并不允许这样做，我得到以下异常： java.nio.channels.IllegalBlo

java sockets asynchronous nio nonblocking 2017-02-17

---

0热度

1回答

套接字：非阻塞关机（SHUT_WR）？

是否有办法异步执行关闭套接字（SHUT_WR）？ I.e.开始操作，然后等待它完成使用民意调查？

sockets nonblocking shutdown 2017-02-20

---

1热度

1回答

为什么进程0不从自身接收数据？

我刚刚开始学习MPI，我得到的问题的原因并不清楚。 #include <stdio.h> #include <stdlib.h> #include <assert.h> #include <mpi.h> int main(int argc, char *argv[]) { int myRank, size; double myLeftBound, myRightB

c mpi blocking nonblocking 2017-02-25

---