Delphi6 BANNED Редактировать | Профиль | Сообщение | Цитировать | Сообщить модератору Хотя в конкретном моем случае речь идет о Delphi, но думаю вопрос больше общий так как касается API функции, которые одинаковые как по синтаксису так и среде использованию для всех (почти) языков. Дело касается потоков и функции TerminateThread(thread.Handle, 0);   Теперь немного о моей программе. В программе есть потоки которые выполняют некую работу. Допустим качают данные с какого-то сайта. Назовем его "поток скачки". Так как у скачки должен быть timeout, я "поток скачки" поместил в другой поток который следит за временем, и в случае его истечения заверещал "поток скачки" аварийно, TerminateThread("поток скачки".handle, 0); Назовем этот "поток проверки".     В итоге что бы выполнить задания закачки одновременно я создавал несколько "потоков проверки" и ждал пока они все закончат работу. Результат мог быть или положительный, а значит "поток скачки" завершил работу удачно, либо отрицательный, не смогли скачать или кончилось время. После чего данный "поток проверки" убивался также функцией TerminateThread("поток проверки".handle, 0); после чего заново запускался но уже с новыми параметрами.   Но при тестировании и наблюдениями за поведением кода, было замечено что после того как первые 10 "потоков проверки" (а это был массив) завершал работу и запускались новые 10 потоков некоторые вообще исчезали. Другими словами есть подозрение что функция TerminateThread убивала больше одного потока за раз! Так как при подсчете, а я учитывал когда поток заканчивал работу, разница была в 50%. Толи потоки не могли быть убиты, толи наоборот их убили случайно   Одним словом, конечно сложно что-то советовать прочитав выше указанный алгоритм, но может у вас была похожая ситуация? И вообще как можно завершить работу потока аварийно. Что бы наглухо, так как алгоритм Thread.Teriminate не подходит, он завершает работу только после того как внутренние компоненты (созданные в потоке) завершат работу.   Заранее благодарю всех сначала за время потраченное на прочтение такого большого текста и потом за ответ   Добавлено: Сори но кажеться я сам лично нашел ошибку, досканально проверял каждый компонент по отдельности и кажеться ошибка вообше банальная (в чужом компоненте не доработка ) Всего записей: 2631 | Зарегистр. 06-07-2004 | Отправлено: 06:12 31-05-2006 | Исправлено: Delphi6, 06:29 31-05-2006

OdesitVadim Advanced Member Редактировать | Профиль | Сообщение | ICQ | Цитировать | Сообщить модератору Anatoliy_A Цитата: >> И вообще как можно завершить работу потока аварийно.     Thread.Suspend;   Thread.Free; Но стрёмно, поток может не завершиться так как надо. Лучше сделать, так как сделали в одном сетевом сканере - создают ещё одно маленькое приложение и запускают несколько копий. Все проблемы быстро решаются ---------- Press any key to continue or any other key to exit Пишите так, чтобы не было стыдно за нобелевскую премию. Всего записей: 1568 | Зарегистр. 19-09-2003 | Отправлено: 12:43 31-05-2006

Delphi6 BANNED Редактировать | Профиль | Сообщение | Цитировать | Сообщить модератору Цитата: Thread.Suspend; Thread.Free; это и есть то что я говорю нереально. Допустим у меня была в прошлом такая ситуация когда информация считывалась с носителя CD. Так вот если место где происходило считывание было повреждено, то даже по истечении времени команда suspend не работала, поток уничтожался только после того как истекало время считывания данных (системный таимаут) и генерировалась ошибка (ее конечно отлавливал), И что я имел в результате, 30 секунд ждал пока поток завершит работу. Когда функция TerminateThread убивает поток насмерть мгновенно! Вот только не знаю насколько качественно освобождается потом память при вызове команды thread.free, хотя думаю память должна освобождаться Думаю это легко проверить если запустить и уничтожить до 10.000 потоков.   Цитата: Лучше сделать, так как сделали в одном сетевом сканере - создают ещё одно маленькое приложение и запускают несколько копий. Все проблемы быстро решаются идейка хорошая, но как потом результат работы каждой программки получать? В файл кидать и потом считывать? но все это доп. ресурсы, учитывая что все на дельфи пишется, хотя если будет не визуальная программулька то думаю все будет ок. Мой вердикт, для моих целей слишком наворочена, да и так работает без проблем пока.   Цитата: все ресурсы в рабочем потоке выделяй только как члены класса вот именно, у меня "поток закачки" создается в "потоке проверки" таким образом если удаляется главный поток то и удаляется все в нем, хотя для доп. безопасности можно их оформить как члены класса. ("поток закачки" член "потоке проверки" класса)   Цитата: то автоматического уничтожения объекта Thread у тебя не произойдет для этой цели я на всякий случай после это команды вызываю thread.free что как я думаю должно освобождать память.   Цитата: Рихтере Это есть зло, он даже писал что надо делать синхронизацию а это оказалось самой большой ошибкой, читал на этот счет много статей в интернете Так что кто знает   Цитата: достаточно и одного потока на всех ок если вы внимательно прочтете алгоритм то заметите что есть вероятность что код закачки в "потоке закачки" может повиснуть, а именно закачка может длиться очень долго если скорость соединения очень мала, а как вы собираетесь после таимаута его убить? Только запустив в потоке и контролируя пройденное время снаружи. Зачем второй поток? А как вы собираетесь контролировать сразу несколько запушенных закачек? Не легче все это оформить в виде одного потока который сам будет следить за всем и через таимаут время выдаст результат или положительный или отрицательный. Сам проанализирует результаты работы "потока закачки". Вам же остается просто запустить 10 (к слову) "потоков проверки" и ждать когда же они все закончат работу (а они сто пудово закончат работу вовремя).   Ну думаю один очень мудрый совет получил на счет того что "поток закачки" лучше оформить в виде члена класса "поток проверки".   И что TerminateThread есть зло. Я согласен, даже читал один мануал в котором говорилось не о TermiateThread а что-то вроде SuspendThread который точно зло, так как в примере было показано как программу можно подвесить такой функцией случайно.   Вопрос до сих пор актуален, как вы убиваете поток, в котором не просто бесконечный цикл (на него команда suspend) сработает, а компонент который работает с внешним миром, типа считывает данные с носителей, качает данные из инета, или проверяет содержимое другой программы или еще что.   Добавлено: Цитата: Может пересмотреть механизм скачки? Например, в самом потоке сделать таймаут, или по таймауту закрывать сокет? Это будет (я так думаю) более удачным решением. В этом случае сам поток поймет, что надо закрываться и грамотно освободит свои ресурсы. А как можно остановить закачку, допустим компонента TIdHTTP? Я думаю это не реально, хотя возможно есть способ, сейчас пробью в инете...   Добавлено: Вот в соседнем форуме ведеться обсуждение и вот что один сказал Цитата: При работе с сокетами (сетью), к сожалению, нормального способа быстро уничтожить поток нет. Если сокет ждет подключения (ответа сервера), сервер не отвечает, поток можно будет убить только после возникновения таймаута. Многие известные программы (в том числе и от MS) уничтожают потоки аварийно, а потом как-то подчищают ресурсы. http://delphimaster.ru/cgi-bin/forum.pl?id=1149041613&n=5 Всего записей: 2631 | Зарегистр. 06-07-2004 | Отправлено: 17:13 31-05-2006

OdesitVadim Advanced Member Редактировать | Профиль | Сообщение | ICQ | Цитировать | Сообщить модератору Delphi6 Цитата: то автоматического уничтожения объекта Thread у тебя не произойдет        для этой цели я на всякий случай после это команды вызываю thread.free что как я думаю должно освобождать память. Будут подчищены только VCL ресурсы. А ведь ещё есть и Windows'овские. И неизвесно, как поведёт себя класс TThread при попытке удалить ресурсы, наличие которых под вопросом (поток мы прибили, а ресурсы потока ушли в свободное плаванье) ---------- Press any key to continue or any other key to exit Пишите так, чтобы не было стыдно за нобелевскую премию. Всего записей: 1568 | Зарегистр. 19-09-2003 | Отправлено: 17:36 31-05-2006

Delphi6 BANNED Редактировать | Профиль | Сообщение | Цитировать | Сообщить модератору OdesitVadim Ок, тепер ясно куда капать надо. А как можно подчистить все. Получаеться если я пользуюсь IdHTTP то надо перед уничтожением потока сделать IdHTTP.Free? Всего записей: 2631 | Зарегистр. 06-07-2004 | Отправлено: 17:42 31-05-2006

OdesitVadim Advanced Member Редактировать | Профиль | Сообщение | ICQ | Цитировать | Сообщить модератору Delphi6 Цитата: Ок, тепер ясно куда капать надо. А как можно подчистить все. Получаеться если я пользуюсь IdHTTP то надо перед уничтожением потока сделать IdHTTP.Free? Даже не знаю. А если поток в это время работает с компонентом? Не будет ли аксес виолейшенов? Поток обратиться к несуществующему компоненту. К тому же синхронизация необходима при доступе к компоненту. А там может быть проблема с критическими секциями. Поток вошёл в неё и не вышел. Основной поток не может обратиться к нему. Я не знаю, как у Вас там организовано, но думаю, что с удалением будут бяки. И лучшим на мой взгляд есть создание дополнительной программы, которой оттдаются указания. ---------- Press any key to continue or any other key to exit Пишите так, чтобы не было стыдно за нобелевскую премию. Всего записей: 1568 | Зарегистр. 19-09-2003 | Отправлено: 19:31 31-05-2006

Delphi6 BANNED Редактировать | Профиль | Сообщение | Цитировать | Сообщить модератору OdesitVadim Что вы подразумеваете когда говорите что поток может обращаться к не существующему компоненту? Единственный компонент с которым он работает, создается в нем же самом. Получается если поток умирает то и компонент сдыхает. Или я не совсем правильно представляю что есть поток?   FireZone Самая мудрая идея, вот это я и хочу проверить, на другом форуме говорили что именно так можно прикрыть соединение аварийно. Посмотрим как на практике.   vserd Спасибо за выписку из доки.   Все больше и больше я начинаю понимать что есть вероятность потери/утечки ресурсов.   Добавлено: Думаю теперь все грамотно?   Thread.TerminateConnection; Thread.Terminate; Thread.Free;   procedure TMyThread.TerminateConnection; begin   fIdHTTP.DisconnectSocket;   fIdHTTP.Free; end;   Что скажете теперь знатоки? Проблем и ошибок не было, код работает как часики, если мне не показалось то он работает намного быстрей Чем с конструкцией TerminateThread Всего записей: 2631 | Зарегистр. 06-07-2004 | Отправлено: 02:18 01-06-2006

Delphi6 BANNED Редактировать | Профиль | Сообщение | Цитировать | Сообщить модератору Как и можно было ожидать, где-то просочилась ошибка Хоть поток удаляется по всем правилам, где-то генерируется ошибка и прога автоматом, без сообщений об ошибке вырубается Когда и при каких обстоятельствах пока не известно, но где-то после 200 запуска/уничтожения потока (прогу оставил работать, сам пошел чаек попить). Сейчас добавлю в программу ведения логов и буду ловить ошибку. А как можно отловить все ошибки возникшие при работе программы? Что бы хотя бы понять где приблизительно ошибка   Добавлено: Лог файлы показали что, после 500 запусков и уничтожений остаются потоки которые не могут быть завершены! А именно мое подозрение касающийся fIdHTTP.DisconnectSocket не срабатывает и поток продолжает работать. Сейчас думаю есть смысл проверить что будет с TerminateThread и запуском 500 раз? Если ошибок не будет то мое подозрение подтвердиться фактом   Добавлено: Тестирование с функцией TerminateThread   Начну с самого лавного, утечка в памяти есть. Не все ресурсы высвобождаются, хотя зато все работает как часы. Потеря не велика до 1мб при запуске/уничтожении 1000 потоков. Сначала было больше пока я не добавил строку IdHTTP.Free до уничтожения потока.   Теперь возникает логический вопрос, как все же убить поток удачно, или что еще надо зачистить? Кроме IdHTTP поток не использует ничего кроме переменных. Не думаю что именно они и не освобождаются И как можно системе передать сообщение что типа убей поток и подчисти все, или дядя Бил это не предусмотрел? И по этой причине винда часто летит? Всего записей: 2631 | Зарегистр. 06-07-2004 | Отправлено: 09:13 01-06-2006

OdesitVadim Advanced Member Редактировать | Профиль | Сообщение | ICQ | Цитировать | Сообщить модератору Delphi6 Цитата:  Получается если поток умирает то и компонент сдыхает. Или я не совсем правильно представляю что есть поток? Если поток умирает "цивилизованым способом", то его VCL обёртка по всем правилам удаляет дочерние компоненты. Если же его убивают жёстко, то он не в состоянии это отследить.   Эксперементы - это правильно! Побольше их. ---------- Press any key to continue or any other key to exit Пишите так, чтобы не было стыдно за нобелевскую премию. Всего записей: 1568 | Зарегистр. 19-09-2003 | Отправлено: 12:08 01-06-2006

Delphi6 BANNED Редактировать | Профиль | Сообщение | Цитировать | Сообщить модератору Сори что долго не отвечал, был в out-е Вот код который я имею на данный момент, как можно догадаться он для проверки работаспособности прокси: Код:   unit Kernel;   interface   uses   Classes, IdHTTP, Windows, Functions, Dialogs;   type   TProxyType = (ptUnknown, ptBad, ptTransparent, ptAnonymouse, ptElite, ptElitePlus);       TProxyCheckerThread = class(TThread)   private     fIdHTTP: TIdHTTP;     fUrl: String;     fCheckString: String;     fResult: Boolean;     fResultString: String;   protected   public     constructor Create(Url, Server: String; Port: Integer); overload;     procedure Execute; override;               procedure TerminateConnection();     function GetResult: Boolean;     function GetResultString: String;   end;     TProxyChecker = class(TThread)   private     fUrl: String;     fCheckString: String;     fServer: String;     fPort: Integer;     fTimeout: Integer;     fResult: Boolean;       //Result variables     fProxyType: TProxyType;     fProxyLatency: Integer;     fProxySSLSupport: Boolean;     fProxyCountryCode: String;     fProxyCountryName: String;   protected     ...удалено для облегчения кода...   public     constructor Create(Url, CheckString, Server: String;       Port, Timeout: Integer); overload;     procedure Execute; override;       function GetResult: Boolean;     function GetProxyType: TProxyType;     function GetLatancy: Integer;   end;   implementation   //====================================================== //TProxyCheckerThread BEGIN //======================================================   constructor TProxyCheckerThread.Create(Url, Server: String; Port: Integer); begin   //Create thread in suspending mode   inherited Create(True);     fResult := false;   fResultString := '';   //Create TIdHTTP component to retrive information   fIdHTTP := TIdHTTP.Create(nil);   fIdHTTP.Request.ProxyServer := Server;   fIdHTTP.Request.ProxyPort := Port;   fUrl := Url;   Resume; end;   procedure TProxyCheckerThread.Execute; begin   try     fResultString := fIdHTTP.Get(fUrl);   except     //Error in connection     exit;   end;   fResult := True; end;   procedure TProxyCheckerThread.TerminateConnection; begin   if Assigned(fIdHTTP) then begin     fIdHTTP.DisconnectSocket;     fIdHTTP.Free;   end; end;   ...удалено для облегчения кода...   //====================================================== //TProxyCheckerThread END //======================================================       //====================================================== //TProxyChecker BEGIN //======================================================   constructor TProxyChecker.Create(Url, CheckString, Server: String;   Port, Timeout: Integer); begin   //Create thread in suspending mode   inherited Create(True);   //Set thread's settings and execute it   //Priority := tpIdle;   fUrl := Url;   fCheckString := CheckString;   fServer := Server;   fPort := Port;   fTimeout := Timeout;   //Prepare global variables   fResult := false;   fProxyType := ptBad;   Resume; end;   procedure TProxyChecker.Execute;   var     PCT: TProxyCheckerThread;     StartTime: Integer;     timePass: Integer; begin   //Prepare thread and execute to recieve result from URL   PCT := TProxyCheckerThread.Create(fUrl, fServer, fPort);   StartTime := GetTickCount;   timePass := 0;   //Work until time will finish and result from page will be recieved   while (timePass < fTimeout) and (not PCT.GetResult) do begin     timePass := GetTickCount-StartTime;     //Wait for result or timeout   end;   //Checking if result exist and analyze it   if PCT.GetResult then begin     fProxyLatency := timePass;     AnalyzeResult(PCT.GetResultString);   end else     fProxyType := ptBad;   //Remove thread, even in case if it still running   //First of all of cause terminate any connection   PCT.TerminateConnection;   PCT.WaitFor;   PCT.Free;   fResult := True; end;   ...удалено для облегчения кода...   //====================================================== //TProxyChecker END //====================================================== end.     Добавлено: Сегодняшние тестирования вообще удивили меня, программа после того как были запушены/уничтожены в суме около 300 поток вырубилась. Снова не показав ошибку. Даже не могу представить как можно отследить в такой ситуации ошибку и где она вообще возникает Не говоря о том что не возможности следить за состоянием потоков. Думаю продеться вести файл лог, хотя не совсем представляю что за информацию туда писать Всего записей: 2631 | Зарегистр. 06-07-2004 | Отправлено: 03:12 02-06-2006 | Исправлено: Delphi6, 04:53 02-06-2006

ShIvADeSt Moderator Редактировать | Профиль | Сообщение | Цитировать | Сообщить модератору Цитата: procedure TProxyCheckerThread.TerminateConnection;   begin     if Assigned(fIdHTTP) then begin       fIdHTTP.DisconnectSocket;       fIdHTTP.Free;     end;   end; Попробуй fIdHTTP.FreeAndNil скорее всего не обнуляет. В каком то топике что то аналогичное рассматривалось. ---------- И создал Бог женщину... Существо получилось злобное, но забавное... Всего записей: 3956 | Зарегистр. 29-07-2003 | Отправлено: 06:32 02-06-2006

Delphi6 BANNED Редактировать | Профиль | Сообщение | Цитировать | Сообщить модератору Цитата: Попробуй fIdHTTP.FreeAndNil скорее всего не обнуляет. В каком то топике что то аналогичное рассматривалось. Вместо обеих строк или все же надо делать DisconectSocket? Всего записей: 2631 | Зарегистр. 06-07-2004 | Отправлено: 07:27 02-06-2006 | Исправлено: Delphi6, 07:27 02-06-2006

Страницы: 1 2

Компьютерный форум Ru.Board » Компьютеры » Прикладное программирование » ошибка в уничтожении потока Delphi+Thread+TerminateThread

Переход по форумам  Закладки   » Компьютеры Цифровое изображение Программы Microsoft Windows UNIX Другие OS Hardware В помощь сисадмину Прикладное программирование Игры Форумные игры   » Интернет Web-программирование В помощь вебмастеру Графика Хостинг Зацените-ка!   » Тематические Ikonboard v.2 Ikonboard v.3 Invision Board Другие форумы PHP-Nuke и другие порталы Мобила   » Общие Спорт Флейм Темы по региональным встречам Музыка и Кино Юмор Литература и Живопись   » Ru.Board Новости Помощь по форуму   » Андеграунд eBookz Варезник Раздачи и акции Мобильный варезник Андеграунд Игры и фильмы   » Специальные Тестирование