Здравствуйте, как вы уже наверное догадались в данной теме речь пойдёт о многопотчном приложении. Перед тем как я сформулирую ошибку, я опишу вам структуру своего проекта. Вообще сейчас я пишу программу для пересылки файлов в сети будь-то телефонное соединение или же локальная сеть. На сервере выбирается файл для отправки и отправляются клиенту поток связанный с выбраннным файлом, а клиент соответственно его принимает. Сначало о принципах работы... Клиент и сервер обмениваютсяпсевдо-командами,например: при выборе файла на сервере
выполняется следующий код:
| Код |
if(Dialog->Execute() && Dialog->FileName!="")
{
FileName=Dialog->FileName;
MessageDlg("Файл подготовлен к передаче:\n"+FileName,mtInformation, TMsgDlgButtons() << mbOK, 0);
RzExpandEdit1->Font->Color=clBlack;
RzExpandEdit1->Text="Файл \""+FileName+"\" готов к передаче";
RzExpandEdit1->Visible=true;
RzProgressBar2->Percent=0;
RzProgressBar2->Visible=true;
Selected=true;
}
else
{
SelFile=false;
}
if(ServerSocket1->Socket->ActiveConnections!=0&&SelFile!=false)
{
ServerSocket1->Socket->Connections[0]->SendText("!selected");
return;
}
else
{
if(SelFile==false)
{
SelFile=true;
}
}
|
А когда подключается клиент такой код:
| Код |
RzStatusPane1->Caption="Присоединился: "+Socket->RemoteHost;
if(SelFile==true)
{
ServerSocket1->Socket->Connections[0]->SendText("!selected");
return;
}
|
т.е. я имею ввиду строку "!selected", котроая посылается клиенту и, вследствие этого, на клиентском
выполняется обработчик события - проверяется какая команда была послана, выполняется соответсвующее действие
ну и т.п.
Ниже я привел обработчик события сокета сервера(для чего я все это делаю будет понятно дальше) :
| Код |
s = Socket->ReceiveText();
if (s=="!send")
{
if(FileName!="")
{
ms = new TFileStream(FileName,fmOpenRead);
RzProgressBar2->Percent=0;
ms->Position = 0;
Socket->SendText(IntToStr(ms->Size)+';'+FileName);
}
}
if (s=="!ready")
{
try
{
g=new PercentH(false);
RzExpandEdit1->Font->Color=clOlive;
RzExpandEdit1->Text="Подождите, не закрывайте приложение (идёт передача файла)";
ServerSocket1->Socket->Connections[0]->SendStream(ms);
}
catch ( ... )
{
ShowMessage("!");
}
}
if (s=="!ok")
{
g->Terminate();
RzProgressBar2->Percent=100;
}
if(s=="!error")
{
RzExpandEdit1->Font->Color=clBlack;
RzExpandEdit1->Text="";
Application->MessageBox("Ошибка передачи данных клиенту\n (попробуйте передать файл ещёраз).","Ошибка",MB_ICONERROR+MB_OK);
RzExpandEdit1->Visible=false;
RzProgressBar2->Visible=false;
delete ms;
}
|
"ms" - это объект класса TFileStream (его я объявил в ".h")
Во время закачки у клиента отображаются проценты (Это вычисляеися простейшим арифмитическим методом пропорции: RzProgressBar1->Percent=100*Data->Size/DataSize : где Data - объект класса TFileStream, а его свойство означает сколько
процентов закачено, т.е. размер файла в которого записывает поток;DataSize - размер пересылаемого файла )
А по поводу сервера я долго ломал голову как можно реализовать подчет процентов, ведь когда сокет начинает посылку потока
"код блокируется". Тут мне в голову пришла идея о многопоточности. Прочитав пару раз главу из книги, я начал написать второй поток.
| Код |
void __fastcall PercentH::Execute()
{
HANDLE Mutexofallsystems;
Mutexofallsystems=CreateMutex(NULL,false,Form1->RzProgressBar2->Name.c_str());
while(true)
{
if(WaitForSingleObject(Mutexofallsystems,INFINITE)==WAIT_OBJECT_0)
{
Synchronize(Display);
Form1->RzProgressBar2->Refresh();
if(Form1->RzProgressBar2->Percent==99)
{
Form1->RzProgressBar2->Percent=100;
Form1->RzExpandEdit1->Font->Color=clGreen;
Form1->RzExpandEdit1->Text="Файл \""+Form1->Dialog->FileName+"\" успешно передан клиенту";
break;
}
}
ReleaseMutex(Mutexofallsystems);
}
}
//---------------------------------------------------------------------------
void __fastcall PercentH::Display()
{
Form1->RzProgressBar2->Percent=Form1->ms->Position*100/Form1->ms->Size;
}
|
Все как и положено, доступ к визуальному компоненту предоставлен через Mutex и Synchronize, и код вроде бы правильный, да и что самое главное
работает, если бы не одно НО! Как мы видим в функции-члене Display(), идёт обращение к другому потоку , о котором я говороил ранее
(см.обработчик события сокета сервера), именно из-за этого и возникает ошибка. А конкретнее ошибке возникет из-за взаимодействия ServerSocket1->Socket->Connections[0]->SendStream(ms) и метода Synchronize. Как я пологаю во время того как один поток (я имею ввиду поток сокета)
прекратил свое существование другой продолжает ссылаться на него, и использовать его данные. Все вроде-бы логично , но всё же Display() использует в
вычисления поток ms, который ни какого отношения (не считая использования) к потоку сокета не имеет! Что же все-таки в итоге получается? Что два
потока используют ms и, из-за синхронного обращения возникет ошибка!?
Эта ошибка чаще всего появляется под конец закчки т.е. стабильно на 99%. Но это ещё не все... Иногда бывает так что посередине зкачки отлдчик выдаёт мне
сообщение об ошибке, но уже иного плана "Can't canvas drawing" или что-то в этом роде (у меня нет возможности сейчас это проверить),но т.к. я использовал
вовсе не канву, а визуальный компонент, причем предаставил доступ к нему правильным образом, меня это подталкивает к выводу, что ошибка всё таже....
Ну вот я и озвучил все проблемы и вопросы, которые у меня были. Готов принять практически любые предложения вплоть до модификации соката или потока; Если у
кого-нибудь есть идеи как реализовать данную задачу, и вовсе без второго потока, я с радостью выслушаю предложения. Заранее благодарен. 
|
Обидно... 
.
!)
.