Hallo...

Mein Kollege kam zu mir weil seine Datenbankanwendung zyklisch sekundenweise einfriert. Beim debuggen hab ich dann schnell herausgefunden, dass die Datenbankabfragen die Ursache dafür sind. Klarer Fall. Das muss gethreadded werden.

Doch auch mit Thread friert meine kleine Sandbox ein. Wie kann das denn angehen?

Bissl (unfertiger) Code:

zusammenfalten · markieren

Delphi-Quellcode:

type
  TUpdater = class(TThread)
  private
    FCnx: TZConnection;
    FQry: TZQuery;

    FCS: TCriticalSection;
    FRepository: CRepository;
    FObjects: TObjectList;
    FTable: String;
    FKlausel: String;

    destructor destroy;
  protected
    procedure Execute; override;
  public
    constructor create(CreateSuspended: Boolean);
  end;

zusammenfalten · markieren

Delphi-Quellcode:

procedure TUpdater.Execute;
var Instance: TKMicsRepository;
begin
  CoInitialize(nil); // Hab ich nach der Forensuche eingebaut - hat nichts bewirkt
  FQry.SQL.Clear;
  FQry.SQL.Add('SELECT * FROM '+FTable);

  if FKlausel <> '' then
    FQry.SQL.Add('WHERE '+FKlausel);

// Alles mögliche auskommentiert - friert trotzdem immernoch kurz ein...
// if Assigned(FCS) then
// FCS.Enter;
  try
    FQry.Open;
// FObjects.Clear;
    while not FQry.Eof do // ... und zwar genau hier
    begin
// Instance:=CRepository(FRepository).Create;
// Instance.readValue(FQry.Fields);
// FObjects.Add(Instance);
      FQry.Next;
    end;
  finally
// if Assigned(FCS) then
// FCS.Leave;
  end;
  FQry.Close;
  FCnx.Disconnect;
  CoUnInitialize;
  Self.Terminate;
end;

constructor TUpdater.create(CreateSuspended: Boolean);
begin
  inherited Create(CreateSuspended);

  FCnx:=TZConnection.Create(nil);
  FCnx.Protocol:= 'firebird-2.1';
  FCnx.HostName:= '192.168.200.5';
  FCnx.Database:= 'c:\firebird\test2.fdb';
  FCnx.User:= 'sysdba';
  FCnx.Password:= 'masterkey';
  FCnx.Properties.Clear;
  {..}

  FQry:=TZQuery.Create(nil);
  FQry.Properties.Clear;
  {..}
  FQry.Connection:=FCnx;
end;

destructor TUpdater.destroy;
begin
  freeAndNil(FCnx);
  freeAndNil(FQry);

  inherited Destroy;
end;

zusammenfalten · markieren

Delphi-Quellcode:

procedure TCachingTable.refresh;
var Updater: TUpdater;
begin
  Updater:=TUpdater.Create(true);
  Updater.FreeOnTerminate:=true;
  Updater.FCS:=FCS;
  Updater.FTable:=FTable;
  Updater.FKlausel:=FKlausel;
  Updater.FRepository:=FRepository;
  Updater.FObjects:=FObjects;
  Updater.Resume;

  while not Updater.Finished do
    Application.ProcessMessages;

  if Assigned(doUpdate) then
    doUpdate(self);
end;

Jemand noch ne Idee was das sein kann?

Gruß,

Toni

Zitat von Tonic1024:

markieren

Delphi-Quellcode:

  while not Updater.Finished do
    Application.ProcessMessages;

Ein Thread und ProcessMessages? Das sieht zumindest ungewöhnlich aus. Wie wäre es denn mit synchronisierten Events?

Naja, er soll ja ausschließlich die Usereingaben weiter ausführen. Ich hielt das für zweckmäßig. zu syncen gibts da nix. Es geht während er läuft (also zwischen Resume und Terminate) nix rein und nix raus.

[Edit]
Es geht mir nur darum während eines Datenbankzugriffs im Frontend Scrollbars bedienen zu können. In meiner Sandbox hab ich eine Combobox mit 200 Einträgen, die ich mit der Maus hoch und runter scrolle.
[/Edit]

Es geht darum, daß man in fremden Threads auf keine VCL-Dinge zugreift (außer man synchronisiert diese Zugriffe in den Hauptthread)

Und ProcessMessages hat in Threads sowieso nichts zu suchen.

markieren

Delphi-Quellcode:

while not Updater.Finished do
    Application.ProcessMessages;

das lass mal besser weg und reagiere auf das onThreadTerminate-Ereignis

Hi,
du gehst die Datenmenge ja einmal komplett durch?
Naja ich würde nach dem Open in dem Fall erstmal ein First machen vll hilft das?
Amsonsten fallen mir nur noch sowas wie Events ein die dran hängen
oder sowas wie CalcFields, weiss leider nicht wie dein FQry aussieht.

markieren

Delphi-Quellcode:

    while not FQry.Eof do// ... und zwar genau hier
     begin
 // Instance:=CRepository(FRepository).Create;
 // Instance.readValue(FQry.Fields);
 // FObjects.Add(Instance);
       FQry.Next;
     end;

Guten Morgen.

@himitsu: Das ist nicht IM Thread sondern eher außen herum in der GUI.

Hab das gestern nicht mehr geschafft auszuprobieren. Aber mit onTerminate klappts. Vielen Dank für den Hinweis. Unter D7 war das nie ein Problem. Ist das neu?

Gruß,

Toni

Du darfst bei Threads nicht wie üblich die (bzw. bestimmte) Felder im constructor initialisieren, sondern du darsft das erst in Execute. Hier geht es hauptsächlich um die DB-Kompos.

VErsuch dir folgende Strucktur anzugewöhnen:

zusammenfalten · markieren

Delphi-Quellcode:

procedure Tupdater.execute;
begin
  ConInitialize(nil);
  myConnection:=TxyzConnection.Create(...);
  myQuery:=...
  try
    eigentlicher_Thread_execute;
  finally
    myQuery.free;
    myConnection.free;
    coUninitialize;
  end;
end;
procedure Tupdater.eigentlicher_thread_execute;
begin
  ...
end;

Edit: Und die letzten 4 Zeilen in Refresh nimmst du bitte auch raus und löst das anders!
Es gibt z.B. das Ereignis onTerminate, dass du zuweisen kannst (auf doUpdate).

Zitat von sirius:

Edit: Und die letzten 4 Zeilen in Refresh nimmst du bitte auch raus und löst das anders!
Es gibt z.B. das Ereignis onTerminate, dass du zuweisen kannst (auf doUpdate).

Das war auch das Problem, wie ich oben geschildert hab. Und weil ich immer gern verstehe warum Dinge so sind wie sie sind, hatte ich nach dem Warum gefragt.

Toni