Блог

Я пишу программу, у которой есть общая «очередь» строк:

• 2 или 3 потока возвращаются в очередь
• Поток пользовательского интерфейса выводит строку из очереди каждые 0,5 — 1 секунду. (Поток пользовательского интерфейса означает CWnd::OnTimer)

Один из потоков записи очень часто отталкивает строку назад. (Строка на самом деле является журналом, который генерируется по 5-10 строк в секунду.)

Я добавляю следующий кодовый снип об объяснении выше.

 class Logger {
    std::mutex m_mutex;
    std::list<std::string> m_queLogs;
public:

    int info(std::string zLog) {
        std::lock_guard<std::mutex> lk(m_mutex);

        m_queLogs.push_back(std::move(zLog));
        ...
    }

    std::string popLog() { //!!!!! Do I need to add a lock_guard here?
        if (m_queLogs.size() == 0)
            return "";

        auto zLog = m_queLogs.front();
        m_queLogs.pop_front();

        return zLog;
    }
}

// Thread 1
int TcpComm::OnRecv(int opCode, char* buf) {

    switch (opCode) {
    case CODE_LOG:                      // generated nearly Real-time 
        Logger::instance()->info(buf);

        break;
        ...
    }
    ...
}

// Thread 2
void MonitorThread(LPVOID lpvoid) {
    while (1) {
        Sleep(60 * 1000);               // generated some times.

        Logger::instance()->info(" ---- monitor signal --- ");
        ...
    }
}


// UI Thread
void CLogView::OnTimer(UINT_PTR nIDEvent)
{
    // every 500 milisecond.
    auto zLog = Logger::instance()->popLog();
    CString strLog = convert_utf8_to_cstring(zLog);

    m_ctrLogView.AppendString(strLog);
}
 

Строки m_queLogs ar никогда не удаляются, только отодвигаются назад в письменных потоках.
Только поток пользовательского интерфейса выводит журнал из m_queLogs .

Я думаю , что нет никаких проблем без блокировки Logger::popLog() , но не уверен, что в случае увеличения частоты регистрации.

Пожалуйста, помогите мне принять решение.

ДА. Считыватель должен быть заблокирован, чтобы избежать записи, которая не имеет последовательности по отношению к чтению, что может привести к неопределенному поведению.

Может быть полезно изучить структуру данных неблокирующей очереди. Я думаю, что нескольким писателям нужно заблокировать, но читателя можно заставить ждать бесплатно. Но имейте в виду, что бесплатное ожидание не обязательно означает эффективность.