multithreading - 与 FireMonkey 并行的多个 REST 请求

Question

我正在 Rad Studio XE7 中构建一个 Firemonkey 应用程序，单击一个按钮后，我需要使用 TRestRequest 进行多个(大约 7 个)Web 服务调用。每个 Web 服务都会返回 json 对象，然后该对象将填充数据集。我正在寻找一种方法来同时进行这些调用，而不需要锁定应用程序的 UI。

您建议采用哪种方式来执行此操作？我看到 Embarcadero 引入了新的线程任务和功能功能，但我仍然不确定我们是否可以使用它以及如何使用。另外，我看到有一个异步执行TRestRequest的函数，使用这个函数:

function TCustomRESTRequest.ExecuteAsync(ACompletionHandler: TCompletionHandler = nil; ASynchronized: boolean = true; AFreeThread: boolean = true): TRESTExecutionThread;

但我找不到任何有关如何使用此方法及其用途的文档。

任何意见都将不胜感激。

Answer 1

ExecuteAsync(ACompletionHandler: TCompletionHandler = nil; ASynchronized: boolean = true; AFreeThread: boolean = true) 方法确实是可行的方法。顾名思义，它是异步的；这意味着您的程序在触发请求后，甚至在触发多个请求后仍保持响应。
然而，重要的是从不同的对象实例激发这些不同的请求；如果您从已经执行 ExecuteAsync 的 TRESTRequest 实例触发 ExecuteAsync，则新请求将妨碍现有请求。您必须为每个并行调用创建一个单独的 TRESTRequest 实例。

注意它的第一个参数是一个过程；您将您选择的过程作为该参数传递。唯一的要求是该过程有正确的签名；在这种情况下，它是一个没有参数的过程。

ExecuteAsync 方法在 REST.Client 中定义。 (我有 Delphi XE-10.1. Berlin，因此它有一个额外的参数，ACompletionHandlerWithError - 出错时调用。但原理保持不变)。

让我们看看:

function TCustomRESTRequest.ExecuteAsync(ACompletionHandler: TCompletionHandler = nil; ASynchronized: boolean = true;
  AFreeThread: boolean = true; ACompletionHandlerWithError: TCompletionHandlerWithError = nil): TRESTExecutionThread;
begin
  Result := TRESTExecutionThread.Create(Execute, self, ACompletionHandler, ASynchronized, AFreeThread, ACompletionHandlerWithError);
end;

这里发生的是创建一个新线程，在其中执行 REST 请求。如果响应到来，它将由 ACompletionHandler 处理。
默认情况下，ACompletionHandler 在 ExecuteAsync 创建的新线程上运行。如果您希望它在主线程上运行，则应将 ASynchronized 设置为 true。

但是如何访问该响应，并使其可供程序的其余部分访问？

FireMonkey 的 TRESTRequest 类有一个属性 Response，它引用包含服务器对我们的请求的响应的 TRESTResponse 对象。
不幸的是，TRESTRequest 和 TRESTResponse 对象都没有传递给我们的 CompletionHandler!

因此我们需要以某种方式向 CompletionHandler 提供此信息。幸运的是，我们可以使用一个方法作为 CompletionHandler。

假设要处理结果数据的类称为DataOwner。我们的目的是 DataOwner 有权访问与我们的 TRESTRequest 实例关联的 TRESTResponse 实例。
最简单的方法是使 TRESTRequest 和/或 TRESTResponse 成为 DataOwner 的成员。

假设您的请求是从名为 MyRESTRequest 的 TRESTRequest 实例触发并由函数 processResponse 处理的，您将使用以下代码:

type TDataOwner = class
   MyData: TSomeDataType;
   procedure GetData();
   procedure FillDataSet();
end;

implementation

procedure DataOwner.GetData();
begin
  // ... initialize MyRESTRequest here...
  MyRESTRequest.ExecuteAsync(FillDataSet);
end;

procedure DataOwner.FillDataSet();
begin
    MyData := processResponse(MyRESTRequest.Response);
end;

如果您想并行触发多个请求，则需要多次使用此模式。不幸的是，我们无法直接访问完成处理程序中的 TRESTRequest 实例或 TRESTResponse 实例，因为这意味着我们必须自己进行簿记。换句话说，程序员需要确保 Completion Handler 处理正确的 Response 对象。