如何使用 Delphi 和 OmniThread 在后台将文件上传到 azure？

Question

我尝试使用 Delphi 将 +100 个文件上传到 azure。但是，调用阻塞了主线程，所以我想使用异步调用或后台线程来执行此操作。

这就是我现在所做的（比如explained here）：

procedure TCloudManager.UploadTask(const input: TOmniValue;
  var output: TOmniValue);
var
  FileTask:TFileTask;
begin
  FileTask := input.AsRecord<TFileTask>;

  Upload(FileTask.BaseFolder, FileTask.LocalFile, FileTask.CloudFile);
end;

function TCloudManager.MassiveUpload(const BaseFolder: String;
  Files: TDictionary<String, String>): TStringList;
var
  pipeline: IOmniPipeline;
  FileInfo : TPair<String,String>;
  FileTask:TFileTask;
begin
  // set up pipeline
  pipeline := Parallel.Pipeline
    .Stage(UploadTask)
    .NumTasks(Environment.Process.Affinity.Count * 2)
    .Run;
  // insert URLs to be retrieved
  for FileInfo in Files do
  begin
    FileTask.LocalFile := FileInfo.Key;
    FileTask.CloudFile := FileInfo.Value;
    FileTask.BaseFolder := BaseFolder;

    pipeline.Input.Add(TOmniValue.FromRecord(FileTask));
  end;//for

  pipeline.Input.CompleteAdding;

  // wait for pipeline to complete
  pipeline.WaitFor(INFINITE);
end;

但是这个块也是（为什么？我不明白）。

Answer 1

这会阻塞，因为您正在调用 WaitFor 等待所有管道阶段完成它们的工作。在等待期间，GUI 被阻止。

正确的做法是

1. 将从 Parallel.Pipeline 返回的接口存储在全局存储中（例如在 TCloudManager 字段中）。
2. 为管道安排工作。
3. 不要 WaitFor 结束，而是分配 OnStop 处理程序并在此处执行您需要的任何清理工作（不要忘记清除保存管道接口的全局存储）。

要执行第 3 步，您需要来自 SVN 的新 OmniThreadLibrary，因为我刚刚添加了此功能 :)

procedure TCloudManager.MassiveUpload(const BaseFolder: String;
  Files: TDictionary<String, String>);
var
  FileInfo : TPair<String,String>;
  FileTask:TFileTask;
begin
  // set up pipeline
  FPipeline := Parallel.Pipeline
    .Stage(UploadTask)
      .NumTasks(Environment.Process.Affinity.Count * 2)
    .OnStop(
      procedure begin
        ShowMessage('All done');
        FPipeline := nil;
      end)
    .Run;
//   insert URLs to be retrieved
  for FileInfo in Files do
  begin
    FileTask.LocalFile := FileInfo.Key;
    FileTask.CloudFile := FileInfo.Value;
    FileTask.BaseFolder := BaseFolder;

    FPipeline.Input.Add(TOmniValue.FromRecord(FileTask));
  end;//for
  FPipeline.Input.CompleteAdding;
end;

Answer 2

Delphi 有一个 .NET 变体，对吗？您是否知道 Azure 存储服务有一个 .NET 托管 API？

CloudBlockBlob 类有一个用于上传/下载等的异步变体。

http://msdn.microsoft.com/en-us/library/windowsazure/microsoft.windowsazure.storageclient.cloudblockblob_methods.aspx