Как я reset аннулированиеToken правильно?
Сегодня утром я играю с async ctp
и имею простую программу с button
и label
. Нажмите button
, и он начнет обновление label
, остановит button
, прекратит запись в label
. Тем не менее, я не уверен, как reset CancellationTokenSource
, чтобы я мог перезапустить процесс. Мой код ниже:
public partial class MainWindow : Window
{
CancellationTokenSource cts = new CancellationTokenSource();
public MainWindow()
{
InitializeComponent();
button.Content = "Start";
}
async Task DoWork(CancellationToken cancelToken)
{
int i = 0;
while (!cancelToken.IsCancellationRequested)
{
label.Content = i++.ToString();
await TaskEx.Delay(50, cancelToken);
}
}
private void Button_Click(object sender, RoutedEventArgs e)
{
if (button.Content == "Start")
{
button.Content = "Stop";
DoWork(cts.Token);
}
else
{
button.Content = "Start";
cts.Cancel();
}
}
}
Ответы
Ответ 1
Вам нужно воссоздать CancellationTokenSource
- это невозможно, если вы установите reset ".
Это может быть просто:
private void Button_Click(object sender, RoutedEventArgs e)
{
if (button.Content == "Start")
{
button.Content = "Stop";
cts.Dispose(); // Clean up old token source....
cts = new CancellationTokenSource(); // "Reset" the cancellation token source...
DoWork(cts.Token);
}
else
{
button.Content = "Start";
cts.Cancel();
}
}
Ответ 2
Даже у меня была такая же проблема, и я понял, что лучший способ ее решить - создать источник токена отмены, только что перед вызовом метода.
это то, что я делаю при нажатии на кнопку "Пуск":
cancellationTokenSource = new CancellationTokenSource();
cancellationToken = cancellationTokenSource.Token;
Task.Factory.StartNew(StartUpload, cancellationToken);
Я изменяю заголовок для одной и той же кнопки для отмены, и когда клик появляется при отмене, я вызываю
cancellationTokenSource.Cancel();
Вот полный код:
if (button3.Text != "&Start Upload")
{
cancellationTokenSource.Cancel();
}
else
{
try
{
cancellationTokenSource = new CancellationTokenSource();
cancellationToken = cancellationTokenSource.Token;
Task.Factory.StartNew(StartUpload, cancellationToken);
}
catch (AggregateException ex)
{
var builder = new StringBuilder();
foreach (var v in ex.InnerExceptions)
builder.Append("\r\n" + v.InnerException);
MessageBox.Show("There was an exception:\r\n" + builder.ToString());
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
}
}