#ifndef _CONDITION_H_
#define _CONDITION_H_

#include <pthread.h>
#include <time.h>
#include "common.h"

typedef struct condition
{
	pthread_mutex_t mtx;
	pthread_cond_t 	cond;
	
}Condition_t;

/*
* @brief 初始化互斥锁和条件变量
*/
int condition_init(Condition_t *cond);

/*
* @brief 互斥锁上锁
*/
int condition_lock(Condition_t *cond);

/*
*@brief 互斥锁解锁
*
*/
int condition_unlock(Condition_t *cond);

/*
*@brief 条件变量等待
*/
int condition_wait(Condition_t* cond);

/*
*@brief 条件变量超时等待
*
*/
int condition_timedwait(Condition_t* cond, const struct timespec *absTime);

/*
*@brief 通知条件变量成立
*
*/
int condition_signal(Condition_t * cond);

/*
* @brief 广播通知条件变量成立
*/
int condition_broadcast(Condition_t *cond);

/*
*@brief 销毁条件变量和互斥锁
*/
int condition_destroy(Condition_t * cond);


#endif