Изучаю асинхронное программирование и готовлю класс асинхронной команды для внедрения в свои проекты.
Поставил себе требования:
- Реализация для
WPF
на базе.NET Core 3.1
с использованиемBinding
в кнопках или всякого рода меню - Решение, не требующее сильно изменять существующий код проекта при внедрении класса в код при условии, что сейчас используется обычный синхронный
RelayCommand
- Должен быть кастомный обработчик исключений, умеющий по-разному реагировать на разные типы исключений (как это обычно бывает в коде здорового человека)
CanExecute
должен возвращатьfalse
во время выполнения команды, и контрол должен немедленно на его изменения реагировать. Запретить команде одновременно выполняться несколько раз.- Всё это должно работать, даже если я вызываю команду императивно, из любого (не UI) потока.
Использовал референсы:
- класс
RelayCommand
из гайда - вот этот блог пост для
ASP.NET
, где очень не любятasync void
(и наверное правильно делают) - вот этот очень сложный гайд, во всяком случае для меня
И вот что получилось:
AsyncRelayCommand.cs
public interface IAsyncCommand : ICommand
{
Task ExecuteAsync(object param);
}
public class AsyncRelayCommand : IAsyncCommand
{
private bool _isExecuting;
private readonly Func<object, Task> _execute;
private readonly Func<object, bool> _canExecute;
private readonly Action<Exception> _exceptionCallback;
private readonly Dispatcher _dispatcher;
public event EventHandler CanExecuteChanged
{
add => CommandManager.RequerySuggested += value;
remove => CommandManager.RequerySuggested -= value;
}
// делаю обязательным добавление коллбэка обработчика исключений
public AsyncRelayCommand(Func<object, Task> execute, Action<Exception> exceptionCallback) : this(execute, null, exceptionCallback) { }
public AsyncRelayCommand(Func<object, Task> execute, Func<object, bool> canExecute, Action<Exception> exceptionCallback)
{
_execute = execute;
_canExecute = canExecute;
_exceptionCallback = exceptionCallback;
_dispatcher = Application.Current.Dispatcher;
}
private void InvalidateRequerySuggested()
{
// говорят, инвок в диспетчер "дорогой", и лучше его делать только когда надо
if (_dispatcher.CheckAccess())
CommandManager.InvalidateRequerySuggested();
else
_dispatcher.Invoke(CommandManager.InvalidateRequerySuggested);
}
public bool CanExecute(object param) => !_isExecuting && (_canExecute == null || _canExecute(param));
public async Task ExecuteAsync(object param)
{
if (CanExecute(param))
{
try
{
_isExecuting = true;
InvalidateRequerySuggested();
await _execute(param);
}
catch (Exception ex)
{
// хочу вызывать обработчик исключений в UI потоке
// быть может здесь будет лучше делать обычный синхронный инвок?
await _dispatcher.BeginInvoke(_exceptionCallback, ex);
}
finally
{
_isExecuting = false;
InvalidateRequerySuggested();
}
}
}
public void Execute(object param) => _ = ExecuteAsync(param); // fire-and-forget
}
Писал я это все в рамках тестового MVVM проека, который выглядит вот так:
MainWindow.xaml
<Window.DataContext>
<local:MainViewModel/>
</Window.DataContext>
<Grid>
<StackPanel Orientation="Vertical">
<TextBlock Margin="5" Text="{Binding Text}"/>
<Button Margin="5" Content="Execute" Command="{Binding MyAsyncCommand}"/>
</StackPanel>
</Grid>
NotifyPropertyChanged.cs
public class NotifyPropertyChanged : INotifyPropertyChanged
{
public event PropertyChangedEventHandler PropertyChanged;
protected virtual void OnPropertyChanged([CallerMemberName]string propertyName = null)
=> PropertyChanged?.Invoke(this, new PropertyChangedEventArgs(propertyName));
}
MainViewModel.cs
public class MainViewModel : NotifyPropertyChanged
{
private string _text = "some text";
private IAsyncCommand _myAsyncCommand;
// обработчик исключений
private readonly Action<Exception> _exceptionCallback = new Action<Exception>(e => {
try
{
throw e;
}
catch (DivideByZeroException ex)
{
// обрабатываю сгенерированное исключение
MessageBox.Show(ex.Message);
}
catch (Exception ex)
{
// это должно ронять программу, и не теряться глубоко в асинхронных тасках
// и оно работает (но это не точно)
throw ex;
}
});
public string Text
{
get => _text;
set
{
_text = value;
OnPropertyChanged();
}
}
public IAsyncCommand MyAsyncCommand => _myAsyncCommand ?? (_myAsyncCommand = new AsyncRelayCommand(async param =>
{
for (int i = 0; i < 500; i++) // типа долго выполняемая асинхронная команда...
{
Text = "Count: " + i.ToString(); // ...которая модифицирует какие-то свойства VM
await Task.Delay(10);
}
int x = 0;
x = 1 / x; // генерирую DivideByZeroException для теста обработчика исключений
}, _exceptionCallback));
public MainViewModel()
{
}
public void Start() // вызывается из переопределенного OnStartup()
{
Task.Run(async () =>
{
await Task.Delay(5000);
await MyAsyncCommand.ExecuteAsync(null); // вызов команды из "любого" потока
});
}
public void ShutDown() // OnExit()
{
}
}
Всё выше показанное работает исправно, но я прошу помочь с пониманием того, что я понаписал и ответить на следующие вопросы:
- Не ломаю ли я MVVM?
- Правильно ли я обрабатываю исключения, или меня надо бить палкой и всё переписывать?
- Правильно ли в классе команды я взаимодействую с
CommandManager
через диспетчер? - Быть может есть еще что улучшить?
<local:MainViewModel/>
. По поводуtry/catch
- их лучше вообще стараться не использовать, научитесь писать приложение так, чтоб у вас было как можно меньше обработчиков ошибок. СамAsyncRelayCommand
мне лично не понятен, что мешает использовать обычную команду, которая выполнит задачу асинхронно? Сейчас вы нагородили всякимиtry/catch
, что мне кажется показывает на нарушение вашей архитектуры приложения.BlockingCollection
. Максимум переварить какие-то уже загруженные данные, не более чем за пару секунд, поэтому возможность отмены выполения команды для меня излишняя. Спасибо.