event_msgqueue.h

spserver 是一个实现了半同步/半异步(Half-Sync/Half-Async)和领导者/追随者(Leader/Follower) 模式的服务器框架

/*
 * event_msgqueue.h
 *
 * Libevent threaded message passing primitives header
 *
 * Andrew Danforth <[e-mail]>, October 2006
 *
 * Copyright (c) Andrew Danforth, 2006
 *
 */

#ifndef _EVENT_MSGQUEUE_H_
#define _EVENT_MSGQUEUE_H_

#include <event.h>
#include <pthread.h>

#ifdef __cplusplus
extern "C" {
#endif

struct event_msgqueue;

struct event_msgqueue *msgqueue_new(struct event_base *, unsigned int, void (*)(void *, void *), void *);
int msgqueue_push(struct event_msgqueue *, void *);
unsigned int msgqueue_length(struct event_msgqueue *);
void msgqueue_destroy(struct event_msgqueue*);

#ifdef __cplusplus
}
#endif

#endif