在 Libevent 中,待处理事件和活动事件有什么区别?



我正在学习如何使用Libevent。但我不明白挂起和活动之间的区别。在我看来,当一个事件被添加到event_base中,而该事件没有发生时,它处于挂起状态,而调用者等待的事件发生了,然后处于活动状态,对吗?Hoever,当我读到event_pending的描述时,看到代码被炸了,它说当事件挂起时,改变它的内部状态是不好的,我认为这里的"挂起"一词被误解了,它应该是"event_active"。。。。我错了吗?

#include <event2/event.h>
#include <stdio.h>
/* Change the callback and callback_arg of 'ev', which must not be
 * pending. */
int replace_callback(struct event *ev, event_callback_fn new_callback,
    void *new_callback_arg)
{
    struct event_base *base;
    evutil_socket_t fd;
    short events;
    int pending;
    pending = event_pending(ev, EV_READ|EV_WRITE|EV_SIGNAL|EV_TIMEOUT,
                        NULL);
    if (pending) {
        /* We want to catch this here so that we do not re-assign a
         * pending event.  That would be very very bad. */
        fprintf(stderr,
            "Error! replace_callback called on a pending event!n");
        return -1;
    }
    event_get_assignment(ev, &base, &fd, &events,
                     NULL /* ignore old callback */ ,
                     NULL /* ignore old callback argument */);
    event_assign(ev, base, fd, events, new_callback, new_callback_arg);
    return 0;
 }

挂起事件意味着一些触发的操作和事件回调的执行在event_base中排队。

活动事件意味着事件回调是当前执行的当前线程或其他线程(不要忘记,您可以操作来自其他线程的事件,即不运行事件循环)

重新分配挂起的事件不是线程安全操作,您可以在事件.c.中看到它

我认为,若编写单线程应用程序,那个么在任何时候重新分配事件都是安全的。

libevent图书报价(http://www.wangafu.net/~nickm/libfevent-book/Ref4_event.html):

一旦调用Libevent函数来设置事件并将其与事件库相关联,它就会初始化。在这一点上,您可以添加,这将使它在基础中挂起。当事件挂起时,如果触发事件的条件发生(例如,其文件描述符更改状态或超时到期),则该事件变为活动事件,并运行其(用户提供的)回调函数。

因此,libevent术语中的"挂起"意味着"刚刚添加到reactor中"。无需操作触发即可获得挂起的事件。我已经用一个简单的程序检查了这种行为:

#include <stdio.h>
#include <unistd.h>
#include <assert.h>
#include <event.h>
void read_cb( int sock, short which, void *arg )
{
    printf( "read_cb() calledn" );
    fflush( stdout );
    // while our callback is running event is active
}
int main()
{
    struct event_base *base = event_base_new();
    int fd[ 2 ];
    assert( pipe( fd ) == 0 );
    struct event ev;
    event_set( & ev, fd[ 0 ], EV_READ | EV_PERSIST, read_cb, NULL );
    event_base_set( base, & ev );
    assert( event_add( & ev, NULL ) != -1 );
    // it's pending now, just after adding
    printf( "event_pending( ... ) == %dn", event_pending( & ev, EV_READ, NULL ) );
    fflush( stdout );
    event_base_loop( base, EVLOOP_ONCE );
    return 0;
}

输出:

event_pending(…)==2

相关内容

  • 没有找到相关文章

最新更新