标签：c-3 linux events concurrency condition-variable

我试图在waitpid()和read()中等待一个真正的循环.具体来说,我正在等待这两个事件中的任何一个,然后在循环的每次迭代中处理它.目前,我有以下实现(这不是我想要的).

while (true) {
  pid_t pid = waitpid(...);
  process_waitpid_event(...);

  ssize_t sz = read(socket, ....);
  process_read_event(...);
}

该实现的问题在于第二事件的处理取决于第一事件的完成.我不想按顺序处理这两个事件,而是希望处理循环的每次迭代中首先出现的事件.我该怎么做？

解决方法:

如果您不想触摸线程,可以将其包含在waitpid调用的选项中：

pid_t pid = waitpid(pid, &status, WNOHANG);

从waitpid的联机帮助页：

WNOHANG – return immediately if no child has exited.

因此,如果waitpid没有准备好,它将不会阻塞,程序将继续前进到下一行.

至于读取,如果它是阻塞的,你可能想看看poll(2).你基本上可以检查你的套接字是否在每个设定的时间间隔内就绪,例如250ms,然后调用read.这将使它不会阻止.

您的代码可能看起来像这样：

// Creating the struct for file descriptors to be polled.
struct pollfd poll_list[1];
poll_list[0].fd = socket_fd;
poll_list[0].events = POLLIN|POLLPRI;
// POLLIN  There is data to be read
// POLLPRI There is urgent data to be read

/* poll_res  > 0: Something ready to be read on the target fd/socket.
** poll_res == 0: Nothing ready to be read on the target fd/socket.
** poll_res  < 0: An error occurred. */
poll_res = poll(poll_list, 1, POLL_INTERVAL);

这只是假设您正在从套接字读取,从代码中的变量名称判断.正如其他人所说,你的问题可能需要像线程一样更重要的东西.

标签：c-3,linux,events,concurrency,condition-variable
来源： https://codeday.me/bug/20190623/1266701.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。