class function TFetchThread.StartThreadFetch(const aSQL: String;
  const aAction: TFetchThreadAction; var aRef: TFetchThread; const aSortDesc: Boolean;
  aDSNotify: TDataSetNotifyEvent
  ): TFetchThread;
const
  C_FETCHTHREAD_MAX_COUNT_ON_TERMINATE = 100;
var
  counter: Integer;
begin
  Result := aRef;
  if (aAction <> ftaNone) then
  begin
    counter := 0;
    while Assigned(aRef) do
    begin
      if Application.Terminated then Exit;;

      if (aAction = ftaTerminate) then
        threadTerminate( aRef );
      Sleep(10);
      Application.ProcessMessages;
      if counter > C_FETCHTHREAD_MAX_COUNT_ON_TERMINATE then Break;
    end;
  end;
  if not Assigned(aRef) then
    Result := TFetchThread.Create( aSQL, aDSNotify, aRef, aSortDesc);
end;

class function TFetchThread.threadTerminate(aRef: TFetchThread): Boolean;
begin
  Result := not isThreadRun(aRef);
  if not Result then
  begin
    aRef.FDSNotify := nil;
    TFetchThread(aRef).Terminate;
    //aRef.Suspend;
    TerminateThread(aRef.Handle, 0);
  end;

  if not Result then
  begin
    Sleep(1);
    TFetchThread(aRef).Terminate;
  end;
end;

procedure TFetchThread.Execute;
begin
  {$IFDEF RUNWATCH}
  AddThread(Self, 'Start>>>');
  {$ENDIF}
  try
    while not Terminated do
    begin
      if sqlChanged then
      begin
        if not DB.Connected then
          DB.Open(False);
        DS.Close;
        DS.SelectSQL.Text := getSQL;
        DS.Open;

      end;

      if DS.Active then
        if not DS.Eof then
        begin
            if Assigned(FDSNotify) then
              Synchronize(
                         procedure
                         begin
                             FDSNotify(DS);
                         end
                        ) ;
              //else
              //  Break;
            DS.Next;
        end;

      if DS.Active then
        if DS.Eof then
        begin
          DS.Close;
          suspend;
        end;

    end;  //while not Terminated

  finally
    DS.Close;
    DB.Close;
  end;

  {$IFDEF RUNWATCH}
  AddThread(Self, 'Stop<<<');
  {$ENDIF}
end;

class function TFetchThread.StartThreadFetch(const aSQL: String;
  const aAction: TFetchThreadAction; var aRef: TFetchThread; const aSortDesc: Boolean;
  aDSNotify: TDataSetNotifyEvent
  ): TFetchThread;
begin

  if Assigned(aRef) then
  begin
    Result := aRef;
    Result.Suspend;
    Result.SQL := aSQL;
    Result.Resume;
  end
  else
    Result := TFetchThread.Create( aSQL, aDSNotify, aRef, aSortDesc);
end;