Code:

var
  Form1: TForm1;
  tr: tNewThread;

implementation

{$R *.dfm}

procedure TForm1.Button1Click(Sender: TObject);
begin
   tr := tNewThread.Create(ibd, 1);   
end;

procedure TForm1.Button2Click(Sender: TObject);
begin
   tr.StopRuning;
   tr.Terminate;
end;

Code:

unit UnitThread;

interface
uses
  Classes, SysUtils, ComCtrls, Windows, DB, IBDatabase, IBCustomDataSet, IBQuery, ExtCtrls;
  
type  
  tNewThread = class(TTHread)
  private
     qr: TIBQuery;
     tr: TIBTransaction;
     da: TIBDatabase;
     ti: TTimer;
     InExec: boolean;
    procedure TimerExec(Sender: TObject);
  protected
     procedure Execute; override;  
  public          
      constructor Create(DataBase: TIBDatabase; IntervalSec: integer=10); reintroduce;
      destructor Destroy;
      procedure Terminated(Sender: TObject);
      procedure StopRuning;
  end;

implementation

{ tNewThread }

constructor tNewThread.Create(DataBase: TIBDatabase; IntervalSec: integer);
var i: integer;
begin
   inherited Create(false);
   self.FreeOnTerminate := true;
   InExec := false;
   OnTerminate := Terminated;
   // kreiranje baze za konekciju
   da := TIBDatabase.Create(nil);
   da.DatabaseName := DataBase.DatabaseName;
   da.Name := 'DatabaseTH';
   da.LoginPrompt := false;
   da.SQLDialect := 3;
   for i := 0 to DataBase.Params.Count-1 do
      da.Params.Append(DataBase.Params.Strings[i]); 
      
   // kreiranje transakcije   
   tr := TIBTransaction.Create(nil);
   tr.DefaultDatabase := da;
   tr.AllowAutoStart := true;
   tr.DefaultAction := TACommit;
   tr.Name := 'TeansactionTH';
   tr.Params.Append('read_committed');
   tr.Params.Append('rec_version');
   tr.Params.Append('nowait');
   da.DefaultTransaction := tr;

   // kreiranje qr-y
   qr := TIBQuery.Create(nil);
   qr.Database := da;
   qr.Transaction := tr;
   qr.Name := 'QryTH';
   qr.SQL.Append('select * from termini_kategorija');

   ti := TTimer.Create(nil);
   ti.OnTimer := TimerExec;
   ti.Interval := IntervalSec * 1000;
   ti.Name := 'TimerTH';
   ti.Enabled := true;
end;

destructor tNewThread.Destroy;
begin
   ti.Enabled := false;
   // ako je pokrenuta procedure, čekaj da završi...
   while InExec do Sleep(1000);
   ti.Free;
   if qr.Active then qr.Close;
   if tr.Active then tr.Rollback;
   if da.Connected then da.Close;
   tr.Free;
   qr.Free;
   da.Free;
   inherited;
end;

procedure tNewThread.Execute;
begin
  inherited;
  ti.Enabled := false;
  InExec := true;
  if not da.Connected then da.Open;
  if not tr.Active then tr.StartTransaction;
  qr.Open;
  qr.Close;
  InExec := false;
  ti.Enabled := true;
end;

procedure tNewThread.StopRuning;
begin
   ti.Enabled := false;
end;

procedure tNewThread.Terminated(Sender: TObject);
begin
   ti.Enabled := false;
end;

procedure tNewThread.TimerExec(Sender: TObject);
begin
   if not InExec then self.Execute;
end;

end.

Code:


procedure TMyThread.Execute;
var
  Temp: Cardinal;
begin
  while not Terminated do
  begin
    if GetTickCount - Temp > 10000 then
    begin
      qry.Open;
      qry.Close;
      Temp := GetTickCount;
    end;

    Sleep(100);
  end;
end;

Code:

procedure tNewThread.Execute;
var
  t1: TDateTime;
  t2: Cardinal;
begin
  while not Terminated do
  begin
    t1 := now;
    if not da.Connected then da.Open;
    if not qr.Transaction.Active then qr.Transaction.StartTransaction;
    try
      qr.Open;
      qr.Close;
    except
    end;
    // SQL qr-a je zadan kao vanjski parametar u Create proceduri
    if qr.Transaction.Active then qr.Transaction.Rollback;
    t2 := MilliSecondsBetween(now, t1);
    // fInterval je određen u Create proceduri - zadan kao vanjski parametar.
    if (fInterval - t2) > 0 then  Sleep(fInterval - t2);
  end;
end;

Code:

   if CuvaVezu = nil then begin
      CuvaVezu := tNewThread.Create(ibRadna, 'select * from termini_kategorija', 60)
    end else begin
       try
          CuvaVezu.Resume;
       except
       end;
    end;

Code:

unit UnitThread;

interface
uses
  Classes, SysUtils, Windows, IBDatabase, IBQuery;
  
type  
  tNewThread = class(TTHread)
  private
     qr: TIBQuery;
     tr: TIBTransaction;
     da: TIBDatabase;
     fInterval: integer;
  protected
     procedure Execute; override;  
  public          
      constructor Create(DataBase: TIBDatabase; SQLText: string; IntervalSec: integer); reintroduce;
      destructor Destroy; override;
  end;

implementation

{ tNewThread }

constructor tNewThread.Create(DataBase: TIBDatabase; SQLText: string; IntervalSec: integer);
var i: integer;
begin
   inherited Create(false);
   fInterval := IntervalSec * 1000;
   self.FreeOnTerminate := true;
   // kreiranje baze za konekciju
   da := TIBDatabase.Create(nil);
   da.DatabaseName := DataBase.DatabaseName;
   da.Name := 'DatabaseTH';
   da.LoginPrompt := false;
   da.SQLDialect := 3;
   for i := 0 to DataBase.Params.Count-1 do
      da.Params.Append(DataBase.Params.Strings[i]); 
      
   // kreiranje transakcije   
   tr := TIBTransaction.Create(nil);
   tr.DefaultDatabase := da;
   tr.AllowAutoStart := true;
   tr.DefaultAction := TACommit;
   tr.Name := 'TeansactionTH';
   tr.Params.Append('read_committed');
   tr.Params.Append('rec_version');
   tr.Params.Append('nowait');
   da.DefaultTransaction := tr;

   // kreiranje qr-y
   qr := TIBQuery.Create(nil);
   qr.Database := da;
   qr.Transaction := tr;
   qr.Name := 'QryTH';
   qr.SQL.Append(SQLText);
end;

destructor tNewThread.Destroy;
begin
   if tr.Active then tr.Rollback;
   if da.Connected then da.Close;
   tr.Free;
   qr.Free;
   da.Free;
   inherited;
end;

procedure tNewThread.Execute;
var
  Temp: Cardinal;
begin
  while not Terminated do
  begin
    if not da.Connected then da.Open;
    if not qr.Transaction.Active then qr.Transaction.StartTransaction;
    try
      qr.Open;
      qr.Close;
    except
    end;
    if qr.Transaction.Active then qr.Transaction.Rollback;
    Temp := GetTickCount;
    while (not Terminated) and ((GetTickCount - Temp) < fInterval) do begin
      Sleep(100);
    end;
  end;
end;

end.

Code:

    Temp := GetTickCount;
    while (not Terminated) and ((GetTickCount - Temp) < fInterval) do begin
      Sleep(100);
    end;

Code:

  procedure SmartSleep(aInterval: cardinal);
  var
    aTick: cardinal;
  begin
    aTick := GetTickCount + aInterval;
    while not(Terminated) and (GetTickCount < aTick) do
      Sleep(100);
  end;