2

我目前正在处理一个从包含数千个文件的大型二进制文件中读取的应用程序，每个文件都由应用程序中的某个其他类处理。此类返回一个对象或 null。我想在主窗体上显示一个进展，但由于某种原因，我无法理解它。

int TotalFound = 0;
var uiScheduler = TaskScheduler.FromCurrentSynchronizationContext;
BufferBlock<file> buffer = new BufferBlock<file>();
DataflowBlockOptions options = new DataflowBlockOptions(){ TaskScheduler = uiScheduler, }; 
var producer = new ActionBlock<someObject>(largeFile=>{ 
    var file = GetFileFromLargeFile(largeFile);
    if(file !=null){
       TotalFound++;
       buffer.post(file);
       lblProgress.Text = String.Format("{0}", TotalFound);
    }
}, options);

上面的代码冻结了我的表单，即使我使用“TaskScheduler.FromCurrentSynchronizationContext”，为什么？因为当我使用下面的代码时，我的表单更新正常

DataflowBlockOptions options = new DataflowBlockOptions(){ TaskScheduler = uiScheduler, }; 
var producer = new ActionBlock<someObject>(largeFile=>{ 
    var file = GetFileFromLargeFile(largeFile);
    if(file !=null){
       Task.Factory.StartNew(() => {
          TotalFound++;
          buffer.Post(file);
       }).ContinueWith(uiTask => {
          lblProgress.Text = String.Format("{0}", TotalFound);
       },CancellationToken.None, TaskContinuationOptions.None, uiScheduler);           
    }
});

我是整个 TPL 数据流的新手，所以我希望有人可以分享一些关于为什么在第二个代码片段中它有效而在第一个片段中它没有的原因。

亲切的问候，马丁

4

1 回答 1

6

您的 UI 被阻止的原因是因为您正在使用FromCurrentSynchronizationContext. GetFileFromLargeFile()它会导致代码在 UI 线程上运行，这意味着如果您正在执行一些长时间运行的操作（很可能），它将冻结。

另一方面，您必须lblProgress.Text在 UI 线程上运行。

我不确定您是否应该lblProgress.Text直接在此代码中设置，这对我来说看起来耦合太紧了。但如果你想这样做，我认为你应该在 UI 线程上运行该行：

var producer = new ActionBlock<someObject>(async largeFile =>
{
    var file = GetFileFromLargeFile(largeFile);
    if (file != null)
    {
        TotalFound++;
        await buffer.SendAsync(file);
        await Task.Factory.StartNew(
            () => lblProgress.Text = String.Format("{0}", TotalFound),
            CancellationToken.None, TaskCreationOptions.None, uiScheduler);
    }
});

但更好的解决方案是，如果您进行GetFileFromLargeFile()异步并确保它不会在 UI 线程上执行任何长时间运行的操作（ConfigureAwait(false)可以帮助您）。如果你这样做了，代码ActionBlock可以在 UI 线程上运行而不会冻结你的 UI：

var producer = new ActionBlock<someObject>(async largeFile =>
{
    var file = await GetFileFromLargeFile(largeFile);
    if (file != null)
    {
        TotalFound++;
        await buffer.SendAsync(file);
        lblProgress.Text = String.Format("{0}", TotalFound)
    }
}, options);
于 2012-05-20T13:12:52.187 回答