mirror of
https://gitee.com/acl-dev/acl.git
synced 2024-12-14 00:40:55 +08:00
91 lines
2.0 KiB
C++
91 lines
2.0 KiB
C++
/**
|
||
* Copyright (C) 2017-2018 IQIYI
|
||
* All rights reserved.
|
||
*
|
||
* AUTHOR(S)
|
||
* Zheng Shuxin
|
||
* E-mail: zhengshuxin@qiyi.com
|
||
*
|
||
* VERSION
|
||
* Tue 22 Aug 2017 11:20:34 AM CST
|
||
*/
|
||
|
||
#pragma once
|
||
#include "../acl_cpp_define.hpp"
|
||
#if !defined(_WIN32) && !defined(_WIN64)
|
||
# include <pthread.h>
|
||
# ifndef acl_pthread_cond_t
|
||
# define acl_pthread_cond_t pthread_cond_t
|
||
# endif
|
||
#else
|
||
struct acl_pthread_cond_t;
|
||
#endif
|
||
|
||
namespace acl {
|
||
|
||
class thread_mutex;
|
||
|
||
/**
|
||
* 线程条件变量
|
||
*/
|
||
class ACL_CPP_API thread_cond
|
||
{
|
||
public:
|
||
/**
|
||
* 构造方法
|
||
* @param mutex {thread_mutex*} 当该参数非 NULL 时，内部自动引用该线程锁，
|
||
* 否则，内部创建线程锁
|
||
*/
|
||
thread_cond(thread_mutex* mutex = NULL);
|
||
~thread_cond(void);
|
||
|
||
/**
|
||
* 等待线程条件变量就绪
|
||
* @param microseconds {long long} 等待条件变量就绪的超时时间(微秒级)
|
||
* > 0 时表示等待超时的时间
|
||
* == 0，不等待
|
||
* < 0 则一直等待直到条件变量就绪
|
||
* @param locked {bool} 当构造参数传入的线程锁非空时，该参数表示外部
|
||
* 传入的线程锁是否已经被外部调用者锁住，如果已经被锁住，则内部将不
|
||
* 再对构造中传入的外部锁加锁，否则，内部将会加锁外部锁，函数返回前
|
||
* 再解外部锁；此外，如果构造参数传入线程锁为空时，内部会自动先加内
|
||
* 部锁，函数返回前再解内部锁
|
||
* @return {bool} 返回 true 表示条件变量就绪，否则表示超时或没被通知
|
||
*/
|
||
bool wait(long long microseconds = -1, bool locked = false);
|
||
|
||
/**
|
||
* 通知一个或几个等待在线程条件变量上的线程，表示条件变量就结
|
||
* @return {bool} 返回 false 表示通知失败
|
||
*/
|
||
bool notify(void);
|
||
|
||
/**
|
||
* 通知所有等待在线程条件变量上的线程，表示条件变量就结
|
||
* @return {bool} 返回 false 表示通知失败
|
||
*/
|
||
bool notify_all(void);
|
||
|
||
/**
|
||
* 获得与该线程条件变量绑定的线程互斥锁
|
||
* @return {thread_mutex&}
|
||
*/
|
||
thread_mutex& get_mutex(void) const;
|
||
|
||
/**
|
||
* 获得系统类型的线程条件变量对象
|
||
* @return {acl_pthread_cond_t*}
|
||
*/
|
||
acl_pthread_cond_t* get_cond(void) const;
|
||
|
||
private:
|
||
thread_mutex* mutex_;
|
||
thread_mutex* mutex_internal_;
|
||
acl_pthread_cond_t* cond_;
|
||
|
||
bool wait(bool locked);
|
||
bool timed_wait(long long microseconds, bool locked);
|
||
};
|
||
|
||
} // namespace acl
|