Тут появилась такая задача.
На диалоге ProgressCtrl и две кнопки, определяющие в какую сторону двигать прогресс.
т.е. по нажатию на кнопку выполняется следующее:

while(m_progress.GetPos() < progress_max)
{
pCtrl->StepIt(); // В ту или иную сторону
// и какой-то код, например
Sleep(100);
}

В цикле пока значение прогресса не дойдет до крайнего значения.
Естественно, что во время выполнения цикла кнопки не доступны. А надо, чтобы во время движения прогресса можно было кнопками менять его направление.
В решении задачи нужно применить многопоточность.
Создал UI поток. И отправляю в него сообщение по нажатию кнопок
pMyThread->PostThreadMessage(WM_USER+1, (WPARAM)m_progress.m_hWnd, (LPARAM)-1/*направление*/);

afx_msg void CMyThread::HandleThreadMessage(WPARAM wParam, LPARAM lParam)
{
    direction = int(lParam);
    CWnd* wnd;
    pCtrl = (CProgressCtrl*)(wnd->FromHandle((HWND)wParam));
    pCtrl->SetStep(direction);
    
    if (direction)
    {
        int min, max;
        pCtrl->GetRange(min, max);
        while((pCtrl->GetPos() >= min)&&(pCtrl->GetPos() <= max))
        {
            pCtrl->StepIt();
            SleepEx(50, false);
        }
    }
}

Теперь кнопки доступны, но все равно поток не может принять сообщения, пока находится в цикле.

Что-то у меня уже ступор.

Или лучше сделать рабочий поток? И управлять им с помощью событий?

Вообще проще всего без всяких потоков сделать таймер (WM_TIMER) и ни каких проблем, но надо с потоком.

Здравствуйте, Аноним, Вы писали:

А>

А>while(m_progress.GetPos() < progress_max)
А>{
А>pCtrl->StepIt(); // В ту или иную сторону
А>// и какой-то код, например
А>Sleep(100);
А>}
А>

Вынеси этот цикл в рабочий поток.

Здравствуйте, dandy, Вы писали:

D>Вынеси этот цикл в рабочий поток.

В потоке придется сделать синхронизацию, например перед запуском нового потока убивать старый, если он запущен и т.п. И в качестве прарметра обычно выгоднее всего передавать указатель на оконный класс, в котором находятся нужные тебе контролы.

Здравствуйте, dandy, Вы писали:

D>В потоке придется сделать синхронизацию, например перед запуском нового потока убивать старый, если он запущен и т.п. И в качестве прарметра обычно выгоднее всего передавать указатель на оконный класс, в котором находятся нужные тебе контролы.

Спасибо, уже сделал через рабочий поток.
Но тут возникла проблема.
В потоке я жду двух событий: по одному (ManualReset) я двигаю прогресс, а по второму выхожу из потока (AfxEndThread(0); )
А в основном потоке при выходе делаю:

    ProgressEvent.ResetEvent();
    ExitEvent.SetEvent();
    WaitForSingleObject(pThread->m_hThread, INFINITE);

И тут все повисает. Насколько я понял взаимоблокировка. Как этого избежать?

Здравствуйте, KokS, Вы писали:

KS>В потоке я жду двух событий: по одному (ManualReset) я двигаю прогресс, а по второму выхожу из потока (AfxEndThread(0); )
KS>А в основном потоке при выходе делаю:

В этом случае синхронизировать лучше примерно так:
Перед созданием нового потока проверять, не работает ли уже предыдущий, проще всего по указателю на объект CWinThread, который делаешь членом класса и инициализируешь нулем в конструкторе, при создании потока присваиваешь ему возврат функции AfxBeginThread. Если указатель не нулевой, событие, по которому выходишь из потока, устанавливаешь в сигнальное состояние, какое — то время ждешь установки указателя в 0 функцией потока, выходишь из функции потока при установленном событии, при выходе из потока устанавливаешь указатель в 0. Можно еще кой — чего добавить, но для этого случая должно быть достаточно.

Здравствуйте, dandy, Вы писали:

D>В этом случае синхронизировать лучше примерно так:
D>Перед созданием нового потока проверять, не работает ли уже предыдущий, проще всего по указателю на объект CWinThread, который делаешь членом класса и инициализируешь нулем в конструкторе, при создании потока присваиваешь ему возврат функции AfxBeginThread. Если указатель не нулевой, событие, по которому выходишь из потока, устанавливаешь в сигнальное состояние, какое — то время ждешь установки указателя в 0 функцией потока, выходишь из функции потока при установленном событии, при выходе из потока устанавливаешь указатель в 0. Можно еще кой — чего добавить, но для этого случая должно быть достаточно.

Хочется понять, почему не работает мой вариант.
И как ждать установки указателя в 0? В цикле? Не красиво.

Здравствуйте, KokS, Вы писали:

KS>Здравствуйте, dandy, Вы писали:

KS>Хочется понять, почему не работает мой вариант.
Судя по всему, ты запускаешь поток при создании диалога. Запускай по нажатию кнопки, с предварительной проверкой и последующим убийством уже запущенного потока — если он уже запущен, конечно.

KS>И как ждать установки указателя в 0? В цикле? Не красиво.
Напиши Sleep(сколько_нужно) один раз. Некрасиво — да. Красиво будешь писать тогда, когда сможешь писать и красиво и правильно.

Здравствуйте, dandy, Вы писали:

D>Здравствуйте, KokS, Вы писали:

KS>>Здравствуйте, dandy, Вы писали:

KS>>Хочется понять, почему не работает мой вариант.
D>Судя по всему, ты запускаешь поток при создании диалога. Запускай по нажатию кнопки, с предварительной проверкой и последующим убийством уже запущенного потока — если он уже запущен, конечно.

На создание/завершение потока тратиться много процессорного времени, поэтому часто (как в моем случае) этого лучше не делать. Мне как раз и надо, чтобы поток создавался при создании диалога и при закрытии завершался.

KS>>И как ждать установки указателя в 0? В цикле? Не красиво.
D>Напиши Sleep(сколько_нужно) один раз. Некрасиво — да. Красиво будешь писать тогда, когда сможешь писать и красиво и правильно.

Так ведь я хочу научиться писать красиво и правильно. Потому и спрашиваю

Здравствуйте, KokS, Вы писали:

KS>На создание/завершение потока тратиться много процессорного времени, поэтому часто (как в моем случае) этого лучше не делать. Мне как раз и надо, чтобы поток создавался при создании диалога и при закрытии завершался.
При обработке нажатия на кнопку это время пренебрежимо мало.

KS>Так ведь я хочу научиться писать красиво и правильно. Потому и спрашиваю
Тогда смотри WaitForSingleObject на хендл убиваемого потока.

D>Здравствуйте, KokS, Вы писали:

Все написанное мной верно, если диалог показывается из процесса.
Если из dll, то все сложнее.

Здравствуйте, dandy, Вы писали:

D>Тогда смотри WaitForSingleObject на хендл убиваемого потока.

Я и делаю

ProgressEvent.ResetEvent();
ExitEvent.SetEvent();
WaitForSingleObject(pThread->m_hThread, INFINITE);

как я уже писал.

Но так все виснет. Как будто ExitEvent не выставляется.

В рабочем потоке:

while (1)
    {
        dwEvent = WaitForMultipleObjects(2, pst->hEvents, FALSE, INFINITE);
        switch(dwEvent)
        {
        case WAIT_OBJECT_0 + 0:
                        // код
            break;
        case WAIT_OBJECT_0 + 1: // ExitEvent
            AfxEndThread(0);
            break;
        }
    }

Здравствуйте, dandy, Вы писали:

D>Все написанное мной верно, если диалог показывается из процесса.
D>Если из dll, то все сложнее.

из процесса

Здравствуйте, KokS, Вы писали:

Твой код работать не должен.

//В потоке:
if(WaitForSingleObject(hEvent, 0) == WAIT_OBJECT_0)
{
    pDlg->pThread_ = 0;
    return 0;
}

//В обработчике:
if(this->pThread_)
{
if(WaitForSingleObject(pThread->m_hThread, сколько_надо) != WAIT_OBJECT_0) 
{
     AfxMessageBox(m_hWnd, _T("Failed to kill thread normally, there thill be a memory leaks"));
     TerminateThread(this->pThread_->m_hThread)
     this->pThread_ = 0;
}
}

примерно так.

D>//В обработчике:
D>if(this->pThread_)
D>{
// Забыл написать: тут нужно выставить событие hEvent в сигнальное состояние
D>if(WaitForSingleObject(pThread->m_hThread, сколько_надо) != WAIT_OBJECT_0)
D>{
D> AfxMessageBox(m_hWnd, _T("Failed to kill thread normally, there will be a memory leaks"));
D> TerminateThread(this->pThread_->m_hThread)
this->>pThread_ = 0;
D>}
D>}

Здравствуйте, dandy, Вы писали:

D>Твой код работать не должен.

Обьясните, пожалуйста, почему. Я просто хочу понять...

Здравствуйте, KokS, Вы писали:

KS>Обьясните, пожалуйста, почему. Я просто хочу понять...

Насколько понял, в потоке дорабатывает до этой строки:
dwEvent = WaitForMultipleObjects(2, pst->hEvents, FALSE, INFINITE);
и, как там и написано, останавливается и бесконечно долго ждет. Если непонятно, воспользуйся дебаггером.

Здравствуйте, dandy, Вы писали:

D>Здравствуйте, KokS, Вы писали:

KS>>Обьясните, пожалуйста, почему. Я просто хочу понять...

D>Насколько понял, в потоке дорабатывает до этой строки:
D>dwEvent = WaitForMultipleObjects(2, pst->hEvents, FALSE, INFINITE);
D>и, как там и написано, останавливается и бесконечно долго ждет. Если непонятно, воспользуйся дебаггером.

Но я же выставляю событие ExitEvent (оно же pst->hEvents[1])
По нему поток и должен завершаться.

Здравствуйте, KokS, Вы писали:

KS>Но я же выставляю событие ExitEvent (оно же pst->hEvents[1])
KS>По нему поток и должен завершаться.

Могу только предположить, что ты не делаешь ему ResetEvent()
Если не так, тогда выкладывай уже весь код.

Здравствуйте, dandy, Вы писали:

И INFINITE ждать не нужно, так делается только в примерах MSDN.

// *.h
    CWinThread* pThread;
    static UINT ThreadProc( LPVOID pParam );
    struct toThread 
    {
        HANDLE hEvents[2];
        HWND hProgress;
    } st;
    CEvent ProgressEvent;
    CEvent ExitEvent;

//*.cpp
// инициализация событий:
:ProgressEvent(FALSE, TRUE), ExitEvent(FALSE, TRUE)

//OnInitDialog
    st.hEvents[0] = ProgressEvent.m_hObject;
    st.hEvents[1] = ExitEvent.m_hObject;
    st.hProgress = m_progress.m_hWnd;
    pThread = AfxBeginThread(ThreadProc, &st, 0, 0, CREATE_SUSPENDED, NULL); 
    pThread->m_bAutoDelete = FALSE;
    pThread->ResumeThread();

// Функция рабочего потока
UINT C_Dlg::ThreadProc(LPVOID pParam)
{
    toThread* pst = (toThread*)pParam;
    CWnd* wnd;
    CProgressCtrl* pCtrl = (CProgressCtrl*)(wnd->FromHandle(pst->hProgress));

    DWORD dwEvent;
    while (1)
    {
        dwEvent = WaitForMultipleObjects(2, pst->hEvents, FALSE, INFINITE);
        TRACE(_T("dwEvent = %d\n"), dwEvent);
        switch(dwEvent)
        {
        case WAIT_OBJECT_0 + 0:
                        // Код, который должен выполняться циклически, пока ProgressEvent установлен, поэтому сдесь я его не сбрасываю
            break;
        case WAIT_OBJECT_0 + 1:
            ResetEvent(pst->hEvents[1]);
            AfxEndThread( 0, FALSE );
            break;
        }
    }
    return 0;
}

// Функция выхода:
void C_Dlg::Exit()
{
    ProgressEvent.ResetEvent();
    ExitEvent.SetEvent();  // Выставляю событие завершения потока, но поток его не получает  :xz: 
    WaitForSingleObject(pThread->m_hThread, 2000);  // Жду когда поток завершиться, но т.к. поток не получил ExitEvent этого не происходит
    delete pThread;
}

Здравствуйте, KokS, Вы писали:

class CManualEvent : public CEvent
{
public:
    CManualEvent() : CEvent(FALSE, TRUE) {}
};

//В классе диалога:
    static UINT ThreadProc( LPVOID pParam );
    CManualEvent ProgressEvent;
    CManualEvent ExitEvent;

// в OnInit...
    ProgressEvent.ResetEvent();
    ExitEvent.ResetEvent();
    pThread = AfxBeginThread(ThreadProc, this); 

UINT CTestKocsDlg::ThreadProc(LPVOID pParam)
{
    CTestKocsDlg * p = static_cast<CTestKocsDlg *>(pParam);

    while(1)
    {

        if(WAIT_OBJECT_0 == WaitForSingleObject(p->ProgressEvent, 200))
        {
            return 0;
        }

        if(WAIT_OBJECT_0 == WaitForSingleObject(p->ExitEvent, 0))
        {
            return 0;
        }

        // Тут делай, что нужно

    }
    return 0;
}

void CTestKocsDlg::OnDestroy() 
{
    ExitEvent.ResetEvent();
    ExitEvent.SetEvent();
    if(::WaitForSingleObject(pThread->m_hThread, 400) != WAIT_OBJECT_0)
    {
        AfxMessageBox(_T("Oops!"));
        ::TerminateThread(pThread->m_hThread, 0);
    }
    CDialog::OnDestroy();

}

Насчет WaitForMultipleObjects — не пользовал

Здравствуйте, dandy, Вы писали:

D>Насчет WaitForMultipleObjects — не пользовал

За ответ спасибо.
Но все равно хочется разобраться с WaitForMultipleObjects.
Что у меня не так? Может еще кто-нибудь подскажет?

Здравствуйте, dandy, Вы писали:

D>[ccode]
D>class CManualEvent : public CEvent
.....................


В вашем варианте этот самый Oooops тоже иногда выскакивает

Здравствуйте, KokS, Вы писали:

KS>Здравствуйте, dandy, Вы писали:

KS>В вашем варианте этот самый Oooops тоже иногда выскакивает

Нужно увеличить продолжительность ожидания завершения потока в OnDestroy()

Здравствуйте, dandy, Вы писали:

D>Нужно увеличить продолжительность ожидания завершения потока в OnDestroy()
С другой стороны, если ты не модифицировал код, то он выскакивать не должен.
Если модифицировал, то см. предыдущий коммент.