Мне нужно приложение с одним глобальным источником CancellationTokenSource. Этот CancellationTokenSource должен активироваться только тогда, когда пользователь закрывает приложение.
Приложение «работает», и для каждого рабочего элемента я хочу передать CancellationToken из глобального CancellationTokenSource. Идея состоит в том, что когда пользователь
хочет выйти из приложения, все запущенные им рабочие элементы будут отменены до закрытия приложения. Вопрос в том, как это реализовать,
не создавая утечки памяти. Ниже приведен пример этой идеи, которая, похоже, вызывает утечку памяти:
internal class Program
{
private static CancellationTokenSource cts = new CancellationTokenSource();
static async Task Main(string[] args)
{
while (StartAnotherWorkItem())
{
Task.Run(DoWork, cts.Token);
}
}
static async Task DoWork()
{
var dictionary = string.Empty;
for (int i = 0; i < 100_000_000; i++)
{
dictionary += "SomeLongString";
}
}
static bool StartAnotherWorkItem()
{
Console.WriteLine("Start another work item? [Y/N]");
var response = Console.ReadKey();
if (response.KeyChar == 'y' || response.KeyChar == 'Y') return true;
return false;
}
}
И из любопытства, может ли это быть связано с той же проблемой, что упомянута здесь:
BAD В этом примере используется Task.Delay(-1, token) для создания задачи, которая завершается при срабатывании CancellationToken, но если она не срабатывает, невозможно избавиться от CancellationTokenRegistration, созданного внутри Task.Delay. Это может привести к утечке памяти.
public static async Task WithCancellation(this Task task, CancellationToken cancellationToken)
{
// There's no way to dispose of the registration
var delayTask = Task.Delay(-1, cancellationToken);
var resultTask = await Task.WhenAny(task, delayTask);
if (resultTask == delayTask)
{
// Operation cancelled
throw new OperationCanceledException();
}
return await task;
}
Подробнее здесь: https://stackoverflow.com/questions/786 ... ing-memory
