Как грамотно прервать выполнение потока

[SSW]

Windows / VC++ 6.0 / MFC

Есть функция

Код:

UINT ThreadProc(LPVOID param)
{
 
while (TRUE) 
{
   ...

 // Wait for notification.
    dwWaitStatus = WaitForMultipleObjects(1, dwChangeHandles, FALSE, INFINITE); 
      switch (dwWaitStatus) 
      {
         case WAIT_OBJECT_0: 
 
         // A file was created or deleted in the directory.
         // Refresh this directory and restart the notification.
 
            AfxMessageBox("YES !!!!!!!!!!!!!!!!!"); 
            break; 
        default: 
            ExitProcess(GetLastError()); 
      }


/*********/
}

Я делаю ее в потоке

Код:

    AfxBeginThread(ThreadProc, this);

Вопрос, как грамотно прервать выполнение такой функции и завершить поток?

[npak]

SSW, добавь ещё одно событие в массив хендлов, которые ожидает WaitForMultipleObjects.  Срабатывание дополнительного события означает, что кто-то вежливо просит поток завершить свою работу.

В потоке

Код:

    HANDLE SyncArray = { ChangeHandle, ExitEvent };
    dwWaitStatus = WaitForMultipleObjects(2, SyncArray, FALSE, INFINITE); 
    switch (dwWaitStatus) { 
         case WAIT_OBJECT_0: 
  
         // A file was created or deleted in the directory. 
         // Refresh this directory and restart the notification. 
  
            AfxMessageBox("YES !!!!!!!!!!!!!!!!!"); 
            break; 
        case WAIT_OBJECT_1: 
  
            // Killed 
  
            AfxMessageBox("I'm dying !!!!!!"); 
            ExitThread(0);
            break; 
        default: 
            ExitProcess(GetLastError()); 
      }

Во внешнем мире:

Код:

   SetEvent( ExitEvent );

прывает исполнение потока

[SSW]

Если я правильно понял, надо добавить хендел потока в масив, и потом ожидать срабатывания от WaitForMultipleObjects.

Сделал так:

Код:

	threadHandle = GetCurrentThread();
	
	DWORD dwWaitStatus;           
    HANDLE dwChangeHandles[2]; 
// Watch the directory for file creation and deletion. 

   dwChangeHandles[0] = threadHandle;
   
   dwChangeHandles[1] = FindFirstChangeNotification( 
      FolderName,                         // directory to watch 
      FALSE,							// do not watch subtree 
      FILE_NOTIFY_CHANGE_FILE_NAME);	// watch file name changes 
// Change notification is set. Now wait on both notification 
// handles and refresh accordingly. 
   while (TRUE) 
   {
   // Wait for notification.

      dwWaitStatus = WaitForMultipleObjects(2, dwChangeHandles, FALSE, INFINITE); 
 
      switch (dwWaitStatus) 
      {
         case WAIT_OBJECT_0: 
 
         // A file was created or deleted in the directory.
         // Refresh this directory and restart the notification.
 
            AfxMessageBox(" YES    !!!!!!!!!!!!!!!!!!!!!"); 
			
	if ( FindNextChangeNotification(dwChangeHandles[0]) == FALSE)
	ExitProcess(GetLastError()); 
            break; 

         case WAIT_OBJECT_0+1: 
  
            // Killed 
  
            AfxMessageBox("I'm dying !!!!!!"); 
            ExitThread(0); 
            break; 


        default: 
            ExitProcess(GetLastError()); 
      }
   }
}

Как только поток получает управления сразу вываливается.
Пошаговое выполнение заканчивается тем, что VC++ выдает:

The thread 0xFC0 has exited with code 6 (0x6).

[npak]

SSW, не, не так.

Перед созданием потока надо сделать событие (CreateEvent) и передать его в процедуру потока

Код:

obj->ThreadExitEvent = CreateEvent( ... );
AfxCreateThread(..., obj);

в потоке

Код:

dwChangeHandles[0] = arg->ThreadExitEvent;

Когда надо будет нить закончить

Код:

SetEvent(obj->ThreadExitEvent);

[SSW]

Ух !

Наконец то заработало !

ОГРОМНОЕ спасибо !

[npak]

SSW,

[Bork]

А еще грамотнее - вместо ExitThread(0) использовать return 0

[RXL]

Bork, это равноценно, но ExitThread() информативнее - сразу видно, что тут не просто выход из ф-ии.

[Bork]

Bork, это равноценно, но ExitThread() информативнее - сразу видно, что тут не просто выход из ф-ии.

Цитата (Рихтер, глава 6):

"Поток можно завершить принудительно, вызвав:

VOID ExitThread(DWORD dwExitCоde);

При этом освобождаются все ресурсы операционной системы, выделенные данному потоку, но C/C++ - pеcypcы (например, объекты, созданные из С++-классов) не очищаются. Именно поэтому лучше возвращать управление из функции потока, чем самому вызывать функцию ExitThread."

т.е. деструкторы локальных объектов вызваны не будут. так что не равноценно это ...

[RXL]

http://msdn.microsoft.com/library/default.asp?url=/library/en-us/dllproc/base/exitthread.asp

Согласен. Но это касается не только автоматических объектов, но и динамических и динамически выделенной памяти. То же самое произойдет и при завершении потока из другого потока - подмечу, что тут уже return ничем не поможет.

При штатном выходе инициировать вызов деструкторов можно поместив создание объектов в блок, а ExitThread() за блоком.