Un serveur multithread
aroslide
Messages postés
23
Date d'inscription
vendredi 3 janvier 2003
Statut
Membre
Dernière intervention
27 juin 2011
-
10 juil. 2007 à 13:02
aroslide Messages postés 23 Date d'inscription vendredi 3 janvier 2003 Statut Membre Dernière intervention 27 juin 2011 - 18 mars 2008 à 23:01
aroslide Messages postés 23 Date d'inscription vendredi 3 janvier 2003 Statut Membre Dernière intervention 27 juin 2011 - 18 mars 2008 à 23:01
2 réponses
aroslide
Messages postés
23
Date d'inscription
vendredi 3 janvier 2003
Statut
Membre
Dernière intervention
27 juin 2011
22 juil. 2007 à 00:24
22 juil. 2007 à 00:24
Bon alors je vais être un peu plus précis. j'utilise un thread tserver qui crée un thread tclient à chaques nouvelles connections par contre dans le server au moment de sa creation j'utilise un semaphore exemple :
constructor tserver_thread.create(Port:Word;BindTo:string);
begin
freeonterminate:=true;
SemaphoreThreads := createSemaphore(nil,1,1,'');
semaphorelistwork :=createsemaphore(nil,1,1,'MYLISTWORK');
inherited create (false);
//apres c blablabla création du serveur on ouvre le port and co
end;
dans l'unité client au niveau de tclient.execute je reprends le semaphore messagetosend.
procedure TUser.Execute;
k,waitresult:integer;
begin
// blablabla on reçoit une instruction de la part d'un client
// on attend que le semaphore se libere pour executer une instruction ares l'autre
k:=0;
WaitResult := WaitForSingleObject(moteur.SemaphoreListWork, 0);
while waitresult<>wait_object_0 do
begin
k:=k+1;
end;
hbwait_ms(k); // là j'attends k milliseconds
end;
là c'est le crash il semble que le sémaphore semaphorelistwork n'attends pas d'avoir terminé une instruction pour en reprendre une autre .... personne à une idée ?
Au secours !!!!!!!!!
constructor tserver_thread.create(Port:Word;BindTo:string);
begin
freeonterminate:=true;
SemaphoreThreads := createSemaphore(nil,1,1,'');
semaphorelistwork :=createsemaphore(nil,1,1,'MYLISTWORK');
inherited create (false);
//apres c blablabla création du serveur on ouvre le port and co
end;
dans l'unité client au niveau de tclient.execute je reprends le semaphore messagetosend.
procedure TUser.Execute;
k,waitresult:integer;
begin
// blablabla on reçoit une instruction de la part d'un client
// on attend que le semaphore se libere pour executer une instruction ares l'autre
k:=0;
WaitResult := WaitForSingleObject(moteur.SemaphoreListWork, 0);
while waitresult<>wait_object_0 do
begin
k:=k+1;
end;
hbwait_ms(k); // là j'attends k milliseconds
end;
là c'est le crash il semble que le sémaphore semaphorelistwork n'attends pas d'avoir terminé une instruction pour en reprendre une autre .... personne à une idée ?
Au secours !!!!!!!!!
aroslide
Messages postés
23
Date d'inscription
vendredi 3 janvier 2003
Statut
Membre
Dernière intervention
27 juin 2011
18 mars 2008 à 23:01
18 mars 2008 à 23:01
bon finalement la meilleur solution ça a été de faire un serveur asynchrone avec l'api winsock en programmation direct. vais bientot poster une source là dessus.
bye bye indy 10 nos amours sont finies.
bye bye indy 10 nos amours sont finies.
