Многопоточный Observer на С++ (практика)

>>uintptr_t
Не особо критично, но пожалуй (хотел было заменить на что-то типа size_t, но решил оставить так).

>>Пока вы писали линейный поиск шесть раз, вам в голову не пришло хранить вектор отсортированным?
Тони Хоар впервые произнёс, а Дональд Кнут впоследствии часто повторял известное высказывание:
«Преждевременная оптимизация — это корень всех бед».
Википедия — Оптимизация

>>Поздравляю, вы изобрели read/write lock! Читайте:
Расскажите пожалуйста по-подробней, каким именно образом нужно применить shared_mutex
для решения проблемы с deadlock-ом в приведенном примере?

Я приводил пример с оконной процедурой, возможно получилось не особо внятно…
Функция Subscribe/Unsubscribe вызывается в обработчике оконного сообщения (например по таймеру), и при этом рабочий поток вызывает в цикле функцию Observer::SendMessage(), а реализация MessageHandler() шлет окну сообщение, к примеру даже WM_SETTEXT.

В общем получается что-то вроде этого:

Observer::CDispatcher g_Dispatcher;
DWORD WINAPI WorkingThread(PVOID)
{
    for(;;)
    {
        g_Dispatcher.SendMessage(NULL);
    }
    return 0;
}
...
class CMainDlg : public Observer::CSubscriber
{
private:
    bool m_bSubscribed;
public:
    //Subscriber interface
    virtual void MessageHandler(void* pContext)
    {
        SetWindowText(L"Deadlock test");
    }
    LRESULT OnTimer(UINT, WPARAM, LPARAM, BOOL& bHandled)
    {
        if(m_bSubscribed)
        {
            g_Dispatcher.Unsubscribe(this->GetSubscriberId());
            m_bSubscribed = false;
        }
        else
        {
            g_Dispatcher.Subscribe(this);
            m_bSubscribed = true;
        }
        bHandled = TRUE;
        return 0;
    }
    LRESULT OnInitDialog(UINT, WPARAM, LPARAM, BOOL&)
    {
        m_bSubscribed = false;
        ::CreateThread(NULL, 0, WorkingThread, NULL, 0, NULL);
        SetTimer(0, 1);
        ...
    }
...
}