0

У меня есть два метода возвращающие Task, которые должны работать параллельно, один метод инкрементирует i, другой, при нажатии i на клавиатуре, отображает текущие значение:

static Task Method(ref int i, CancellationToken cancellationToken)
{
    while (i < 2100000000)
    {
        if (cancellationToken.IsCancellationRequested)
        {
            break;
        }

        i++;
    }

    return Task.CompletedTask;
}

static Task Info(ref int i, CancellationToken cancellationToken)
{
    while (!cancellationToken.IsCancellationRequested)
    {
        if (Console.KeyAvailable)
        {
            ConsoleKeyInfo keyInfo = Console.ReadKey();

            if (keyInfo.Key == ConsoleKey.I)
            {
                Console.Clear();
                Console.WriteLine(i);
            }

            if (keyInfo.Key == ConsoleKey.Q)
            {
                break;
            }
        }
    }

    return Task.CompletedTask;
}

я пытался их запустить в Main, но они запускаются синхронно:

static async Task Main()
{
    int i = 0;
    var cts = new CancellationTokenSource();

    Task task1 = Method(ref i, cts.Token);
    Task task2 = Info(ref i, cts.Token);

    await task1;
    cts.Cancel();

    Console.WriteLine("Готово");
    Console.ReadKey();
}

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

2
  • 1
    Ваши методы действительно синхронные. Возврат Task.CompletedTask не делает их асинхронными. Commented 24 окт. 2023 в 18:17
  • ru.stackoverflow.com/a/1339259/373567
    – aepot
    Commented 24 окт. 2023 в 18:43

1 ответ 1

1

Ваш код не работает потому, что

Task task1 = Method(ref i, cts.Token);

запускает Method и ждёт окончания его работы для того, чтобы присвоить результат его выполнения как задачи переменной слева.

Нужно сделать так:

var task1 = new Task(() => Method(ref i, cts.Token));
var task2 = new Task(() => Info(ref i, cts.Token));
task1.Start(); Console.WriteLine("task1");
task2.Start(); Console.WriteLine("task2");
Task.Delay(5000).Wait(); // это чтобы через 5 с полюбому закончилось
cts.Cancel();
Task.WaitAll(new Task[] { task1, task2 });

Можно убрать CancellationToken и заменить последние три строки на:

Task.WaitAny(new Task[] { task1, task2 }, 5000);

Можно и с таксраном (ой, опечатка, наверное):

var task1 = Task.Run(() => Method(ref i, cts.Token)); Console.WriteLine("task1");
var task2 = Task.Run(() => Info(ref i, cts.Token)); Console.WriteLine("task2");
Task.WaitAny(new Task[] { task1, task2 }, 5000);
2
  • Хотелось бы пояснение, почему код автора не работает. | ЗЫ: Task.Run рулит. Commented 24 окт. 2023 в 18:07
  • @AlexanderPetrov А вот некоторые ru.stackoverflow.com/questions/1547441/… не объясняют, и даже не отвечают на вопрос, и ничего... :-)
    – rotabor
    Commented 24 окт. 2023 в 18:14

Ваш ответ

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

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