深入解析线程同步中WaitForSingleObject的超时问题

DWORD dwWaited = WaitForSingleObject(g_hToStopEvent, 100);

// 监听线程改进
DWORD dwAdaptiveWait = CalculateOptimalWaitTime(); // 动态计算等待时间
DWORD dwWaited = WaitForSingleObject(g_hToStopEvent, dwAdaptiveWait);

if (dwWaited == WAIT_OBJECT_0) {
    SetEvent(g_hAlreadyStopedEvent);
    
    // 缩短恢复等待时间，添加超时处理
    dwWaited = WaitForSingleObject(g_hContinueRecvEvent, 500);
    if (dwWaited == WAIT_TIMEOUT) {
        RecoverCommunication(); // 自动恢复逻辑
    }
}

// 主线程改进
bool SafeSendCommand() {
    for (int i = 0; i < 3; i++) { // 最多重试3次
        SetEvent(g_hToStopEvent);
        
        DWORD dwWaited = WaitForSingleObject(g_hAlreadyStopedEvent, 500);
        if (dwWaited != WAIT_TIMEOUT) {
            return SendCommand(); // 发送指令
        }
        
        TRACE("第%d次重试...", i+1);
    }
    return false;
}

void InitSerialPortTimeout(HANDLE hPort) {
    COMMTIMEOUTS timeouts;
    timeouts.ReadIntervalTimeout = 20; 
    timeouts.ReadTotalTimeoutMultiplier = 1;
    timeouts.ReadTotalTimeoutConstant = 50;
    SetCommTimeouts(hPort, &timeouts);
}