首先介绍windows的一个基本函数：
HANDLE CreateEvent(
LPSECURITY_ATTRIBUTES lpEventAttributes, // 安全属性
BOOL bManualReset, // 复位方式
BOOL bInitialState, // 初始状态
LPCTSTR lpName // 对象名称
);lpEventAttributes： 一个指向 SECURITY_ATTRIBUTES 结构的指针，确定返回的句柄是否可被子进程继承。如果lpEventAttributes是NULL，此句柄不能被继承。
Windows NT/2000：lpEventAttributes的结构中的成员为新的事件指定了一个安全符。如果lpEventAttributes是NULL，事件将获得一个默认的安全符。
如果是TRUE，表示是手动重置事件，那么必须用ResetEvent函数将事件的状态复原到无信号状态。
如果设置为FALSE，表示自动重置，当事件被一个等待线程释放以后，系统将会自动将事件状态复原为无信号状态。
bInitialState： [输入]指定事件对象的初始状态。如果为TRUE，初始状态为有信号状态；否则为无信号状态。 lpName： [输入]指定事件的对象的名称，是一个以0结束的字符串指针。名称的字符格式限定在MAX_PATH之内。名字是对大小写敏感的。 如果lpName指定的名字，与一个存在的命名的事件对象的名称相同，函数将请求EVENT_ALL_ACCESS来访问存在的对象。这时候，由于bManualReset和bInitialState参数已经在创建事件的进程中设置，这两个参数将被忽略。如果lpEventAttributes是参数不是NULL，它将确定此句柄是否可以被继承，但是其安全描述符成员将被忽略。 如果lpName为NULL，将创建一个无名的事件对象。内核对象名冲突：如果lpName的和一个存在的信号、互斥、等待计时器、作业或者是文件映射对象名称相同，函数将会失败，在GetLastError函数中将返回ERROR_INVALID_HANDLE。造成这种现象的原因是这些对象共享同一个命名空间。
相关方法：
PulseEvent()是一个比较有意思的使用方法，正如这个API的名字，它使一个Event对象的状态发生一次脉冲变化，从无信号变成有信号再变成无信号，而整个操作是原子的。对自动复位的Event对象，它仅释放第一个等到该事件的thread（如果有)，而对于人工复位的Event对象,它释放所有等待的thread。
类Signal进一步封装事件操作，用于同步和互斥
通过枚举类型Result定义了事件的等待结果
SIGNAL_TIMEOUT： 事件未触发，但是已超时
SIGNAL_SET： 事件被触发
SIGNAL_ERROR： 出错
定义了事件的相关操作：等待事件和触发事件
等待事件：WaitFor
触发事件：Set
struct signalData; //为下文定义的一个封装了事件操作的结构体
class Signal
{
public:
enum Result { SIGNAL_TIMEOUT, SIGNAL_SET, SIGNAL_ERROR };
Signal(bool broadcast = false);
virtual ~Signal();
virtual Signal::Result WaitFor(SAFMQ_INT32 timeoutmilliseconds);
virtual void Set();
private:
signalData *data;
};
//定义信号结构体数据
struct signalData {
signalData(bool broadcast) {
event = ::CreateEvent(NULL, broadcast? TRUE:FALSE , FALSE , NULL);
}
~signalData() {
::CloseHandle(event);
}
Signal::Result wait(SAFMQ_INT32 timeoutmilliseconds) {
DWORD result;
if (timeoutmilliseconds < 0)
result = ::WaitForSingleObject(event, INFINITE); //表示一直等待，直至事件被通知
else
result = ::WaitForSingleObject(event,timeoutmilliseconds);
if (result == WAIT_OBJECT_0) //事件收到通知
return Signal::SIGNAL_SET;
else if (result == WAIT_TIMEOUT) //事件未收到通知，超时
return Signal::SIGNAL_TIMEOUT;
return Signal::SIGNAL_ERROR;
}
void set() {
::PulseEvent(event);
}
HANDLE event;
};
Signal::Signal(bool broadcast)
{
data = new signalData(broadcast);
}
Signal::~Signal()
{
delete data;
}
Signal::Result Signal::WaitFor(SAFMQ_INT32 timeoutmilliseconds)
{
return data->wait(timeoutmilliseconds);
}
void Signal::Set()
{
data->set();
}