Firebird con Threads

[Jack]

Hola a todos. Estoy últimando una aplicación multihilo tipo servidor de ficheros.
Todo marcha bien al arrancar cada hilo de ejecución. La secuencia es la siguiente: crea basedatos, crea tabla, crea transacion, ejecuta selectsql y devuelve el resultado.
Cuando arranca un segundo hilo y el primer hilo no ha acabado, este segundo hilo se congela, justo en una de estas sentencias database.connected := true, transaction.starttransaction, tabla.active := true indistintamente. Es decir que cuando hago algún movimiento efectivo sobre firebird 1.5 el segundo hilo se cuelga, bueno la verdad es que se cuelgan todos los hilos.
He probado de todo, con variables de tipo FList, cambiando los componentes de los ibx a los UIB( decían en internet que estos eran los únicos thread-safe que existen ), cambiando el firebird 1.5 de superserver a classic y nunca he conseguido ningún resultado, siempre la congelación.
He leído algunos hilos del foro hablando del tema pero sin dar ninguna solución viable.
Si alguien puede dar alguna pista se agradecería.
Un saludo

[Caral]

Hola
Pregunto:
No sera que firebird necesita hacer un Commit o un Commitretained para que se cierre la tabla ?.
Saludos

[Chris]

Hola compañero Jack!

Primero, supongo que estás utilizando un componente de conexión, llamese TDatabase, distinto para cada hilo y en mejor manera, una copia para cada hilo de cada componente utilizado en la conexión. Si es así, entonces el problema está en la biblioteca cliente de Firebird (fbclient.dll). Tengo entendido que esta biblioteca no soporta multi hilos hasta la versión 2.5 de Firebird.

Si es posible, intenta hacer tus pruebas con una versión más reciente de la biblioteca cliente o en última instancia, con una versión más reciente del servidor Firebird.

Saludos,
Chirs

[gluglu]

Yo trabajo con múltiples Thread's en FB 2.1 sin problemas.

Tienes que asegurarte 100% de que tanto el TIBDatabase, como TIBTransaction y los TIBDataSet que utilices sean UNICOS e independientes para cada Thread. Se deben de crear en cada Thread que vayas a utilizar y se deben de liberar igualmente en cada Thread.

[Jack]

Gracias a todos por responder.
Cambie la base de datos a la versión 2.5 y comprobé con varios tipos de modos de transacción. Obtuve los mismos resultados.
Para gluglu: he hecho exactamente lo que tu dices y lo único que he logrado es que se cuelgue la primer hilo y que arranque el segundo pero nunca los dos a la vez. Te agradecería un poco mas de información de como lo has podido resolver. Gracias de antemano. Un saludo. Jack

[gluglu]

Por lo que indicas, no haga nada diferente a lo que tu haces, al menos en referencia a crear y eliminar, tanto la BBDD como la transacción como las tablas a utilizar dentro del Thread.

También debes de considerar otro tema muy importante : No puedes hacer ninguna operación con estos componentes que afecten a algo externo al Thread, m explico, no puedes intentar actualizar algo en pantalla o utilizar un dato obtenido en el thread con estos componentes, si no es a través del método Syncronize.

Indícame por favor cómo devuelves los datos que has obtenido dentro del Thread a tu aplicación principal, y a ver si podemos aclarar algo más. :rolleyes:

[gluglu]

... añado ....

También podrías ejecutar tu aplicación en modo Debug, e ir mirando paso por paso las líneas que va ejecutando, tanto de tu aplicación principal como del Thread.

Así podrías ver exactamente en qué sentencia se queda 'congelado' el Thread, y probablemente sirva para entender mejor el problema.

[Chris]

Sería bueno que nos compartieras algo de código Jack. Pero también busca usos del procedimiento Synchronize, un mal uso de este procedimiento puede dar resultados como el que estás teniendo.

Saludos,
Chris

[Jack]

Lo he probado todo lo que me habéis dicho y todo continua igual, no entiendo que pasa ...

[Chris]

Qué componentes estás utilizando para hacer la conexión?

[gluglu]

Como dice Chris ...., si compartieras algo de código, probablemente te podamos ayudar mejor. Si no, simplemente estás indicando que no te funciona.

[Casimiro Notevi]

Como dicen mis compañeros: ¡¡¡ El código !!! ;)

Es que no nos funciona la bola de cristal usb ;)

[Jack]

He tenido que confeccionar un código nuevo porque tenía el otro empotrado en toda la aplicación y me parecía muy difícil de poner todo.
Ahí va la unidad nueva entera:
Y gracias de antemano por la contestación. Un saludo.


unit Unit1;

interface

uses
Windows, Messages, SysUtils, Classes, Graphics, Controls, Forms, Dialogs,
StdCtrls, Buttons, Button2011, IBDataBase, IBCustomDataSet;


type
THilo = class(TThread)
private
DataBase: TIBDataBase;
Tabla: TIBDataSet;
procedure ActualizaMemo;
public
CadenaMostrar: string;
constructor Create( Suspendido: Boolean );
procedure Execute; override;
end;



type
THPrueba = class(TForm)
Button20111: TButton2011;
Memo1: TMemo;
procedure Button20111Click(Sender: TObject);
private
{ Private declarations }
public
{ Public declarations }
end;

var
HPrueba: THPrueba;

implementation

{$R *.DFM}

procedure THilo.Execute;
begin
// Aqui no tengo mu claro lo que tengo que poner
{ while Self.Terminated = False do
Self.Synchronize;}
end;


constructor THilo.Create( Suspendido: Boolean );
begin
inherited Create( True );
// Quizas tuviera que crear un objeto TList con un database, transaction y tabla
// para cada ejecución del hilo
DataBase := TIBDataBase.Create( nil );
DataBase.DataBaseName := 'C:\DATOS\BASEDATOS.FDB';
DataBase.LoginPrompt := False;
DataBase.Params.Clear;
DataBase.Params.Add( 'user_name=sysdba' );
DataBase.Params.Add( 'password=masterkey' );
DataBase.Connected := True;
//
Tabla := TIBDataSet.Create( nil );
Tabla.DataBase := DataBase;
Tabla.Transaction := TIBTransaction.Create( nil );
Tabla.Transaction.DefaultDataBase := DataBase;
Tabla.Transaction.Params.Clear;
Tabla.Transaction.Params.Add( 'read_committed' );
Tabla.Transaction.Params.Add( 'rec_version' );
Tabla.Transaction.Params.Add( 'nowait' );
Tabla.Transaction.StartTransaction;
Tabla.SelectSQL.Clear;
Tabla.SelectSQL.Add( 'select Codigo, Denominacion from Apuntes' );
Tabla.SelectSQL.Add( 'where Periodo = 2010' );
Tabla.Active := True;
while not Tabla.Eof do begin
CadenaMostrar := Tabla.Fields[ 0 ].AsString + ' ' +
Tabla.Fields[ 1 ].AsString;
Synchronize( ActualizaMemo );
Tabla.Next;
end;
end;

procedure THilo.ActualizaMemo;
begin
HPrueba.Memo1.Lines.Add( CadenaMostrar );
end;





procedure THPrueba.Button20111Click(Sender: TObject);
var Hilo: THilo;
begin
Hilo := THilo.Create( True );
Hilo.Execute;
Hilo := THilo.Create( True );
Hilo.Execute;

end;

end.

[gluglu]

Bueno ....

A ver .... a falta de mejores criterios de otros compañeros del foro, veo algunos errores básicos de concepto ! :o

Empecemos por el más grave :

procedure THPrueba.Button20111Click(Sender: TObject);
var Hilo: THilo;
begin
Hilo := THilo.Create( True );
Hilo.Execute;
Hilo := THilo.Create( True );
Hilo.Execute;

Sin duda alguna, y con el 10000% de seguridad, esto se te va a quedar colgado siempre y en todas las ocasiones.

Estás declarando una variable Hilo, que utilizas dos veces y como no, se tiene que quedar colgado a la fuerza. No puedes utilizar la misma variable para dos Thread's diferentes que además se están ejecutando a la vez.

O bien declarar una variable Hilo1 y otra Hilo2, o si vas a crear una lista grande de Threads, lo que te recomiendo es que te crees un Array de THilo.

En primer lugar, probaría con dos variables diferentes, al menos para comprobar que tu código funciona, y ya después te puedes plantear la creación de un Array.

procedure THPrueba.Button20111Click(Sender: TObject);
var Hilo1, Hilo2: THilo;
begin

Hilo1 := THilo.Create( True );
Hilo1.FreeOnTerminate := True;
Hilo1.Resume;

Hilo2 := THilo.Create( True );
Hilo2.FreeOnTerminate := True;
Hilo2.Resume;

end;

Además no se llama al procedimiento Execute del propio hilo de manera directa (o al menos yo tampoco lo hago), sino al procedimiento Resume que a su vez ejecutará el Execute del hilo.

Si Hilo1 e Hilo2 tienen que estar accesibles en otra parte de tu Form, tendrías que declarar ambas variables en el apartado 'var' del Form.

var
HPrueba: THPrueba;
Hilo1: THilo;
Hilo2: THilo;

Siguiente tema : Aunque queda claro que declaras y creas la BBDD y la tabla como parte del Hilo, personalmente incluiría también en cualquier caso la delcaración de la Transacción :

type
THilo = class(TThread)
private
DataBase: TIBDataBase;
Transaccion : TIBTransaction;
Tabla: TIBDataSet;
procedure ActualizaMemo;
public
CadenaMostrar: string;
constructor Create( Suspendido: Boolean );
protected
procedure Execute; override;
end;

Nunca lo he visto así, y no sé si puede o no dar problemas, pero nunca he visto ni utilizado un Constructor declarado en el propio Thread. En todas mis declaciones de Thread's, además el procedimiento Execute lo tengo en el apartado de declaraciones 'Protected'.

Al no utilizar nunca un Constructor, toda la creación de la BBDD, transacción y tablas, yo las meto en el propio Execute.

procedure THilo.Execute;
begin

// Aqui no tengo mu claro lo que tengo que poner
{ while Self.Terminated = False do
Self.Synchronize;}

// Quizas tuviera que crear un objeto TList con un database, transaction y tabla
// para cada ejecución del hilo

//Como ya te indiqué, no tienes que crear un Tlist para cada uno de los elementos que indicas, sino
// tienes que crear un Array o TList para cada Hilo en sí.

DataBase := TIBDataBase.Create( nil );
DataBase.DataBaseName := 'C:\DATOS\BASEDATOS.FDB';
DataBase.LoginPrompt := False;
DataBase.Params.Clear;
DataBase.Params.Add( 'user_name=sysdba' );
DataBase.Params.Add( 'password=masterkey' );
DataBase.Connected := True;

Transaccion := TIBTransaction.Create( nil );
Transaccion.DefaultDataBase := DataBase;
Transaccion.Params.Clear;
Transaccion.Params.Add( 'read_committed' );
Transaccion.Params.Add( 'rec_version' );
Transaccion.Params.Add( 'nowait' );

Tabla := TIBDataSet.Create( nil );
Tabla.DataBase := DataBase;
Tabla.Transaction := Transaccion;
Tabla.Transaction.StartTransaction;
Tabla.SelectSQL.Clear;
Tabla.SelectSQL.Add( 'select Codigo, Denominacion from Apuntes' );
Tabla.SelectSQL.Add( 'where Periodo = 2010' );
Tabla.Active := True;

while not Tabla.Eof do begin
CadenaMostrar := Tabla.Fields[ 0 ].AsString + ' ' + Tabla.Fields[ 1 ].AsString;
Synchronize( ActualizaMemo );
Tabla.Next;
end;

Tabla.Close;
Transaccion.Active := False;
Database.Close;

DataBase.Free;
Transaccion.Free;
Tabla.Free;

Terminate;

end;

La llamada a Synchronize(ActualizaMemo), en principio me parece correcta, al igual que la propia ejecución del procedimiento ActualizaMemo.

Intenta de momento hacer estos cambios que te propongo, a ver si así ya vas mejorando y si hace falta algo más, ya te intentamos ayudar posteriormente.

Un saludo ;)

P.D. Se me olvidaba, también muy importante, debes de liberar todos los elementos creados, dentro del propio Thread.

[gluglu]

Además me gustaría comentarte que si realizas una búsqueda sobre Thread's o Hilos en los foros, te encontrarás mucha información al respecto, entre otras : http://www.clubdelphi.com/foros/showthread.php?p=390534&highlight=Thread#post390534

En ese hilo también se hace referencia a varios temas que sobre este asunto ha puesto nuestro compañero Neftali.

[Chris]

Inderectemente el compañero Gluglu te he dicho el problema que tienes. A parte de todo lo que ha mencionado, te diré que el problema radica en que estás escribiendo la lógica en el procedimiento Create (el constructor). Tienes que saber que el constructor de la clase TThread se ejecuta en el mismo hilo principal de la aplicación. Es por eso que estás experimentando cómo si estuvieras utilizando un sólo hilo. Tienes que mover todo el código de lógica al procedimiento Execute. El código de Execute y cualquier otro procedimiento que él llame si es ejecutado en un hilo separado. Espero que me halla podido dar a entender lo que te quise decir, y que siempre lo tengas en cuenta cuando vuelvas a escribir código multihilo.

Saludos,
Chris

[Jack]

Cris cambie todo el código al metodo execute del hilo.
Gracias por la puntualización del método create del thread, seguro que me servirá para futuras ocasiones.
Ahora se me ha quedado como te indico abajo, pero además he cambiado los componentes de la conexión a los zeos creo que es la versión 6 y además he cambiado de firebird a mssql y tampoco me funciona. No se que pasa, estaría conformado si no se pudiera hacer en ningún caso pero es que he leído que hay algunos programadores que consiguen realizar justamente lo que yo necesito. Me encuentro un poco frustrado llevo muchos días con este problema y no le veo la punta por ningún lado.
Ahí te pongo el nuevo código a ver si me dais alguna pista.
He puesto un timer y dos conexiones con nombre diferente para asegurarme que los componentes son diferentes y se ejecutan los dos a la vez.
El método vermensaje me indica justa en que linea se para el código , en este caso devuelve un error de dirección de memoria.
Muchas gracias de antemano.


unit Unit1;

interface

uses
Windows, Messages, SysUtils, Classes, Graphics, Controls, Forms, Dialogs,
StdCtrls, Buttons, Button2011, IBDataBase, IBCustomDataSet, ExtCtrls,
ZConnection, Db, ZAbstractRODataset, ZAbstractDataset, ZDataset;


type
THilo = class(TThread)
private
DataBase: TZConnection;
Tabla: TZQuery;
DataBase1: TZConnection;
Tabla1: TZQuery;
procedure ActualizaMemo;
procedure PonTag;
procedure VerMensaje;
public
CadenaMostrar: string;
constructor Create( Suspendido: Boolean );
procedure Execute; override;
end;



type
THPrueba = class(TForm)
Button20111: TButton2011;
Memo1: TMemo;
Timer1: TTimer;
ZConnection1: TZConnection;
ZQuery1: TZQuery;
procedure Button20111Click(Sender: TObject);
procedure Timer1Timer(Sender: TObject);
private
{ Private declarations }
public
{ Public declarations }
end;

var
HPrueba: THPrueba;

implementation

{$R *.DFM}

procedure THilo.Execute;
begin
// Aqui no tengo mu claro lo que tengo que poner
while Self.Terminated = False do begin
if HPrueba.Tag = 0 then begin
Synchronize( PonTag );
DataBase := TZConnection.Create( nil );
DataBase.Protocol := 'mssql';
DataBase.DataBase := 'BASE2011QO';
DataBase.HostName := 'NUEVOJACK\SQLEXPRESS';
DataBase.LoginPrompt := False;
DataBase.Password := '';
DataBase.User := '';
DataBase.Connected := True;
//
Tabla := TZQuery.Create( nil );
Tabla.Connection := DataBase;
Tabla.SQL.Clear;
Tabla.SQL.Add( 'select * from Articulo' );
Tabla.Active := True;
while not Tabla.Eof do begin
CadenaMostrar := Tabla.Fields[ 0 ].AsString + ' ' +
Tabla.Fields[ 1 ].AsString;
Synchronize( ActualizaMemo );
sleep( 1000 );
Tabla.Next;
end;
end
else begin
Cadenamostrar := 'ooooooo';
Synchronize( ActualizaMemo );
DataBase1 := TZConnection.Create( nil );
DataBase1.Protocol := 'mssql';
DataBase1.DataBase := 'BASE2011QO';
DataBase1.HostName := 'NUEVOJACK\SQLEXPRESS';
DataBase1.LoginPrompt := False;
DataBase1.Password := '';
DataBase1.User := '';
DataBase1.Connected := True; // Aqui se cuelga

Synchronize( Vermensaje );
//
Tabla1 := TZQuery.Create( nil );
Tabla1.Connection := DataBase;
Tabla1.SQL.Clear;
Tabla1.SQL.Add( 'select * from Articulo' );
Tabla1.Active := True;
while not Tabla1.Eof do begin
CadenaMostrar := Tabla1.Fields[ 0 ].AsString + ' ' +
Tabla1.Fields[ 1 ].AsString;
Synchronize( ActualizaMemo );
sleep( 1000 );
Tabla1.Next;
end;
end;
end;
end;


constructor THilo.Create( Suspendido: Boolean );
begin
inherited Create( True );
// Quizas tuviera que crear un objeto TList con un database, transaction y tabla
// para cada ejecución del hilo
end;

procedure THilo.ActualizaMemo;
begin
HPrueba.Memo1.Lines.Add( CadenaMostrar );
end;

procedure THilo.PonTag;
begin
HPrueba.Tag := 1;
end;

procedure THilo.VerMensaje;
begin
showmessage( 'pp' );
end;




procedure THPrueba.Button20111Click(Sender: TObject);
var Hilo: THilo;
begin
Hilo := THilo.Create( True );
Hilo.FreeOnTerminate := False;
Hilo.Resume;
Timer1.Enabled := True;
end;

procedure THPrueba.Timer1Timer(Sender: TObject);
begin
Button20111Click( Self );
Timer1.Enabled := False;

end;

end.

[Chris]

He revisado tu código. Generalmente no he visto ningún problema en él. Pero si lo he reducido para empezar a "debuguear" desde él:

Prueba este código y cualquier error, comparte en gran detalle toda la información del error que se presente, la clase de la excepción, el mensaje y la línea. Por allí ay que empezar

unit Unit1;

interface

uses
Windows, Messages, SysUtils, Classes, Graphics, Controls, Forms, Dialogs,
StdCtrls, Buttons, Button2011, IBDataBase, IBCustomDataSet, ExtCtrls,
ZConnection, Db, ZAbstractRODataset, ZAbstractDataset, ZDataset;


type
THilo = class(TThread)
private
procedure ActualizaMemo;
procedure PonTag;
public
CadenaMostrar: string;
constructor Create( Suspendido: Boolean );
procedure Execute; override;
end;

THPrueba = class(TForm)
Button20111: TButton2011;
Memo1: TMemo;
Timer1: TTimer;
ZConnection1: TZConnection;
ZQuery1: TZQuery;
procedure Button20111Click(Sender: TObject);
procedure Timer1Timer(Sender: TObject);
end;

var
HPrueba: THPrueba;

implementation

// TODO: lee en la ayuda de Delphi sobre "Threadvar"
threadvar
ZConnection; TZConnection;
ZQuery: TZQuery;

{$R *.DFM}

{ ~~~~~~~~~~~~~~~~~~~~ THilo ~~~~~~~~~~~~~~~~~~~~ }

constructor THilo.Create( Suspendido: Boolean );
begin
inherited Create( Suspendido );
// Quizas tuviera que crear un objeto TList con un database, transaction y tabla
// para cada ejecución del hilo
// R:/ NO ES NECESARIO, HASTA DÓNDE VEO TU CASO, ADEMÁS TE COMPLICARÍAS LAS COSAS.
end;

procedure THilo.Execute;
begin
try
ZConnection = TZConnection.Create(nil);
ZQuery := TZQuery.Create(nil);

with ZConnection do
begin
Protocol := 'mssql';
DataBase := 'BASE2011QO';
HostName := 'NUEVOJACK\SQLEXPRESS';
LoginPrompt := False;
Password := '';
User := '';
Connected := True;
end;

with ZQuery do
begin
Connection := DataBase;
SQL.Clear;
SQL.Add( 'select * from Articulo' );
Active := True;

while not EoF do
begin
CadenaMostrar := (Fields[ 0 ].AsString + ' ' + Fields[ 1 ].AsString);
Synchronize( ActualizaMemo );
Sleep( 300 );
Next;
end;
end;

finally
ZConnection.Free;
ZQuery.Free;
end;
end;


procedure THilo.ActualizaMemo;
begin
HPrueba.Memo1.Lines.Add( CadenaMostrar );
end;

procedure THilo.PonTag;
begin
HPrueba.Tag := 1;
end;

{ ~~~~~~~~~~~~~~~~~~~~ THPrueba ~~~~~~~~~~~~~~~~~~~~ }

procedure THPrueba.Button20111Click(Sender: TObject);
var Hilo: THilo;
begin
Hilo := THilo.Create( True );
Hilo.FreeOnTerminate := False;
Hilo.Resume;
Timer1.Enabled := True;
end;

procedure THPrueba.Timer1Timer(Sender: TObject);
begin
Button20111Click( Self );
Timer1.Enabled := False;
end;

end.

Este es tu mismo código, con la misma funcionalidad, nada más que acortado y adaptado para que sea más entendible (por lo menos desde mi punto de vista :P)

Saludos,
Chris

[gluglu]

:( :( :( ... me siento absoluta y totalmente ignorado !

.... bueno, allá vosotros !

Aun así, os vuelvo a indicar que el código expuesto es imposible que funcione correctamente, ya cambies a Oracle o a superbasededatos Ver 1000.1, oc ambies igualmente cualquier componente a supercomponentes Ver 2021.7.

De nuevo os indico los errores, según mi punto de vista, la mayoría de ellos ya los comenté anteriormente :

THilo = class(TThread)
private
procedure ActualizaMemo;
procedure PonTag;
public
CadenaMostrar: string;
// Olvídate de este Constructor
constructor Create( Suspendido: Boolean );
// Indica que el procedimiento Execute está en protected
protected
procedure Execute; override;
end;

El Thread debe de ser TOTALMENTE encapsulado. A lo mejor a la primera no da problemas, pero a ls segunda o tercera, seguro que dá problemas ...

procedure THilo.Execute;
begin
// Aqui no tengo mu claro lo que tengo que poner
while Self.Terminated = False do begin
if HPrueba.Tag = 0 then begin
Synchronize( PonTag );

No debes de acceder a una Variable de HPrueba dentro del propio Thread.

Por qué os empeñais en crear dos hilos diferentes con el mismo nombre de la variable ?
procedure THPrueba.Button20111Click(Sender: TObject);
var Hilo: THilo;
begin
Hilo := THilo.Create( True );
Hilo.FreeOnTerminate := False;
Hilo.Resume;
Timer1.Enabled := True;
end;

Por mucho que lo ejecuteis después en un Timer, el Thread se vuelve a crear dentro de Button20111Click con el mismo nombre de la variable, y eso os va a dar problemas porque en ningún caso va a saber referenciar correctamente cualquier llamada.

Por qué no probais :
procedure THPrueba.Timer1Timer(Sender: TObject);
var Hilo2: THilo;
begin
Hilo2 := THilo.Create( True );
Hilo2.FreeOnTerminate := False;
Hilo2.Resume;
Timer1.Enabled := False;
end;


Saludos ... ! :rolleyes:

[gluglu]

Acabo de generar este código, con Firebird 2.1 y componentes IBX, y me funciona perfectamente, sin problema alguno :

unit Unit1;

interface

uses
Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
Dialogs, DB, IBCustomDataSet, IBDatabase, StdCtrls;

type

THilo = class(TThread)
private
Hilo_DataBase: TIBDatabase;
Hilo_Transact: TIBTransaction;
Hilo_Tabla: TIBDataSet;
procedure ActualizaMemo;
public
CadenaMostrar: string;
protected
procedure Execute; override;
end;

TForm1 = class(TForm)
IBDatabase1: TIBDatabase;
IBTransaction1: TIBTransaction;
IBDataSet1: TIBDataSet;
Memo1: TMemo;
Button1: TButton;
procedure Button1Click(Sender: TObject);
procedure FormCreate(Sender: TObject);
private
{ Private declarations }
Num_Hilo : Integer;
public
{ Public declarations }
end;

var
Form1: TForm1;
Hilo1: THilo;
Hilo2: THilo;

implementation
{$R *.dfm}

procedure THilo.Execute;
var
i, j : Integer;
Aux_Date, Aux_Date2 : TDateTime;
Aux_Valid : Boolean;
Count_Categ : Integer;
Count_SubCat : Integer;
begin

Hilo_Database := TIBDatabase.Create(nil);
Hilo_Database.DatabaseName := 'MiBasedeDatos';
Hilo_Database.LoginPrompt := False;
Hilo_Database.Params.Clear;
Hilo_Database.Params.Add( 'user_name=SYSDBA' );
Hilo_Database.Params.Add( 'lc_ctype=ISO8859_1' );
Hilo_Database.Params.Add( 'password=masterkey' );
Hilo_Database.SQLDialect := 3;
Hilo_Database.Connected := True;

Hilo_Transact := TIBTransaction.Create(nil);
Hilo_Transact.DefaultDataBase := Hilo_DataBase;
Hilo_Transact.DefaultAction := TARollback;
Hilo_Transact.Params.Clear;
Hilo_Transact.Params.Add( 'read_committed' );
Hilo_Transact.Params.Add( 'rec_version' );
Hilo_Transact.Params.Add( 'nowait' );
Hilo_Transact.StartTransaction;

Hilo_Tabla := TIBDataSet.Create(nil);
Hilo_Tabla.Transaction := Hilo_Transact;
Hilo_Tabla.SelectSQL.Clear;
Hilo_Tabla.SelectSQL.Add( 'Select NOMBRE, APELLIDO from CLIENTES' );
Hilo_Tabla.Prepare;
Hilo_Tabla.Open;

while not Hilo_Tabla.Eof do begin
CadenaMostrar := Hilo_Tabla.Fields[0].AsString + ' ' +
Hilo_Tabla.Fields[1].AsString;
Synchronize(ActualizaMemo);
Sleep(1000);
Hilo_Tabla.Next;
end;

Cadenamostrar := 'Fin de Fichero';
Synchronize(ActualizaMemo);

end;

procedure THilo.ActualizaMemo;
begin
Form1.Memo1.Lines.Add(CadenaMostrar);
end;

procedure TForm1.Button1Click(Sender: TObject);
begin

if Num_Hilo = 1 then begin
Hilo1 := THilo.Create( True );
Hilo1.FreeOnTerminate := False;
Hilo1.Resume;
Num_Hilo := 2;
end;

if Num_Hilo = 2 then begin
Hilo2 := THilo.Create( True );
Hilo2.FreeOnTerminate := False;
Hilo2.Resume;
end;

end;

procedure TForm1.FormCreate(Sender: TObject);
begin
Num_Hilo := 1;
end;

end.

[maeyanes]

Hola...

gluglu, este código:


procedure THPrueba.Button20111Click(Sender: TObject);
var
Hilo: THilo;

begin
Hilo := THilo.Create(True);
Hilo.FreeOnTerminate := False;
Hilo.Resume;
Timer1.Enabled := True
end;


se puede ejecutar las veces que quieras y no va a dar ningún problema, no se por que sigues diciendo que si. Es más, hasta se podría escribir así:


begin
with THilo.Create(True) do
begin
FreeOnTerminate := False;
Resume
end;
Timer1.Enabled := True
end;


y seguiría sin dar problemas. Esto claro, en el caso expuesto en el ejemplo. En algún otro caso, donde si necesites hacer referencia a algún hilo en particular, entonces si que se podría usar algún mecanismo para guardar estas referencias.



Saludos...

[gluglu]

Pues tienes toda la razón. Estoy equivocado. También funciona como indicas. Lo acabo de comprobar.

Tenía entendido que era 'necesario' tener diferentes referencias de cada hilo. Me queda claro que si no necesito hacer referencia desde otro sitio a ninguno de estos hilos en particular, no hace falta darle diferentes nombres.

... disculpas :o

[Jack]

gluglu tu código funciona perfecto, mil millones de gracias por tus indicaciones y agradecimiento a todos los que me han dado alguna pista.
Sólo me queda transformar este código para acoplarlo a la recepción y reenvio de datos via socket. Espero no tener ningún problema y poder averiguar donde estaba cometiendo el error que tantos quebraderos de cabeza me ha dado. Cuando lo tenga implementado y funcionando volveré a agradeceros a todos vuestras indicaciones. Un saludo Jack.

[aladelta]

Hola a todos,
Me gustaria hacerles una pregunta...¿se puede interactuar con una tabla creada dentro de un thread?, es decir, en los ejemplos precedentes se declara una database, transaccion y dataset, y la cuestion es si este dataset se puede poner en un dbgrid e interactuar con el dbgrid de forma habitual.
Yo actualmente trabajo en XE2 y firebird 2.5 con los componentes de DBExpress, y si esto se puede extrapolar a estos componentes, ¿podriamos abrir un tclientdataset de un datamodulo dentro de un Thread e interactuar con el en la forma descrita antes?
Gracias a todos por la ayuda.