Я использовал функцию CancellationTokenSource для предоставления функции, чтобы пользователь мог отмените длительное действие. Однако после того, как пользователь применяет первую отмену, более поздние дальнейшие действия больше не работают. Я предполагаю, что статус CancellationTokenSource был установлен на Cancel, и я хочу знать, как reset он вернулся.
-
Вопрос 1: Как reset Источник CancellationTokenSource после первого использования?
-
Вопрос 2: Как отладить многопоточность в VS2010? Если я запустил приложение в режиме отладки, я могу увидеть следующее исключение для утверждение
this.Text = string.Format("Processing {0} on thread {1}", filename, Thread.CurrentThread.ManagedThreadId);
InvalidOperaationException не был обработан кодом пользователя Неверная операция поперечного потока: Control 'MainForm', доступ к которому осуществляется из потока другой чем поток, на котором он был создан.
Спасибо.
private CancellationTokenSource cancelToken = new CancellationTokenSource();
private void button1_Click(object sender, EventArgs e)
{
Task.Factory.StartNew( () =>
{
ProcessFilesThree();
});
}
private void ProcessFilesThree()
{
ParallelOptions parOpts = new ParallelOptions();
parOpts.CancellationToken = cancelToken.Token;
parOpts.MaxDegreeOfParallelism = System.Environment.ProcessorCount;
string[] files = Directory.GetFiles(@"C:\temp\In", "*.jpg", SearchOption.AllDirectories);
string newDir = @"C:\temp\Out\";
Directory.CreateDirectory(newDir);
try
{
Parallel.ForEach(files, parOpts, (currentFile) =>
{
parOpts.CancellationToken.ThrowIfCancellationRequested();
string filename = Path.GetFileName(currentFile);
using (Bitmap bitmap = new Bitmap(currentFile))
{
bitmap.RotateFlip(RotateFlipType.Rotate180FlipNone);
bitmap.Save(Path.Combine(newDir, filename));
this.Text = tring.Format("Processing {0} on thread {1}", filename, Thread.CurrentThread.ManagedThreadId);
}
});
this.Text = "All done!";
}
catch (OperationCanceledException ex)
{
this.Text = ex.Message;
}
}
private void button2_Click(object sender, EventArgs e)
{
cancelToken.Cancel();
}
