按顺序处理任务

Question

我每次都会发生一些事件通知，例如将文件添加到文件夹中（这不是我的情况，只是一个类比来解释）。

文件夹中可以添加任意数量的文件，我们不知道会有多少。

目前，每次添加文件时都会触发我的事件 myEvent_Handler

private void myEvent_Handler(object sender, SomeEvent e)
{
  // I dont know how many times this event will fire
  if (something == true) (1)
  {
    var t = Task.Run(() =>
    {
      DoSomething(e);  (2)
    });
  }
}

上述事件处理程序中的问题是标有 (1) 和 (2) 的竞态条件。例如，该事件被触发 4 次：

1. (1) 为真，(2) 在任务中排队运行
2. (1) 为真，(2) 在任务中排队运行
3. (1) 为真，(2) 在任务中排队运行
4. (1) 为真，(2) 在任务中排队运行

现在，任务队列有 4 个任务要运行，但这些任务的执行顺序不同。它们可以按任何顺序执行，即 3->2->4->1 但我需要它们按 1->2->3->4 执行而不阻塞 UI 线程。

如何在不阻塞 UI 线程的情况下实现这一点？

Answer 1

我会考虑为此使用 Microsoft 的反应式框架 (NuGet "System.Reactive")。很理想。

Observable
    .FromEventPattern<EventHandler, EventArgs>(
        h => myEvent.Handler += h, h => myEvent.Handler -= h)
    .ObserveOn(Scheduler.Default)
    .Subscribe(ep => DoSomething(ep.EventArgs));

它将自动编组到后台线程 (Scheduler.Default)，并保证每个订阅调用都等到前一个调用完成后再继续。

这将完全取代myEvent_Handler 方法。

.Subscribe(...) 调用返回 IDispose，您可以随时使用它来停止处理 - 它有效地与事件分离。

Answer 2

我想通了并重写了上面的代码来做到这一点：

private void myEvent_Handler(object sender, SomeEvent e)
{
  // I dont know how many times this event will fire
  Task t = new Task(() =>
  {
    if (something == true) 
    {
        DoSomething(e);  
    }
  });
  t.RunSynchronously();
}

效果很好，不会阻塞我的 UI 线程。

更新：虽然我发现这对我很有用（它修复了我的竞争条件并且我的 UI 线程没有被阻塞），但经过进一步调查，我发现调用此代码的方法没有在 UI 线程上执行（这解释了为什么这段代码没有阻塞我的 UI 线程）但是检查 ManagedThreadId，我发现上面的任务在运行这个方法的同一个线程上运行。 结果，我根据这两个帖子更改了我的实现：

https://msdn.microsoft.com/library/system.threading.tasks.taskscheduler.aspx

How (and if) to write a single-consumer queue using the TPL?

使用 LimitedConcurrencyLevelTask​​Scheduler（在上面的 MSDN 文章中提供。

该解决方案效果很好，该任务与实例化任务的方法不在同一线程上执行，从而提高了性能。