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;

现在 Execute :

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;

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

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

对于如何改进此代码的任何建议/意见，我将不胜感激。

Answer 1

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

如果由于错误而引发异常，则意味着您的代码中发生了您没有计划的事情。你的代码建立在一堆关于事情正常、事情按计划工作的假设之上，当出现意外异常时，这意味着这些假设不再一定成立。此时最好的做法是生成错误报告并发回给您，然后尽快关闭。

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

我完全理解无论如何都要让程序继续运行的愿望，但不幸的是它与现实根本冲突。当您遇到未处理的异常时，唯一明智的做法是生成错误报告并关闭。

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

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