ejecutando hilos en componenetes indy tcp

[richy08]

gracias manuc la razon por lo que no los destruyo es por que no se con certeza si el hilo espera a que termine una peticion para empezar a ejecutar la otra, o si crea diferentes instancias de la funcion donde los crea me podrias iluminar saludos.

[manuc]

Hola richy08,

Dentro de cada hilo, la ejecución es lineal. Es decir, cuando se conecta el tcpClient, el tcpServer Crear un hilo que atenderá la actividad de esa conexión y la ejecución del código programado para ese hilo se hará de forma lineal.
Si, mientras un hilo ejecuta su código, entra otra conexión, se generará un hilo paralelo y se ejecutaran ambos al mismo tiempo.

Gracias a esto, el TCPServer es multihilo y cada conexión se ejecuta de forma independiente, salvo en los puntos donde se utilice "synchronize".

Sabiendo esto, puedes hacer dos cosas:

1.- Crear tus componentes en el evento onConnect del tcpServer. Es decir, por cada hilo que se crea en el tcpServer, creas los componentes correspondientes.
Para este caso, deberías destruir los componentes cuando no los necesites, es decir, cuando se destruye el hilo. Esto ocurre en el evento onDisconnect del tcpServer.

2.- Crear tus componentes en el evento onExecute del tcpServer. Es decir, cada vez que un hilo tiene actividad, creas los componentes que necesites.
Igualmente, cuando ya no necesites estos componentes, los debes destruir. Esto es justo al final del evento onExecute del tcpServer.

En ambos casos, debes relacionar de alguna forma cada componente que creas con el hilo correspondiente, de tal forma que cuando un hilo finaliza su ejecución sepas qué componentes has de destruir.

Otra cosa que te recomiendo, es que incluyas un try-except en tu evento onExecute, englobando todo el código, para que puedas controlar mejor la destrucción de los componentes que creas y no se te quede ninguno cargado en memoria.

Espero haberte ayudado de alguna forma.

Si tienes más dudas, pregunta sin problemas.

un saludo.

[richy08]

Empezado por manuc

Hola richy08,

En ambos casos, debes relacionar de alguna forma cada componente que creas con el hilo correspondiente, de tal forma que cuando un hilo finaliza su ejecución sepas qué componentes has de destruir.

un saludo.

gracias manuc ahora tengo mas claro el comportamiento de los hilos, solo me queda una ultima duda en el codigo arriba les voy dando un nombre a cada componenete, que se compone del nombre de la maquina+'caracter', pero al intentar accederlo por su nombre no logro hacerlo alguna otra idea de como podria distinguir que componnete se creo en cada hilo, o como poderlo acceder por el nombre que le he asignado.

saludos

[manuc]

Hola Richy08,

Pues sí, alguna te puedo dar.

Este código puede ser un poco más complicado de seguir al principio, pero creo que el más cómo, una vez lo tengas claro.

1.- Te Creas una nueva clase, para manejar tus componentes:

Código Delphi [-]
type
  tmisComponentes=Class(tPersistent)
  private
   fConexion:TSQLConnection;
   fQuery:TDataSet;
  Public
   destructor Destroy;
   property Conexion:TSQLConnection read fConexion write fConexion;
   property Query:TDataSet read fQuery write fQuery;
  end;

Cambia el tipo de componetes que quieras crear.

2.- Al recibir la conexión en el tcpServer Creamos los componentes:

Código Delphi [-]
procedure TForm1.IdTCPServer1Connect(AThread: TIdPeerThread);
var
 MisComponentes:tmisComponentes;
begin
 MisComponentes := tmisComponentes.Create;
 MisComponentes.Conexion := TSQLConnection.Create(self);
 MisComponentes.Query := TDataSet.Create(Self);

 AThread.Data := @MisComponentes;

end;

3.- ¿Cómo usarlos?

Código Delphi [-]
procedure TForm1.IdTCPServer1Execute(AThread: TIdPeerThread);
var
 MisComponentes:tmisComponentes;
begin
 MisComponentes :=  tmisComponentes(AThread.Data);

 MisComponentes.Query ....

end;

4.- Como destruirlos:

Código Delphi [-]
procedure TForm1.IdTCPServer1Disconnect(AThread: TIdPeerThread);
var
 MisComponentes:tmisComponentes;
begin
 MisComponentes :=  tmisComponentes(AThread.Data);

 MisComponentes.Conexion.Free;
 MisComponentes.Query.Free;

 ...

end;

Básicamente, lo que se haces es "recordar" la dirección de memoria donde están localizados los componentes, utilizando para ello un "puntero" que tiene cada conexión (.data).

Lo he hecho de cabeza y sin compilarlo. Puede ser que me haya equivocado en algo, pero básicamente lo puedes hacer así.

Si encuentra alguna duda, consulta sin problemas.

Un saludo.

[richy08]

gracias manuc tratare de implementarlo asi y comento.

[richy08]

hola manuc perdon por responder hasta ahora peor me habian asignado otras tareas sabes he estado haciendo pruebas sobre la red, y los sockets abren y cierran perfectamente pero al devolver por el hilo el mensaje de que el procedimiento se llevo acabo bien nunca ejecuta ningun query ni devuelve le mensaje, es justo en este pedazo de codigo, me podrias orientar si es que me hace falta algo, este codigo lo tome del ejemplo de IdTCPDemo, gracias

Código Delphi [-]
procedure TFrm_Interfaces.ServerExecute(AThread: TIdPeerThread);
var
  ActClient, RecClient: PClient;                                                                              
  CommBlock, NewCommBlock: TCommBlock;
  RecThread: TIdPeerThread;
  i: Integer;
begin
  if not AThread.Terminated and AThread.Connection.Connected then
  begin
    AThread.Connection.ReadBuffer (CommBlock, SizeOf (CommBlock));
    ActClient := PClient(AThread.Data);
    ActClient.LastAction := Now;  // update the time of last action

    CreaAdo(CommBlock.MyUserName, CommBlock.nombre, CommBlock.acode, CommBlock.estado);

    Protocol.Lines.Add (TimeToStr(Time)+' The process for '+CommBlock.MyUserName+' was done ');// # Confirm'+inttostr(CommBlock.nconf));
    NewCommBlock.Command := 'DIALOG';       // the message should popup on the client's screen
    NewCommBlock.MyUserName := '[PBX Server]';  // the server's username
    NewCommBlock.Msg := 'The process was done  ';  // the message to show
    NewCommBlock.ReceiverName := '[return-to-sender]'; // unnecessary
                                                                                                                                           
    AThread.Connection.WriteBuffer (NewCommBlock, SizeOf (NewCommBlock), true);  // and there it goes...
  end;
end;

[richy08]

sabes creo que mas bien el problema radica en este pedazo de codigo que corre en el cliente

Código Delphi [-]
procedure TClientHandleThread.Execute;
begin
  while not Terminated do
  begin
    if not Frm_Posgue.Client.Connected then
      Terminate
    else
    try
      Frm_Posgue.Client.ReadBuffer(CB, SizeOf (CB));
      Synchronize(HandleInput);
    except
    end;
  end;
end;

ya que al llegar a esta linea Frm_Posgue.Client.ReadBuffer(CB, SizeOf (CB)); por alguna razon no manda llamar el Synchronize alguna pista de que pueda ser gracias por cualquier comentario