继续执行多项任务

Question

我正在使用 TPL 在 MVVM 应用程序的后台线程上串行执行两个任务。任务运行时，应用程序会显示“进度”对话框。因此，我的 MVVM 命令的 Execute() 方法首先在主视图模型中引发一个 ImageProcessingStarting 事件。视图通过显示“进度”对话框来响应事件。然后，该命令启动第一个任务，继续执行第二个任务，并通过在主视图模型中引发 ImageProcessingEnding 事件来执行最终的“继续”。视图通过关闭“进度”对话框来响应该事件。代码如下。

两个后台任务都正常执行，但“进度”对话框在第一个任务完成后（而不是第二个任务完成后）提前关闭。我希望有人能告诉我原因以及如何解决这个问题。感谢您的帮助。

---

public void Execute(object parameter)
{
    ...

    // Announce that image processing is starting
    m_ViewModel.RaiseImageProcessingStartingEvent();

    // Set up a cancellation token source
    var tokenSource = new CancellationTokenSource();
    m_ViewModel.ProgressDialogViewModel.TokenSource = tokenSource;

    // Background Task #1: Add time stamps to files
    var task = Task.Factory.StartNew(() => this.AddTimeStampsToFiles(fileList, progressDialogViewModel));

    /* The Progress dialog is closing at this point! */

    // Background Task #2: Resequence files
    task.ContinueWith(t => this.ResequenceFiles(fileList, progressDialogViewModel));

    /* The Progress dialog should close at this point. */

    // Announce that image processing is finished
    task.ContinueWith(t => m_ViewModel.RaiseImageProcessingEndingEvent(), TaskScheduler.FromCurrentSynchronizationContext());
}

Answer 1

根据 MSDN

Task.ContinueWith 方法

创建一个当目标执行时异步执行的延续
任务完成。

这意味着当主要任务完成时，两个ContinueWith 调用中的其他项目将并行运行。

为了演示这一点，您可以使用下面的代码：

System.Threading.Tasks.Task task = new System.Threading.Tasks.Task(() => Console.WriteLine("1"));
task.ContinueWith((t) => { System.Threading.Thread.Sleep(1000); Console.WriteLine("2"); });
task.ContinueWith((t) => Console.WriteLine("3"));

然后输出窗口将显示：

1
3
2

为了帮助您解决问题，我一直使用 System.ComponentModel.BackgroundWorker 来串行运行任务。可能有更好的方法，但这目前对我有用。

public void Execute(object parameter)
{
    BackgroundWorker bgW = new BackgroundWorker();

    bgW.DoWork += (s, args) =>
    {
        AddTimeStampsToFiles(fileList, progressDialogViewModel);
        ResequenceFiles(fileList, progressDialogViewModel);
    };

    bgW.RunWorkerCompleted += (s, args) =>
    {
        m_ViewModel.RaiseImageProcessingEndingEvent();
    }; 

    m_ViewModel.RaiseImageProcessingStartingEvent();
    bgW.RunWorkerAsync();
}

为此，您可能需要将 fileList 和 progressDialogViewModel 值传递到 bgW.RunWorkerAsync() 方法。

对于多个值，我通常使用 Dictionary 对象，这样我就可以按名称引用值。

希望这有帮助。

Answer 2

找到了我的答案。在我的原始代码中，第二个和第三个任务都是第一个任务的延续。我更改了代码，为原始任务 (taskOne) 和延续任务（taskTwo 和 taskThree）创建单独的任务。然后，taskTwo继续taskOne，taskThree继续taskTwo，就像这样：

// Background Task #1: Add time stamps to files
var taskOne = Task.Factory.StartNew(() => AddTimeStampsToFiles(fileList, progressDialogViewModel));

// Background Task #2: Resequence files
var taskTwo = taskOne.ContinueWith(t => this.ResequenceFiles(fileList, progressDialogViewModel));

// Announce that image processing is finished
var taskThree = taskTwo.ContinueWith(t => m_ViewModel.RaiseImageProcessingEndingEvent(), TaskScheduler.FromCurrentSynchronizationContext());

我已经接受了胖子的回答，因为它确实提供了一个可行的替代方案。然而，我在我的应用程序中使用了这个答案中的方法，因为我使用的是 TPL。