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;