3

我有应用程序，它定期（通过计时器）检查一些数据存储。
像这样：

#include <iostream>
#include <cerrno>
#include <cstring>
#include <cstdlib>
#include <sys/fcntl.h>
#include <unistd.h>

// EPOLL & TIMER
#include <sys/epoll.h>
#include <sys/timerfd.h>

int main(int argc, char **argv)
{
    /* epoll instance */
    int efd = epoll_create1(EPOLL_CLOEXEC);

    if (efd < 0)
    {
        std::cerr << "epoll_create error: " << strerror(errno) << std::endl;
        return EXIT_FAILURE;
    }

    struct epoll_event ev;
    struct epoll_event events[128];

    /* timer instance */
    int tfd = timerfd_create(CLOCK_MONOTONIC, TFD_CLOEXEC);

    struct timespec ts;
    // first expiration in 3. seconds after program start
    ts.tv_sec = 3;
    ts.tv_nsec = 0;

    struct itimerspec new_timeout;
    struct itimerspec old_timeout;

    bzero(&new_timeout, sizeof(new_timeout));
    bzero(&old_timeout, sizeof(old_timeout));

    // value
    new_timeout.it_value = ts;

    // no interval;
    // timer will be armed in epoll_wait event trigger
    new_timeout.it_interval.tv_sec =
    new_timeout.it_interval.tv_nsec = 0;

    // Add the timer descriptor to epoll.
    if (tfd != -1)
    {
        ev.events = EPOLLIN | EPOLLERR /*| EPOLLET*/;
        ev.data.ptr = &tfd;
        epoll_ctl(efd, EPOLL_CTL_ADD, tfd, &ev);
    }

    int flags = 0;
    if (timerfd_settime(tfd, flags, &new_timeout, &old_timeout) < 0)
    {
       std::cerr << "timerfd_settime error: " << strerror(errno) << std::endl;
    }

    int numEvents = 0;
    int timeout = 0;
    bool checkTimer = false;
    while (1)
    {
        checkTimer = false;
        numEvents = epoll_wait(efd, events, 128, timeout);
        if (numEvents > 0)
        {
            for (int i = 0; i < numEvents; ++i)
            {
                if (events[i].data.ptr == &tfd)
                {
                    std::cout << "timeout" << std::endl;
                    checkTimer = true;
                }
            }
        }
        else if(numEvents == 0)
        {
            continue;
        }
        else
        {
            std::cerr << "An error occured: " << strerror(errno) << std::endl;
        }

        if (checkTimer)
        {
            /* Check data storage */
            uint64_t value;
            ssize_t readBytes;
            //while ( (readBytes = read(tfd, &value, 8)) > 0)
            //{
            //    std::cout << "\tread: '" << value << "'" << std::endl;
            //}
            itimerspec new_timeout;
            itimerspec old_timeout;
            new_timeout.it_value.tv_sec = rand() % 3 + 1;
            new_timeout.it_value.tv_nsec = 0;
            new_timeout.it_interval.tv_sec =
            new_timeout.it_interval.tv_nsec = 0;
            timerfd_settime(tfd, flags, &new_timeout, &old_timeout);
        }
    }

    return EXIT_SUCCESS;
}

这是对我的应用程序的简单描述。每次超时后，计时器需要在每次超时时重新设置一些不同的值。

问题是：

  1. 是否需要将 timerfd 添加到带有 EPOLLET 标志的 epoll (epoll_ctl) 中？
  2. 每次超时后是否需要读取timerfd？
  3. 是否有必要无限等待epoll_wait（超时= -1）？
4

2 回答 2

5

您可以在两种模式之一（边沿触发或电平触发）中执行此操作。如果您选择边缘触发路线，那么您必须通过EPOLLET并且不需要timerfd在每次唤醒后阅读。您收到一个事件的事实epoll意味着一个或多个超时已经触发。或者，您可以阅读，它将返回自您上次阅读以来timerfd已触发的超时数。

如果你选择了水平触发的路线，那么你不需要通过EPOLLET，但你必须timerfd在每次唤醒后阅读。如果您不这样做，那么您将立即再次被唤醒，直到您消耗时间为止。

您应该作为超时或一些正值传递-1给。epoll如果你通过0了，就像你在示例中所做的那样，那么你将永远不会入睡，你只会旋转等待触发时间。这几乎可以肯定是不受欢迎的行为。

于 2012-09-19T09:48:57.220 回答
0

问题的答案：

  1. 是否需要将 timerfd 添加到带有 EPOLLET 标志的 epoll (epoll_ctl) 中？

不会。添加EPOLLET（边缘触发）确实会改变接收事件的行为。如果没有EPOLLET，您将不断收到来自epoll_wait与 相关的事件，timerfd直到您read()来自timerfd。使用EPOLLET，您将不会收到超出第一个事件的其他事件，即使发生了新的到期，直到您read()从 开始timerfd并且发生了新的到期。

  1. 每次超时后是否需要读取timerfd？

是的，以便在发生新到期时（见上文）继续并接收事件（仅）。不使用定期计时器（仅单次到期）时不，并且您关闭timerfd而不阅读。

  1. 是否有必要无限等待epoll_wait（超时= -1）？

不，您可以使用epoll_wait' 超时代替timerfd。timerfd我个人认为它比继续计算下一个超时更容易使用EPOLL，特别是如果您期望多个超时间隔；当超时发生时，密切关注您的下一个任务是什么，因为它与唤醒的特定事件相关联时会容易得多。

于 2020-09-19T05:49:01.420 回答