3

我想从客户端（通过网络）读取 blobfield（使用 blobstream），但应用程序在获取数据时冻结。如何在不冻结并使用进度条显示百分比的情况下阅读 blobfield。（我正在使用 Delphi 和 Firebird）

我正在使用独特的组件。我从以下网址找到了这段代码：http ://forums.devart.com/viewtopic.php?t=14629

但它不能正常工作：

const
BlockSize= $F000;
var
Blob: TBlob;
Buffer: array of byte;
p: pointer;
pos, count: integer;

  UniQuery1.SQL.Text:= 'select * from TABLE1 where FIELD_ID = 1';
  UniQuery1.Open;

  blob:= uniquery1.GetBlob('DATA');
  SetLength(buffer, blob.Size);
  ProgressBar1.Position:= 0;
  Application.ProcessMessages;

 repeat
  count:= Blob.Read(pos, blocksize, p);
  ProgressBar1.Position:= Round(pos/Blob.Size * 100);
  pos:= pos + count;
  p:= pointer(integer(p) + count);
  Application.ProcessMessages;
 until count < blocksize;

PS：我已经设置了独特的选项：

cacheblobs:= false;
streamedblobls:= true;
deferredblobread:= true;

在 repeat-until 循环的第一步中，Blob.Read 方法读取了所有流，因此无法正常工作。

4

1 回答 1

1

您应该使用线程，这是 Delphi 的示例TThread：

type
  TMyForm = class(TForm)
  private
    FPosition: Integer;
    procedure ProgressUpdate;
    procedure Execute;
  end;

procedure TMyForm.ProgressUpdate;
begin
  ProgressBar1.Position := FPosition;
end;

procedure TMyForm.Execute;
begin
  FPosition:= 0;
  ProgressUpdate;
  Thread := TThread.CreateAnonymousThread(procedure
    begin
      repeat
        // Do some long running stuff (in chunks, so we can update the position)
        FPosition := CalculatePosition;
        // Important: Synchronize will run ProgressUpdate in the main thread!
        TThread.Synchronize(nil, ProgressUpdate); 
      until SomeCondition;
    end
  );
  Thread.Start;
end;

因此，将此模式应用于您的代码后，我们得到：

type
  TMyForm = class(TForm)
  private
    FPosition: Integer;
    procedure ProgressUpdate;
    procedure Execute;
  end;

procedure TMyForm.ProgressUpdate;
begin
  ProgressBar1.Position := FPosition;
end;

procedure TMyForm.Execute;
var
  Blob: TBlob;
  Thread: TThread;
begin
  UniQuery1.SQL.Text := 'SELECT * FROM TABLE1 WHERE FIELD_ID = 1';
  UniQuery1.Open;
  Blob := UniQuery1.GetBlob('DATA');

  FPosition:= 0;
  ProgressUpdate;
  Thread := TThread.CreateAnonymousThread(
    procedure
    const
      BlockSize = $F000;
    var
      Buffer: array of Byte;
      P: Pointer;
      Pos, Count: Integer;
    begin
      SetLength(Buffer, Blob.Size);
      repeat
        Count := Blob.Read(Pos, BlockSize, P);
        FPosition := Round(Pos / Blob.Size * 100);
        Pos := Pos + Count;
        P := Pointer(Integer(P) + Count);
        // Important: Synchronize will run ProgressUpdate in the main thread!
        TThread.Synchronize(nil, ProgressUpdate); 
      until Count < BlockSize;
    end
  );
  Thread.Start;
end;

我删除了Application.ProcessMessage并将所有处理移至线程。

线程正在设置FPosition私有属性并用于TThread.Synchronize将 ProgressBar 位置设置为FPosition在主线程中。

如果您的块大小不够大，这可能仍会阻塞 UI（由于过度同步），因此请选择适当的块大小或添加一些更新延迟。

您必须确保UniQuery1在匿名线程运行时在主线程中不使用对象的连接，或者将连接和查询也移动到线程。

这也可能有重入问题，但它应该让您了解如何使用线程进行后台处理。

PS：在线程中运行查询可能也是一个好主意，特别是如果它可能需要一些时间。

于 2014-01-17T14:25:44.170 回答