- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
我无法从 epoll 文档中理解这一点:假设我有 pipe(fd)
所以我们有 fd[0]
用于读取和 fd[ 1]
用于书写。我们向 fd[1]
写入一些内容,然后将其关闭:
write(fd[1], "abc", 3);
write(fd[1], "def", 3);
close(fd[1]);
可能同时,我们创建一个 epoll 实例,告诉它等待直到它可以从 fd[0]
读取,一旦它读取 3 个字节。
int epoll_fd = epoll_create(10);
struct epoll_event ev;
ev.events = EPOLLIN;
ev.data.fd = fd[0];
epoll_ctl(epoll_fd, EPOLL_CTL_ADD, fd[0], &ev);
struct epoll_event event;
epoll_wait(epoll_fd, &event, 1, -1);
char buffer[100];
read(fd[0], buffer, 3);
现在我们再次调用epoll_wait
。即使管道已关闭,内核仍应缓冲 3 个字节供我们从 fd[0]
读取,是吗?所以我希望以下内容能够工作(即不阻塞):
epoll_wait(epoll_fd, &event, 1, -1);
read(fd[0], buffer, 3); // buffer should start with "def" now
现在管道中什么都没有了,写入端也关闭了。如果我第三次 epoll_wait
会发生什么?
epoll_wait(epoll_fd, &event, 1, -1); // will this block indefinitely?
read(fd[0], buffer, 3);
我有两段不同的代码似乎都在这里表示不同的答案,所以我想知道应该发生什么以更好地破译正在发生的事情。
最佳答案
正在关闭的管道的写端应该用返回 0 的 read() 发出信号。
假设:
那么你最后的 epoll_wait 应该不会阻塞,下面的 read() 应该返回 0。
(并且记得检查 read() 返回的字节数是您假设它返回的字节数)
关于c - epoll_wait-ing 在封闭管道的读取端的预期行为是什么?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/19871556/
我正在考虑基于 epoll 编写一个 tcp 服务器. 为了获得最佳性能,我也想实现多核支持。但在我的研究过程中,出现了以下问题: 叫两个更快吗epoll_wait() - 来自两个不同线程的调用,每
使用epoll_wait时,它似乎会“吃掉”写入stdout的所有内容,并延迟打印,直到epoll_wait收到事件之后,即使我尝试在调用与 epoll 相关的任何内容之前进行打印(它甚至可能位于我的
我有一个 Connection 对象,代表一个由 epoll 管理的连接。在发生事件时,调用 Connection::eventWrite() 或 Connection::eventRead()。连接
epoll_wait() 的第二个参数是大小为 sizeof (struct epoll_event) * 调用者期望(或监视)的事件总数(文件描述符)的缓冲区。在第一次传递给 epoll_wait(
我的应用程序在 epoll_wait 中等待的时间比我在超时中指定的时间长得多: 22578 09:33:46.959791 epoll_wait(5, 22578 09:33:50.010794
我已经编写了一个简单的 TCP 服务器套接字并将 fd 添加到 epoll_cntl。客户端连接后,accept fd也被添加到epoll_cntl中。 当客户端关闭时,我通过 epoll_wait
请原谅我的长篇文章。我会发布代码,以便更容易理解我面临的问题。似乎如果将信号套接字添加到 epoll 实例,则 epoll 实例上的 epoll_wait 不会阻塞。下面的例子让我相信了这一点: #i
我的应用程序使用 epoll_wait 来执行定时等待 IO 事件。如果没有事件发生,epoll_wait 应该在超时后返回并且我的应用程序继续。 在测试期间,有人将系统时钟调慢了一天,我的应用程序中
我正在使用一个多线程嵌入式应用程序,其中 epoll 用于其中一个线程中的 IO。我依赖于 epoll 的一个特定功能,该功能指定关闭文件描述符会自动将其从 epoll 集中删除(man 7 epol
int epoll_wait(int epfd, struct epoll_event *events, int maxevents, int timeout); 我对 maxevents 参数有点困
When successful, epoll_wait(2) returns the number of file descriptors ready for the requested I/O, o
所以我有一些看起来像这样的代码: for (;;) { errno=0; epoll_event e = {}; auto wait_r = epoll
我有两次调用 event_wait。 线程 1:监听来自子进程的管道 struct epoll_event *ev; struct EpollStub stub[poo
所以....我很困惑为什么我的基于 epoll 的 tcp 服务器随机挂起 epoll_wait,然后在我用 SIGINT 终止时向某些连接发送一个空数组。 事实证明,我的软件中有一个随机错误,导致我
1) 我有 epoll_wait(..., events, ...) 循环,我需要在每次迭代前重新初始化 events 数组吗? 2) 根据epoll() 手册例子没有必要,是不是搞错了? 3) 我还
我无法从 epoll 文档中理解这一点:假设我有 pipe(fd) 所以我们有 fd[0] 用于读取和 fd[ 1] 用于书写。我们向 fd[1] 写入一些内容,然后将其关闭: write(fd[1]
当我使用此命令检查页面执行时,我面临着较长的 epoll_wait 时间。 strace -o output.txt -f -r -s4096 -p 21605 输出是一个很大的txt文件,但
我有一个线程负责轮询各种fds。我正在使用设置了超时的 epoll_wait。以下是代码片段: do { n = epoll_wait(epollFd, eventsList, eventsT
我正在使用 C++ 和 pthreads 进行一些事件处理。我有一个从我定义的事件队列中读取的主线程,以及一个填充事件队列的工作线程。队列当然是线程安全的。 工作线程有一个文件描述符列表,并创建一个
如果 epoll_wait 被任何原因(例如 SIGINT)中断,我想处理 while ( true ) { n = epoll_wait ( epoll_fd, events, max_ev
我是一名优秀的程序员,十分优秀!