只允许启动一个线程答案

【问题标题】：Allow start ONLY one thread只允许启动一个线程
【发布时间】：2023-01-16 19:09:15
【问题描述】：

我们如何安全地只启动一个 WorkerThread？
存在它的设计模式吗？

实际上我是这样做的，看来我有点过于复杂了。

void CLogView::OnStartStoplogger()
{
    m_bLogPtRun = !m_bLogPtRun;    // (bool)
    if (m_bLogPtRun)
    {
        // First check, if Thread is still running
        if (!m_pLogPointThread) 
        {
            m_pLogPointThread = AfxBeginThread(AddLogPointThread, this);
        }
        else
           return;   // Thread still running
    }
    else
    {   
      if (m_pLogPointThread )
      {
         if (m_pLogPointThread) {
           DWORD dwRET = WaitForSingleObject(m_pLogPointThread->m_hThread, /*INFINITE*/ 5000);
           if (dwRET != WAIT_OBJECT_0)
             MessageBox(_T("Could not finished LogPointThread"));
      }
}

【问题讨论】：

旁注：std::thread 更易于使用 MFC 线程 api。它也是 C++ 标准。它有一个join 方法可以代替你的WaitForSingleObject。
此外，您的 if (!m_pLogPointThread) m_pLogPointThread = ... 支票也不安全。另一个线程可以在if条件检查和创建线程之间启动线程。
您正在编写代码 - 为什么要担心启动多个线程？似乎不太可能。
另一种选择是使用 std::async/std::future 或 C++20 std::jthread，它们具有更好的 RAII 行为，这意味着 std::future 或 std::jthread 的析构函数会为您执行同步/连接。此外，当您使用线程时，了解std::mutex/std::scoped_lock，它们将帮助您避免race-conditions
另外，if (m_bLogPtRun) { ... } else { m_bLogPtRun = false; ... } 有点疯狂。

标签： c++ mfc

【解决方案1】：

好的，下面是一个示例，假设您创建了一个工作线程，它将一直运行到应用程序退出。用户可以暂停和恢复数据检索和记录。不需要为此使用 APC，如 cmets 中所述，而是使用同步来控制工作线程。我提议的同步对象是手动重置事件。它充当“同步布尔值”，由主 (UI) 线程设置和清除 - 如果它未发出信号，工作线程将等待它。

1.变量和初始化

BOOL bInitOK = FALSE;  // Worker Thread Successfully Initialized
BOOL bChkRTD = FALSE;  // Retrieval & Logging of RTD Enabled
HANDLE m_hEvt = CreateEvent(NULL, TRUE, FALSE, TRUE); // Controlling Retrieval & Logging of RTD
CWinThread *m_pLogPointThread = AfxBeginThread(AddLogPointFN, this); // Worker Thread - Created once

请注意这里的AddLogPointFN是AFX_THREADPROC函数，不是类。这将创建一个没有消息队列的线程。此外，您不需要定义和使用任何线程本地数据（即每个线程实例化的数据），因为线程将只实例化一次，即您的数据本质上是“全局的”（尽管它们可能包含在另一个线程中单实例类，如主窗口或视图）。或者，您可以使用 CreateThread() 函数和 LPTHREAD_START_ROUTINE 创建线程 - 这个是 _stdcall。该事件控制工作线程是否检查数据；它有点“复制”由用户设置的bChkRTD 变量——事件是可等待对象，而布尔变量不是。

2. 线程程序

UINT AddLogPointFN(LPVOID lParam)
{
    // CLogView* variable - For convenience
    CLogView* pView = (CLogView*)lParam; // Assuming lParam is CLogView

    // Add one-time, resource-heavy initialization here, eg connections
    .
    .
    bool bInit = InitConnections();

    if (!bInit)
    {
        // Initialization Failed - Tell UI to display an error-message or exit
        pView->PostMessage(USERMESSAGE_ALPNOTIFY, 1); 
        return 1;
    }
    
    // Initialization Successful - Tell UI to enable RTD request menus or buttons
    pView->PostMessage(USERMESSAGE_ALPNOTIFY, 2);

    // Wait if m_hEvt is non-signalled
    while(WaitForSingleObject(pView->m_hEvt,INFINITE)==WAIT_OBJECT_0)
    {
        // Retrieve RTD
        .
        .
        // Data retrieved, tell UI to update
        pView->PostMessage(USERMESSAGE_ALPNOTIFY, 3, (LPARAM)p_Data);
    }
    return 0;
}

RTD 检索是通过等待事件对象来控制的。该事件是手动重置的，即等待函数不会重置它 - 它仅由 UI 线程设置/重置。该线程不会直接修改（全局）bInitOK 变量（这需要同步访问），而是通知 UI 线程进行设置。

3. 主线程项和例程

// Start/Stop Command and UI Update
void CLogView::OnStartStoplogger()
{
    bChkRTD = !bChkRTD; // Check-box behavior, see also ON_UPDATE_COMMAND_UI
    if (bChkRTD) SetEvent(m_hEvt);
    else ResetEvent(m_hEvt);
}

void CLogView::OnUpdateStartStoplogger(CCmdUI *pCmdUI)
{
    pCmdUI->Enable(bInitOK);    // Enabled if Initialization Successful
    pCmdUI->SetCheck(bChkRTD);  // Checked if RTD Retrieval Enabled
}

// USERMESSAGE_ALPNOTIFY Handler
afx_msg LRESULT CLogView::OnALPNotify(WPARAM wParam, LPARAM lParam)
{
    switch(wParam)
    {
        case 1: // Initialization Failed - Show some message or exit
            .
            .
            break;
        case 2: // Initialization Successful - Enable Start/Stop UI item
            bInitOK = TRUE;
            break;
        case 3: // New RTD Available - Display the data
            // E.g. copy the date returned from the worker thread to some local structure
            CopyMyData(m_pMyData, (MY_DATA*)lParam);
            GlobalFree((HGLOBAL)lParam)
            UpdateData(FALSE);
            break;
    }
}

【讨论】：