Работа с потоками

[gagarin0]

Здравствуйте!
У меня программа, которая считывает данные с порта и записывает их в файл.
Считывание проводится с помощью потока.
Вопросы:
Как правильно закрывать файл и поток?
Как проверить или они закрылись?
Как сделать так, чтоб при закрытии всей программы, если запись в файл не закончилась, то дописать в него, а потом закрыть программу?
закрываю потоки так:

         if(reader)//Если поток чтения работает, завершить его
        {
                TerminateThread(reader,0);
                CloseHandle(overlapped.hEvent);//Закрываем объект-событие
                CloseHandle(reader);
        }
        if(port)//Если порт не закрыт
        {
                CloseHandle(port);//закрываем порт
                port=0;//обнулим переменную для дескриптора порта
        }
        if(handle)//Если файл не закрыт
        {
                close(handle);//Закроем файл, в который велась запись принимаемых данных
                handle=0;//Обнулим переменную для дескриптора файла
        }

С потоками и файлами только начал разбираться, поэтому еще не сильно понимаю как это все сделать. Подскажите, пожалуйста!

[rpy3uH]

Сообщение от gagarin0

Как правильно закрывать файл и поток?

файл надо закрывать через closehandle, других вариантов нет. поток должен завершаться сам, т.е. в конце его выполнения должно быть ExitThread(0).

Сообщение от gagarin0

Как проверить или они закрылись?

проверка существования потока WaitForSingleObject если поток сейчас выполняется, функция ждёт когда поток завершится или истечём время указанное во втором параметре и только тогда вернёт управление, если потока нет, то ожидания не будет. Используй эту функцию указав вторым параметром ноль и анализируй код ошибки через GetLastError.
ситуация когда необходима проверка "закрыт ли файл" возникает при неправильном проектировании программы. Функция открыла файл то она должна его закрыть, ситуация когда один поток отрывает файл, а другой закрывает возникает при неправильном проектировании программы.

Сообщение от gagarin0

Как сделать так, чтоб при закрытии всей программы, если запись в файл не закончилась, то дописать в него, а потом закрыть программу?

юзай WaitForSingleObject.

поток который работает с файлом или портом только сам открывать и закрывать файл. Функция TerminateThread предназначена для аварийных ситуаций и принудительного завершения. При закрытии программы достаточно поставить WaitForSingleObject.

[gagarin0]

Спасибо, вам за советы!
Но хочу уточнить...
У меня два потока - один для чтения байт из порта и запись их в файл и еще один для посылки данных в порт.
Поток для чтения реагирует на событие прихода байта в порт, тогда он считывает приходящие байты и заносит в файл. Закрывается поток при нажатии на кнопку Закрыть порт и при закрытии формы.
Поток записи в порт активируется на кнопке Передать и после передачи приостанавливается.
Теперь вопрос: где мне ставить ExitThread(0)? в самом потоке? А в обработчике кнопки закрыть и закрития формы ставить какой-то флаг? К примеру так:

DWORD WINAPI ReadThread(LPVOID)
{
 ..........

 while(!flag_end)	//пока поток не будет прерван, выполняем цикл
  {
   .........
  }
handleoverlapped.hEvent);
ExitThread(0);
}

Так?
Дальше проверка правильности закрытия мне нужно для того, чтобы в случае какой-то ошибки порт не оказался заблокирован до перезагрузки системы...Для этого мне проверить, наверное, надо или закрылся правильно сам порт, правильно? Потоки тут же не при чем?
То есть if(!CloseHandle(port))? Если CloseHandle(port)=0, то ошибка и ошибку ловить GetLastError(). Так? А как потом реагировать на эти ошибки?
А для файла WaitForSingleObject(handle, INFINITE), так? Файл освобождается от записи а потом его закрыть...

Извиняюсь за такое количество вопросов...)

[rpy3uH]

если я всё правильно понял, то надо примерно так

DWORD WINAPI ReadThread(LPVOID)
{
 ..........
  //открываем все необходимые потоку хендлы
  while(WaitForSingleObject(<хендл объекта-события>,0)==WAIT_OBJECT_0)//пока не нажали кнопку "закрыть"
  {
   .........
  }  
  //закрываем все используемые потоком хендлы 
  ExitThread(0);
}

в основном потоке программы надо заранее создать объект-событие (CreateEvent) и перевести его в сигнальное состояние (SetEvent).

при нажатии на кнопку "закрыть" надо сделать примерно следующее

    ResetEvent(<хендл объекта-события>); //переводим событие в несигнальное состояние
    WaitForSingleObject(<хендл потока>, INFINITE);   
    // поток завершился и закрыл все хендлы, можно завершать программу, блокировки порта не будет

[gagarin0]

Сделал! Вроде, работает! Спасибо большое!!