如何在工作线程上对 ClientDataSet 进行线程安全？

Question

我有一个非常慢的查询，总是让 Windows 将我的程序标记为无响应。我决定创建一个后台工作者来执行这个查询，而主线程显示一个 GIF。我做了一切，它的工作原理！ =D

但是...当我关闭我的表单时，我得到了一个 EInvalidPointer 异常，只有当我使用工作线程时。

这是我的代码：

主线程调用工作线程

if not TThreadDB.ExecutarThreadDB(cdsSolicitacao,
                                   FConsultaSql,
                                   nil,
                                   tpHigher) then
 begin
   Exit;
 end;

在哪里： cdsSolicitacao 是我想在线程之间共享的 clientDataSet， FConsultaSql 字符串（我的查询）

我的线程单元

unit UThreadDB;

interface 

uses Classes, DBClient, DB, SysUtils, Variants, JvJCLUtils;

type

  TParametros = class
  private
    FTotal: Integer;
    FCampo: array of string;
    FTipo: array of TFieldType;
    FValor: array of Variant;
  public
    constructor Create(ACampos: string; ATipos: array of TFieldType; AValores: array of Variant); reintroduce;
  end;

  TThreadDB = class(TThread)
  private
    FExecutou: Boolean;
    FClientDataSet: TClientDataSet;
    FConsultaSQL: string;
    FParametros: TParametros;
    procedure CarregarDados;
  protected
    procedure Execute; override;
  public
    constructor Create(ACreateSuspended: Boolean; AClientDataSet: TClientDataSet; AConsultaSQL: string = '';
      AParametros: TParametros = nil); reintroduce;

    class function ExecutarThreadDB(AClientDataSet: TClientDataSet; AConsultaSQL: string = '';
      AParametros: TParametros = nil; APriority: TThreadPriority = tpNormal): Boolean;

    class procedure ExecutarThreadDBParalela(AThreadDB: TThreadDB; AClientDataSet: TClientDataSet;
      AConsultaSQL: string = ''; AParametros: TParametros = nil; APriority: TThreadPriority = tpNormal);
  end;

implementation

uses
   BIBLIO;

{ TThreadDB }

class function TThreadDB.ExecutarThreadDB(AClientDataSet: TClientDataSet; AConsultaSQL: string = '';
   AParametros: TParametros = nil; APriority: TThreadPriority = tpNormal): Boolean;
var
   lThreadDB: TThreadDB;
begin
   lThreadDB := TThreadDB.Create(True, AClientDataSet, AConsultaSQL, AParametros);

   try

      //lThreadDB.FreeOnTerminate := True;
      lThreadDB.Priority := APriority;
      lThreadDB.Resume;

      lThreadDB.WaitFor;

      Result := lThreadDB.FExecutou;

   finally
      lThreadDB.Terminate;

      //lThreadDB := nil;
      FreeAndNil(lThreadDB);
   end;
end;

class procedure TThreadDB.ExecutarThreadDBParalela(AThreadDB: TThreadDB; AClientDataSet: TClientDataSet;
   AConsultaSQL: string = ''; AParametros: TParametros = nil; APriority: TThreadPriority = tpNormal);
begin
   AThreadDB := TThreadDB.Create(True, AClientDataSet, AConsultaSQL, AParametros);

   AThreadDB.FreeOnTerminate := True;
   AThreadDB.Priority := APriority;
   AThreadDB.Resume;
end;

procedure TThreadDB.CarregarDados;
var
   lIndex: Integer;
begin
   FClientDataSet.Close;

   try

      if (FConsultaSQL <> '') then
      begin
         FClientDataSet.CommandText := FConsultaSQL;
      end;

      if (FParametros <> nil) then
      begin
         for lIndex := 0 to (FParametros.FTotal - 1) do
         begin
            case FParametros.FTipo[lIndex] of
               ftInteger : FClientDataSet.Params.ParamByName(FParametros.FCampo[lindex]).AsInteger := FParametros.FValor[lIndex];
               ftString  : FClientDataSet.Params.ParamByName(FParametros.FCampo[lindex]).AsString  := FParametros.FValor[lIndex];
               ftDate    : FClientDataSet.Params.ParamByName(FParametros.FCampo[lindex]).AsDate    := FParametros.FValor[lIndex];
            end;
         end;
      end;

      FClientDataSet.Open;

      FExecutou := True;

   except
      on E: Exception do
      begin
        Erro('Não foi possível carregar os dados solicitados!' + #13 +
             'Classe do erro: ' + E.ClassName + #13 +
             'Mensagem: ' + E.Message);
      end;
   end;

   if (FParametros <> nil) then
   begin
      FreeAndNil(FParametros);
   end;
end;

constructor TThreadDB.Create(ACreateSuspended: Boolean; AClientDataSet: TClientDataSet; AConsultaSQL: string = '';
   AParametros: TParametros = nil);
begin
  inherited Create(ACreateSuspended);

   FClientDataSet := AClientDataSet;

   FConsultaSQL := AConsultaSQL;

   FParametros := AParametros;

   FExecutou := False;
end;

procedure TThreadDB.Execute;
begin
   CarregarDados;
end;

{ TParametros }

constructor TParametros.Create(ACampos: string; ATipos: array of TFieldType; AValores: array of Variant);
var
   lIndex: Integer;
begin
  inherited Create;

   FTotal := ContaCaracteres(ACampos, ';') + 1;

   SetLength(FCampo, FTotal);
   SetLength(FTipo, FTotal);
   SetLength(FValor, FTotal);

   for lIndex := 0 to FTotal - 1 do
   begin
      FCampo[lIndex] := ExtractDelimited(lIndex + 1, ACampos , [';']);
   end;

   for lIndex := 0 to FTotal - 1 do
   begin
      FTipo[lIndex] := ATipos[lIndex];
   end;

   for lIndex := 0 to FTotal - 1 do
   begin
      FValor[lIndex] := AValores[lIndex];
   end;
end;

end.

关于我缺少什么的任何想法？

Answer 1

您在问题中没有提到这一点，但我猜您描述的问题可能是由修改数据集对象引起的，该对象同时被主线程消耗（例如显示在网格中）。换句话说，您将传递给工作线程数据集，该数据集链接到主线程中的某些控件。或者，以另一种方式描述，您的 cdsSolicitacao 数据集对象通过数据源对象链接到主窗体上的某些控件。

请注意，主线程永远不能处理正在被工作线程修改的对象。

甚至模态动画也不会阻止主线程使用刚刚修改的数据集。例如，可以请求重新绘制 DB 网格，这需要访问其底层数据集，同时由工作线程修改。

如果这是您的情况，并且您不想创建一个新的数据集实例，然后在工作线程完成时将其替换为使用的数据集实例， 在传递给工作线程之前，您需要（理想情况下）断开该数据集对象与每个链接控件的连接，并在完成时重新连接。