1

Посредством такой конструкции

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

запускается несколько процессов обработки, параметры которой переданы в таблице _targetTable. Нужно вывести в окне приложения статус для каждого процесса (например, запрос данных, получение данных, обработка результатов, сохранение), сам прогресс (проценты) не нужны. Прочитал, что можно воспользоваться интерфейсом

IProgress<T>

но все примеры только для одного потока. Подскажите пожалуйста, как можно организовать вывод текущего статуса для всех потоков?

Спасибо

8
  • 1
    _targetTable.Rows.Cast<DataRow>() и MVVM, вы серьезно? По поводу вашей задачи я бы сделал так: Отдельный класс, который отвечает за скачивание файла, у которого есть событие "изменения статуса", класс имеет Task, который запускает например загрузку. Ну а дальше все просто: 1. Создали класс, подписались на событие, запустили Task. Если таких задач много, то формируете список тасков.
    – EvgeniyZ
    27 апр 2020 в 10:29
  • @EvgeniyZ что не так с приведением типа в MVVM? Допустим оформлю обработку в отдельный класс, по прежнему стоит вопрос, как из потока вернуть его текущий статус (чем он сейчас занимается). По условию задачи мне нужно не только его скачать, но и обработать согласно правил и вернуть результат. Может я чего-то не понимаю? 27 апр 2020 в 11:22
  • что не так с приведением типа в MVVM? - то, что MVVM, это строгое разделение на слои, где VM слой не должен совершенно нечего знать про View слой и наоборот, View не должен нечего знать про VM и M слой. Вы используете _targetTable, это явно компонент таблицы (контрол), а значит, вы используете либо подписку на событие и через него обращаетесь к контролу, либо делаете это напрямую, что является грубым нарушением MVVM.
    – EvgeniyZ
    27 апр 2020 в 11:52
  • как из потока вернуть его текущий статус - Во первых где вы увидели поток, а во вторых что вам не понятно в событиях? Вот я делал недавно загрузчик, там есть событие ProgressChanged, которое из кода вызывается. Сама загрузка файла запускается при помощи Task асинхронно. Вот прям берите тот код, делайте список задач и запускайте их при помощи Task.WhenAll() например.
    – EvgeniyZ
    27 апр 2020 в 11:57
  • По поводу DataTable позвольте с Вами не согласиться, так как это элемент самого фреймворка, это такая-же структура данных как List или Dictionary. Потоки создаются (используются) при использовании класса Parallel (по крайней мере так пишут в книгах. В моём случае VM ничего не знает про V. В свою очередь, V читает VM. Из набора потоков надо получать статус. Пока вижу вариант только событиями, но как использовать IProgress? 27 апр 2020 в 13:41

1 ответ 1

1

Согласно документации, вызов колбэка IProgress осуществляется с перенаправлением в SynchronizationContext того потока, который его создал. Следовательно, он является своего рода потокобезопасным способом отчитываться о прогрессе.

Any handler provided to the constructor or event handlers registered with the ProgressChanged event are invoked through a SynchronizationContext instance captured when the instance is constructed.

Поэтому, вы можете просто создать поле типа 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 можно передавать объект любого типа, не обязательно строку.

3
  • А в ReadData _myProgress передавать не надо? достаточно его объявить вне цикла? 28 апр 2020 в 8:44
  • 1
    @АртемийСоболев да, можно просто глобально, передать его в итератор конечно можно попробовать, но зачем, если обратная связь идет через синхронизацию контекста и делагат Action? Грубо говоря Report - это вызов колбэка, метода, а не просто типа глобальная переменная. Вы же выносите в методы класса повторяющийся код, а не объявляете их локально, и считаете это нормальным, вот и здесь я не вижу ничего не нормального. :) Для еще большей уверенности, можете его сделать свойством с одним { get; } или readonly полем.
    – aepot
    28 апр 2020 в 9:22
  • @АртемийСоболев дополнил ответ
    – aepot
    28 апр 2020 в 9:44

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими условиями использования и подтверждаете, что прочитали и поняли наши политику конфиденциальности и нормы поведения.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.