Я создаю поток HCOM1 = AfxBeginThread(COM1, this);
как потом его остановиьть чтобы неюыло ликов?
Поток должен выполняться на протяжении всей роботы программы.

Неь,нужно прописать что-то типа AutoDelete///Короче посмотрю,а то не помню...Ну если раньше не ответят..
Вообще-то посмотри МСДН про потоки в МФС там есть

Что у тебя означает COM1. По идее это должен быть объект - наследник класса CWinThread, тогда глюков быть не должно.

А глюки будут, так как с этого дня ты узреешь, что в С++ надо обязательно уничтожать обьекты памяти, особенно при работе с потоками и при их многоразовом использовании
Вот это ссылка тебе возможно поможет :
http://forum.vingrad.ru/index.php?showtopic=38847
А вообще тебе надо именно приостановить ?(для таких случаев имхо suspendthread смотри) или остановить, поменять значения для потока, а потом запустить ? - вот если так, то по той ссылке тебе обязательно надо сходить!

Фунция, простите поток, обьявлен у меня так
Добавлено @ 17:33
Фунция, простите поток, обьявлен у меня так
UINT Stream(LPVOID Param)

Дело в том что он должен просматривать очередь и если она не пуста то выполнять там определенные действий, а при закрытии программы вызываеться деструктор очередь, ну и должен закрыться поток.

Какой смысл тебе использовать MFC функции, когда та не создаешь объект класса CWinThread?.
Делай на API, вот пример:

Код

// объявляем поток, простите функцию DWORD WINAPI ThreadFunc( LPVOID lpParam ) {    // тут наш поток    return 0; } . . . . . .     DWORD dwThreadId, dwThrdParam = 1; HANDLE hThread; hThread = CreateThread(NULL, 0, ThreadFunc, &dwThrdParam, 0, &dwThreadId); // продолжаем работать       . . . . . . CloseHandle( hThread ); // завершаем

Да WinApi в этом случае будет актуальнее...

Хорошо зарекомендовал себя след способ

В класе своего трида (например СMyThread) обьявляешь, например, метод ReleaseThread.

void CMyThread::ReleaseThread(int nExitCode)
{
PostThreadMessage(WM_QUIT, nExitCode, NULL);
}

ну а когда поток надо кикнуть, вызываешь данный метод. Работает на ура.

alien_by
Всё гениальное просто !

А просто

Код

PostThreadMessage(MyThread->m_hThread, WM_QUIT, nExitCode, NULL);

нельзя?

DWORD WINAPI Наверное вы правы, так действительно будет лучше, но лик всеравно остался, правда меньше 100 бай, но это вопрос принцыпа.

Может там проблема в самой функции? Она организована так:

DWORD WINAPI COM1(LPVOID Param)
{
while(true)
{
.....
Sleep(delay);
};
return 0;
}

Идем дальше,
void CMyThread::ReleaseThread(int nExitCode)
{
PostThreadMessage(WM_QUIT, nExitCode, NULL);
}

ничего не сработало Лик даже не изменился

Nuzur мой способ возьми.

Если на WinApi (точнее, не используя CWinThread), то PostThreadMessage не будет работать до тех пор, пока в процедуру потока не будет вставлена соответствующая обработка сообщений виндов (GetMessage или PeekMessage).
Сделай лучше

Код

BOOL Terminated=FALSE; DWORD WINAPI COM1(LPVOID Param) {  while(!Terminated)  {    .....    Sleep(delay);  };  return 0; } ... //в основном потоке extern BOOL Terminated; //запустить поток; Terminated=FALSE; hThread=CreateThread(... ... //когда надо остановить Terminated=TRUE; WaitForSingleObject(hThread,INFINITE); //в приниципе, лучше вместо INFINITE поставить //что-нибудь заведомо больше, чем delay из Sleep(delay) CloseHandle(hThread);//если этого не сделать, то и будет лик байт на 100

Это сообщение отредактировал(а) Adil' - 16.1.2005, 12:16

Если будешь использовать CWinThread, то:
BEGIN_MESSAGE_MAP(CTvoiPotok, CWinThread)
ON_THREAD_MESSAGE(WM_TO_THREAD, OnWMToThread)
END_MESSAGE_MAP()
В InitInstance() своего потока вызывай Run().

Ну и потом шлешь сообщения: PostThreadMessage(TvoiPotok.m_nThreadID, WM_TO_THREAD, 0, 0);

Че-то я проморозился и морозиться продолжаю
Ну ладно,пора браться за старое
alien_by
А если не работаю с производным классом от СWinThread?
Вообще для остановки потока я знаю три способа:
1.Остановка с помощю задание флага,используя глобальную переменную(примитивно и неактуально)
2.Способ предложеный(похожий) на alien_by,с помощью отправки своего сообщения.
3.С помощью класса CEvent.
Если еще интересно ответь,я напишу с примерами.

Цитата(Coocky @ 11.2.2005, 22:51)

Че-то я проморозился и морозиться продолжаю Ну ладно,пора браться за старое alien_by А если не работаю с производным классом от СWinThread? Вообще для остановки потока я знаю три способа: 1.Остановка с помощю задание флага,используя глобальную переменную(примитивно и неактуально) 2.Способ предложеный(похожий) на alien_by,с помощью отправки своего сообщения. 3.С помощью класса CEvent. Если еще интересно ответь,я напишу с примерами.

Интерестно, в данном проекте уже вроде как-то прокатило и с ликом, но в жизни пригодиться это точно.
Тоесть если вам не сложно, то я буду очень признателен Вот.

Ну так где там примеры? Мне ведь интерестно!

Секунду Nuzur,ща горю...Курсовая... Точно будет в четверг

Последний раз поднимаю.

Nuzur
Завтра,гадом буду

А можно послать MFC и утворить:

Код

class Thread { public:     Thread ( DWORD (WINAPI * pFun) (void* arg), void* pArg)     {         _handle = CreateThread (             0, // Security attributes             0, // Stack size             pFun,             pArg,             CREATE_SUSPENDED,             &_tid);     }     ~Thread () { CloseHandle (_handle); }     void SetPriority(int nPriority){ #ifndef WINPLATFORM             SetThreadPriority(_handle,nPriority); #endif     }     void Resume () { ResumeThread (_handle); }     void Suspend() { SuspendThread(_handle); }      void WaitForDeath ()     {         WaitForSingleObject (_handle, 2000);     }     HANDLE GetHandle() { return _handle; }     DWORD GetID() {return _tid; } private:     HANDLE _handle;     DWORD  _tid;     // thread id }; class cAdvancedActiveObject { public:     cAdvancedActiveObject ();     virtual ~cAdvancedActiveObject () { Stop(); }     virtual bool Start(char *chThreadName = "");     virtual bool Stop();     bool Started() { return (_thread != NULL); };     virtual bool SetPriority(int nPriority); protected:     virtual void InitThread () {};     virtual void Loop () = 0;     virtual void FlushThread () {};     static DWORD WINAPI ThreadEntry (void *pArg);     int            _isDying;     Thread *    _thread; }; /* in derived class's destructor you should call use Stop(), else FlushThread won't be called */ inline cAdvancedActiveObject::cAdvancedActiveObject () {      _thread = NULL; } inline bool cAdvancedActiveObject::Start (char *chThreadName) {     if (_thread)         return false;     InitThread();     _isDying = 0;     _thread = new Thread(ThreadEntry, this);     if (!_thread)         return false;     _thread->Resume(); #ifndef WINPLATFORM     #ifdef PHARLAP     EtsSetThreadDebugName(_thread->GetHandle(), chThreadName); #endif //PHARLAP #endif     return true; } inline bool cAdvancedActiveObject::Stop () {     if (!_thread)          return false;     _isDying++;     // Let's make sure it's gone     _thread->WaitForDeath ();     delete _thread;     _thread = NULL;     FlushThread ();     return true; } inline DWORD WINAPI cAdvancedActiveObject::ThreadEntry (void* pArg) {     cAdvancedActiveObject * p = reinterpret_cast<cAdvancedActiveObject *>(pArg);     p->Loop ();     return 0; } inline bool cAdvancedActiveObject::SetPriority(int nPriority) {      if (!_thread)         return false;     _thread->SetPriority(nPriority);     return true; } // Пример class cTest : cAdvancedActiveObject {   cTest() { cAdvancedActiveObject::Start() };   ~cTest() { cAdvancedActiveObject::Stop() };   void Loop()  // наш thread   {     while (!_isDying)     {            // Типа вечный двигатель :)     }   } };

bel_nikita,не понял.Это насчет переменной?
Добавлено @ 23:44
А ,все понятно...Но вижу только 2 способа.А че МФС посылать? Разве неудобно?

Coocky

Цитата

А че МФС посылать?

А потому, что я его не знаю

З.Ы.: А вообще, треды функциями, типа WaitForSingleObject ..., останавливают

Цитата

А вообще, треды функциями, типа WaitForSingleObject ..., останавливают

Да,и это считается нормальным и правильным!Но есть и другие методы-иногда похабные,но простые.Короче завтра напишу-если че прочтешь:-)

Итак,как обещал
1 Способ-глобальные переменные.Не лучший способ-небезопасен.
Итак заводим перемную,КОТОРУЮ добавлем вверху,сразу после endif;
Обьявляем ее так votalite bool Stop;(votalite-это означает,что вне потока!)
Присваиваем ей значение Stop=true;
И теперь в функции потока (MyPotok() ;) пишем

Код

UINT MyPotok(LPVOID param) { while (Stop) { // Код Потока } }

//Когда нужно остановить-пишем Stop=false;
//Все  

2 Способ тебе описали -это с помощью сообщения.Повторятся не буду.
3 Способ.CEvent
Создаем глобальные обьекты CEvent Start и CEvent Stop ;
Добавляем #include "afxmt.h"
Для установки в состояние сигнализации делаем Start.SetEvent(); Stop.SetEvent();(там где раньше true и false)
и теперь функция

Код

UINT MyPotok(LPVOID param) { ::WaitForSingleObject (Start.m_hobject,INFINITE); BOOL Potok=TRUE; while (Potok) { // Код Потока int result=:WaitForSingleObject (Stop,m_hobject,0); if (result==WAIT_OBJECT_0) Potok=FALSE; } return 0; }

Все понятно или обьяснить.Если не поймешь что к чему,пиши -обьясню на пальцах

Это сообщение отредактировал(а) Coocky - 12.3.2005, 23:48

Да, добавлю.Последний способ-єто сигнализация обьекта CEvent.
Когда Start переведется в состоянии сигнализации,функция начнет работать.
Поток входит в цикл while,где віполняется опрос обьекта собітия Stop.Цикл продолжается до тех пор,потка обьект Stop не будет переведен в состояние сигнализации,и выйдем.
Извини,че не так с синтаксисом-пишу с головы и в плохом состоянии
Если че не так исправлю.Когда протрезвею
Удачи.Побежал

Это сообщение отредактировал(а) Coocky - 12.3.2005, 23:48

Coocky, Базара нет, круто! Только непонятно зачем.
Идея здесь уже была написана, просто повторю.
Поток - это цикл (в общем случае), поэтому, если не нужно использовать CWinThread, а его им лучше пользоваться только когда потоку необходимо передавать сообщения типа SenMessage (чем лично я никогда не пользовался - не было нужды), все делают так

Код

bool volatile bContinue=false; void Class::StartTherad...... { bContinue=true; hThread=beginthreadex(....); ............ } void Class::StopTherad...... { bContinue=false; WaitForSingleObject(hThread); } unsigned __stdcall ThreadFunc( void* pArguments ) {       while(bContinue)      {       .........................      } }

Объявляем глобальную, по отношению к функции потока, переменную и зацикливаем поток до тех пор, пока кто-то не изменит её значение (остановит поток). Так как поток в основном ждёт чего-то (WaitFor....Object), то такой цикл не будет занимать много процессорного времени.
Функцию Sleep лучше не использовать, потому что из неё невозможно корректно выйти, без TerminateThread.


Это сообщение отредактировал(а) Олег М - 14.3.2005, 22:11

Олег М
Я не понял твоей иронии.Я человеку показываю все доступные методы,а его выбор,чем пользоваться

Цитата

Только непонятно зачем.

Зачем-ЧТО?

Nuzur
И еще.Во всех приведеных примерах ты посылал ПОТОКУ команду из главной проги,когда остановиться.
Но есть ситуация,когда ПОТОК должен сказать проге,что мне пора бы остановиться.Для этого регистрируешь свое сообщение,и когда поток должен сказать-все хватит,отправляешь из него это сообщение.А в обработчике своего сообщения ставишь обьекты или переменные в нужное состояние.И все происходит как выше...

Это сообщение отредактировал(а) Coocky - 15.3.2005, 14:06

Цитата(Coocky @ 15.3.2005, 14:05)

Зачем-ЧТО?

Зачем использовать событие в качестве булевской переменной

Олег М

Цитата

Зачем использовать событие в качестве булевской переменной

А что в этом плохого?
Нормальный подход..А чем он хуже твоего?

1
CWinThread::SuspendThread()-приостановка потока
CWinThread::ResumeThread()-возобновление
2
::Sleep()


завершение потока
1
AfxEndThread или API PostQuitMessage c флагом WM_QUIT если поток отправляет сообшение сам себе
2
GetExitCodeThread()

Цитата(Coocky @ 16.3.2005, 14:21)

Нормальный подход..А чем он хуже твоего?

Нормального немного, как-то слишком хитро и медленно. Единственно, что одно событие можно использовать в разных процессах. Но это, я так понял, в данном случае не актуально.
Вот что действительно нужно, так это использовать WaitForSingleObject для события вместо Sleep. Потому что при необходимости корректно завершить поток Sleep нельзя прервать, а ожидание события можно.