主页 / 问题 / 1116451
Accepted
Артемий Соболев
Asked:2020-04-27 17:23:04 +0000 UTC2020-04-27 17:23:04 +0000 UTC

显示通过 Parallel.ForEach 启动的多个进程的当前状态

  • 772

通过这个建设

Parallel.ForEach(_targetTable.Rows.Cast<DataRow>(), ReadData);

启动了几个处理进程，其参数在_targetTable表中传递。您需要在应用程序窗口中显示每个进程的状态（例如，请求数据、接收数据、处理结果、保存），不需要进度本身（兴趣）。我读到你可以使用界面

IProgress<T>

但所有示例仅适用于一个线程。你能告诉我如何组织所有线程的当前状态的输出吗？

谢谢

c#

1 个回答

  1. Best Answer

    根据文档，调用回调IProgress时重定向到SynchronizationContext创建它的线程。因此，它是一种线程安全的进度报告方式。

    提供给构造函数的任何处理程序或向事件注册的事件处理程序都是通过在构造实例时捕获的实例ProgressChanged调用的。SynchronizationContext

    因此，您可以简单地创建一个 type 的字段，在那里IProgress编写一个Progress带有回调的类的实例，并且一切都应该工作，无论迭代器是在一个线程中执行，还是在多个线程中执行。

    可以通过字段实现

    private readonly IProgress<string> _myProgress = new Progress(s =>
{
    Status = s; // предположим, что к Status привязан TextBlock через Binding
});

    或通过延迟初始化的属性

    private IProgress<string> _myProgress;

public IProgress<string> MyProgress => _myProgress ?? (_myProgress = new Progress(s =>
{
    Status = s;
}));

    最好确保第一个调用MyProgress来自 UI 线程。

    好吧，或者没有延迟初始化的属性

    public IProgress<string> MyProgress { get; } = new Progress(s =>
{
    Status = s;
});

    在迭代器中，只需调用Report().

    private void ReadData(DataRow dataRow)
{
    MyProgress.Report("my status");
}

    可以传递任何类型的IProgress对象，不一定是字符串。

    • 1

相关问题