multithreading - 处理 TThread.Execute 中的异常以使其不可中断

Question

有一个多线程应用程序，24/7 运行。正确的资源处置以及正确的异常处理(包括 EAccessViolation)是关键因素。

我有点难以理解如何在线程函数中正确嵌套异常处理 block 。

在TMyThread.Execute中有两个辅助函数:

function LoadHtml(const AUrl: sting): string - TIdHTTP.Get()的简单包装器

function ParsePage(const Id: string): TOffers - 解析器/数据库更新器函数

Execute 开始在数据库中查询 ID 的初始记录集。然后它启动一个 while not rs.Eof do 循环，其中调用 ParsePage 这是一个主处理器。

ParsePage 加载 HTML(由 LoadHtml 处理)，然后执行一些字符串解析操作，最后更新数据库。

以下是代码结构:(为简洁起见，省略了详细信息)

{Wrapper-function to load HTML page}
function TMyThread.LoadHtml(const AUrl: string): string;
var
  Response: TStringStream;
  HTTP: TIdHTTP;
begin
  Result := '';
  Response := TStringStream.Create('');
  try
    try
      HTTP := TIdHTTP.Create(nil);
      HTTP.ReadTimeout := 10000;
      HTTP.Response.KeepAlive := false;
      try
        HTTP.Get(AUrl, Response);
        if HTTP.ResponseCode = 200 then Result := Response.DataString;
      finally
        HTTP.Free;
      end;
    finally
      Response.Free;
    end;
  except
    //This code will run only on exception and *after* freeing all resources?
    on E: EIdHTTPProtocolException do
      if E.ErrorCode = 404 then
        raise EMyOwnHTTPNotFoundError.Create('Page not found');
    else
      HandleErrorAndLogItToDB(E.Class);
  end;
end;

{Loads HTML, processes it and updates DB}
function TMyThread.ParsePage(const Id: string): TOffers;
var
  RawHTML: string;
  Offer: TOffer; //a simple record to store key offer details;
begin
  Result := TOffers.Create;
  try {top-level try..except block}
    try {Critical request. If it fails I want to move}
      RawHTML := LoadHtml('http://onlinetrade.com/offer.html?id=' + Id);
    except
      on E: EMyOwnHTTPNotFoundError do {Defined in function LoadHtml()}
        //Update DB: product does not exist.
      else
        HandleErrorAndLogItToDB(E.Class);
      end;
    end;
    try
      //Preform some basing string operations on RawHTML
    except
      on E: Exception do HandleErrorAndLogItToDB(E.Class);
    end;
    try {Iterate through some blocks of data and put them in the Offers: TList}
      for i := 0 to N do
      begin
        //Set up TOffer record
        Result.Add(Offer);
      end
    finally
      FreeAndNil(Offer);
    end;
  except
    on E: Exception do
    begin
      HandleErrorAndLogItToDB(E.Class);
      FreeAndNil(Result);
      raise; {does this return control to Execute?}
    end;
  end;
end;

现在执行:

procedure TMyThread.Execute;
var
  j: Integer;
  s: string;
  Offers: TOffers; {Is a simple TList to store a collection of TOffer (record)}
begin
  inherited;
  CoInitialize(nil); {ADO is in da house}
  try {top-level try..except block}
    try {nested try..finally to call CoUninitialize}
      try {A critical operation which sources all further operations}
        rs := AdoQuery('GetSomeRecords ' + IntToStr(SomeId));
      except
        on E: Exception do
        begin
          HandleErrorAndLogItToDB(E.Class);
          Exit; {DB-query error means no reason to continue}
        end;
      end;
      while not rs.EOF do
      begin
        try //a loop top-level try..except handler
          Offers := ParsePage(rs.Fields['Id'].Value);
          try //nested resource freeer
            begin
              try //nested try..except to handle DB queries
                for j := 0 to N do with Offers.Items[j] do
                  AdoUpdateDB; //Update DB
                Synchronize(UpdateProgressBar);
              except
                on E: Exception do
                begin
                  HandleErrorAndLogItToDB(E.Class);
                  Continue; //as suggested
                  raise; //as suggested
                end;
              end;
              rs.MoveNext;
            end;
          finally
            FreeAndNil(Offers);
          end;
        except
          on E: Exception do HandleErrorAndLogItToDB(E.Class);
        end;
      end; //end while..do loop
      Synchronize(ResetProgressBar);
    finally
      CoUnitialize;
    end;
  except
    on E: Exception do
    begin
      //Make everything possible to keep the thread running. No matter of:
      //- HTTP/404 - Not Found exceptions (which I handle)
      //- UpdateDatabase fails
      //- String operation exceptions
      //If anything critical occurs, Execute() shall just go to the next offer
      //even if the current one is not properly processed.
    end;
end;

看着这段代码，我想，我尝试处理太多我可能不需要处理的异常，只需将它们传递给 Execute 中最外层的 try.. except 处理程序。我真正需要处理的只有几个异常:初始数据库查询和 EMyOwnHTTPNotFoundError(设置一个表示优惠不存在的标志)。我在某处读到一条建议，除非您确实需要，否则不要明确追求异常处理...

但是，无论在任何代码块内部/外部抛出哪种异常，线程都保持运行非常重要。这个想法是完全忽略异常，并且永远不会中断 while..do 循环或停止线程。同时，正确配置资源也是必须的。

如果您有任何有关如何改进此代码的建议/评论，我将不胜感激。

Answer 1

没有好的方法来“处理”访问冲突，或者实际上任何不表明代码已经计划的特定条件的异常。 (例如，如果您可以简单地告诉用户请求另一个文件，则可以很好地处理“找不到文件”异常。)

如果由于错误而引发异常，则意味着您的代码中发生了您没有计划的事情。您的代码依赖于一系列关于事情进展顺利、事情按计划进行的假设，并且当引发意外异常时，这意味着这些假设不再一定成立。此时最好的做法是生成错误报告并发回给您，然后尽快关闭。

为什么？因为您的假设之​​一可能不再成立，即“关键数据处于有效、未损坏的状态”。如果程序继续运行，盲目地遵循所有数据都良好的假设，然后对其采取行动，它可以非常非常快地将一个小问题变成一个更大的问题。

我完全理解无论如何都要让这个计划继续下去的愿望，但不幸的是它与现实根本相冲突。当您遇到未处理的异常时，唯一明智的做法是生成错误报告并关闭，尤其是诸如访问冲突之类的情况，仅可能是某种错误代码的结果.

如果停机是一件非常糟糕的事情，您可以采取一些措施来确保尽快重新启动。这将使您保持运行，但它会重置您的不变量(基本假设)并清除损坏的数据。但是出于对所有二进制文件的热爱，关闭程序，然后立即执行。

然后获取错误报告并修复您的错误。