Почему async/await выполняются синхронно?

@SunRain · Регистрация: 03.09.2012

Студворк — интернет-сервис помощи студентам

Добрый день, Гуру!
Немного запутался в логике работы async/await, очень прошу просветить..)
Есть несколько асинхронных методов, выполняющихся синхронно в одном таске, хотелось бы понять почему.

Как я это понимаю:
-В строке 1 синхронно запускается метод MethodCaller()
-В строке 2 MethodCaller() возвращает в Main() незавершенный Task и запускает MethodA() в новом потоке, в то время как основной поток выполняет строку 3.

Но все выполняется полностью синхронно, т.е. строка 3 выполняется последней. Почему?

P.S. И еще один вопрос: асинхронные методы идут каскадом, скажем, десяток асинхронных методов дергает один другой. При каждом встреченном await из пула будет извлекаться поток?

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
 
 
        private static void Main()
        {
            MethodCaller(); //1
            Console.WriteLine($"Task - {Task.CurrentId}: Main do work"); //3
            Console.ReadKey();
        }
 
        private static async Task MethodCaller()
        {
            Console.WriteLine($"Task - {Task.CurrentId}: Start MethodCaller()");
            var myNum = await MethodA(); //2
            Console.WriteLine($"Task - {Task.CurrentId}: Finish MethodCaller(), {myNum}");
        }
 
        private static async Task<int> MethodA()
        {
            Console.WriteLine($"Task - {Task.CurrentId}: Start MethodA()");
            var result = await MethodB(); 
            Console.WriteLine($"Task - {Task.CurrentId}: Finish MethodA()");
            return result;
        }
 
        private static async Task<int> MethodB()
        {
            Console.WriteLine($"Task - {Task.CurrentId}: Start MethodB()");
            var randomNumber = new Random().Next(5, 10);
            Console.WriteLine($"Task - {Task.CurrentId}: Finish MethodB()");
            return randomNumber;
        }

@Usaga · 07.11.2016, 12:19

SunRain, так у тебя метод MethodB синхронный, потому и вся цепочка работает синхронно.

@SunRain · 07.11.2016, 12:59 **[ТС]**

То есть, если в цепочке хотя бы один метод выполняется синхронно, вся цепочка становиться синхронной?

Добавлено через 6 минут
Как должен выглядеть MethodB(), что бы код был асинхронным?

@LeniumSoft · 07.11.2016, 13:03

Сообщение от SunRain

То есть, если в цепочке хотя бы один метод выполняется синхронно, вся цепочка становиться синхронной?

Выполни этот код в WinForms приложении. Всё будет асинхронным.
async/await в консоли нормально не пашут.

Добавлено через 2 минуты
Console можно заменить на Debug и смотреть в окно Output

@SunRain · 07.11.2016, 13:05 **[ТС]**

LeniumSoft,
Да, я знаю, в WPF все у меня отлично отрабатывает, поэтому и хочу понять в чем проблема..)
Причем, если в консоли вместо самодельных MethodA и MethodB ждать просто Task.Delay(1000), то все отработает асинхронно, поэтому и хочется понять, что именно я делаю не так..(

@EveKS · 07.11.2016, 13:31

Возможно, можно это:

C#
1
2
3
4
5
6
7
        private static async Task<int> MethodB()
        {
            Console.WriteLine($"Task - {Task.CurrentId}: Start MethodB()");
            var randomNumber = new Random().Next(5, 10);
            Console.WriteLine($"Task - {Task.CurrentId}: Finish MethodB()");
            return randomNumber;
        }

Заменить на

C#
1
2
3
4
5
6
7
8
        private static async Task<int> MethodB()
=>await Task.Run(()=>
        {
            Console.WriteLine($"Task - {Task.CurrentId}: Start MethodB()");
            var randomNumber = new Random().Next(5, 10);
            Console.WriteLine($"Task - {Task.CurrentId}: Finish MethodB()");
            return randomNumber;
        });

@SunRain · 07.11.2016, 14:06 **[ТС]**

EveKS,
Да, так асинхронность заработала, вопрос насколько good practice считается подобный код..

Кстати, почему метод MethodA() после await запускается в том же таске, что и MethodCaller()?
Получается до первого явного запуска нового таска (как в MethodB()) реально все будет выполнятся синхронно?

@gvt · 07.11.2016, 14:23

SunRain, рекомендую изучить это

Добавлено через 5 минут
И это

@SunRain · 07.11.2016, 14:32 **[ТС]**

gvt,
Спасибо, отличная статья..)
Получается аналог асинхронных методов самого .NET, которые выполняют какую-то ресурсоемкую работу стоит делать как раз с помощью TaskCompletionSource, а уже их вызов осуществлять каскадом async/await методов?

Что-то вроде

C#
1
2
3
4
5
6
7
8
9
10
11
12
 private static Task<int> MethodBAsync()
        {
            var task = Task.Factory.StartNew(() =>
            {
                Console.WriteLine($"Task - {Task.CurrentId}: Start MethodB()");
                var randomNumber = new Random().Next(5, 10);
                Console.WriteLine($"Task - {Task.CurrentId}: Finish MethodB()");
                return randomNumber;
            });
            var tcs = new TaskCompletionSource<int>(task);
            return tcs.Task;
        }

@IamRain · 07.11.2016, 14:55

Сообщение от SunRain

стоит делать как раз с помощью TaskCompletionSource

Необязательно. Акцент в статье был на то, чтобы реализовывать асинхронность, затрачивая на это меньше ресурсов, а не просто оборачивая синхронные методы в Task-и. Читайте внимательнее.

Ятп в вашем случае, TaskCompletionSource нафиг не нужен. Вы ведь создали и запустили Task - для чего вам нужен этот TaskCompletionSource?

C#
1
2
3
4
5
6
7
8
9
10
private static Task<int> MethodBAsync()
        {
           return  Task.Factory.StartNew(() =>
            {
                Console.WriteLine($"Task - {Task.CurrentId}: Start MethodB()");
                var randomNumber = new Random().Next(5, 10);
                Console.WriteLine($"Task - {Task.CurrentId}: Finish MethodB()");
                return randomNumber;
            });            
        }

@EveKS · 07.11.2016, 15:19

Я особо не понимаю в тасках, вот чуть переделал написанное выше:

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
using System;
using System.Threading;
using System.Threading.Tasks;
 
class Program
{
    private static void Main()
    {
        CancellationTokenSource cancelTokSrc = new CancellationTokenSource();
        Task tsk = Task.Factory.StartNew(MethodCaller, cancelTokSrc.Token, cancelTokSrc.Token); //1
        Console.WriteLine($"Task - {Task.CurrentId}: Main do work"); //3
        tsk.GetAwaiter().GetResult();
 
        Console.ReadKey();
    }
 
    private static async Task MethodCaller(object cancellationToken)
    {
        Console.WriteLine($"Task - {Task.CurrentId}: Start MethodCaller()");
        var myNum = await MethodA((CancellationToken)cancellationToken); //2
        Console.WriteLine($"Task - {Task.CurrentId}: Finish MethodCaller(), {myNum}");
    }
 
    private static async Task<int> MethodA(CancellationToken cancellationToken)
    {
        Console.WriteLine($"Task - {Task.CurrentId}: Start MethodA()");
        var result = await MethodBAsync(cancellationToken);
        Console.WriteLine($"Task - {Task.CurrentId}: Finish MethodA()");
        return result;
    }
    public static async Task<int> MethodBAsync(CancellationToken cancellationToken)
    => await Task.Run(() =>
        {
            Console.WriteLine($"Task - {Task.CurrentId}: Start MethodB()");
            var randomNumber = new Random().Next(5, 10);
            Console.WriteLine($"Task - {Task.CurrentId}: Finish MethodB()");
            return randomNumber;
        }, cancellationToken);
}

Теперь можно отменять задачу через cancelTokSrc.Cancel();

@IamRain · 07.11.2016, 15:28

EveKS,
насколько я помню, чтобы отменить таску, нужно вбросить исключение, у CancellationToken есть для этого специализированный метод Throwifcancellationrequested.
Если таска уже отменена и при этом не успела запуститься - она и не запустится. Если же уже запущена - то сама логика в таске должна явно поддерживать операцию отмены. (С) Рихтер.
И единственный способ прервать выполнение и уведомить клиентский код об отмене - вбросить исключение.

@EveKS · 07.11.2016, 15:48

IamRain,

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
        CancellationTokenSource cancelTokSrc = new CancellationTokenSource();
        Task tsk = Task.Factory.StartNew(MethodCaller, cancelTokSrc.Token, cancelTokSrc.Token); //1
        try
        {
            cancelTokSrc.Cancel();
            tsk.GetAwaiter().GetResult();
        }
        catch(AggregateException aex)
        {
           
        }
        catch (Exception ex)
        {
            // todo:
        }
        finally
        {
            tsk.Dispose();
            cancelTokSrc.Dispose();
        }

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
        CancellationTokenSource cancelTokSrc = new CancellationTokenSource();
        Task tsk = Task.Factory.StartNew(MethodCaller, cancelTokSrc.Token, cancelTokSrc.Token); //1
        try
        {
            cancelTokSrc.Cancel();
            tsk.Wait();
        }
        catch(AggregateException aex)
        {
            // todo:
        }
        catch (Exception ex)
        {
 
        }
        finally
        {
            tsk.Dispose();
            cancelTokSrc.Dispose();
        }

Новые блоги и статьи Все статьи Все блоги /
Валидация и контроль данных табличной части документа перед записью Maks 22.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа, разработанного в КА2. Задача: контроль и валидация данных табличной части документа перед записью с учетом регламента компании. . .	Отчёт о затраченных материалах за определенный период с макетом печатной формы Maks 21.04.2026 Отчёт из решения ниже размещён в конфигурации КА2. Задача: разработка отчёта по затраченным материалам за определённый период, с возможностью вывода печатной формы отчёта с шапкой и подвалом. В. . .	Отчёт о спецтехнике находящейся в ремонте Maks 20.04.2026 Отчёт из решения ниже размещен в конфигурации КА2. Задача: отобразить спецтехнику, которая на данный момент находится в ремонте. Есть нетиповой документ "Заявка на ремонт спецтехники" который. . .	Памятка для бота и "визитка" для читателей "Semantic Universe Layer (Слой семантической вселенной)" Hrethgir 19.04.2026 Сгенерировано для краткого описания по случаю сборки и компиляции скелета серверного приложения. И пусть после этого скажут, что статьи сгенерированные AI - туфта и не интересно. И это не реклама -. . .
Запрет удаления строк ТЧ документа при определённом условии Maks 19.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа "Аккумуляторы", разработанного в конфигурации КА2. У данного документа есть ТЧ, в которой в зависимости от прав доступа. . .	Модель заражения группы наркоманов alhaos 17.04.2026 Условия задачи сформулированы тут Суть: - Группа наркоманов из 10 человек. - Только один инфицирован ВИЧ. - Колются одной иглой. - Колются раз в день. - Колются последовательно через. . .	Мысли в слух. Про "навсегда". kumehtar 16.04.2026 Подумалось тут, что наверное очень глупо использовать во всяких своих установках понятие "навсегда". Это очень сильное понятие, и я только начинаю понимать край его смысла, не смотря на то что давно. . .	My Business CRM MaGz GoLd 16.04.2026 Всем привет, недавно возникла потребность создать CRM, для личных нужд. Собственно программа предоставляет из себя базу данных клиентов, в которой можно фиксировать звонки, стадии сделки, а также. . .

@Usaga 14322 / 9412 / 1356 Регистрация: 21.01.2016 Сообщений: 35,481
	07.11.2016, 12:19
	SunRain, так у тебя метод MethodB синхронный, потому и вся цепочка работает синхронно. 1

@SunRain 13 / 13 / 2 Регистрация: 03.09.2012 Сообщений: 133
	07.11.2016, 12:59 [ТС]
	То есть, если в цепочке хотя бы один метод выполняется синхронно, вся цепочка становиться синхронной? Добавлено через 6 минут Как должен выглядеть MethodB(), что бы код был асинхронным? 0

@SunRain 13 / 13 / 2 Регистрация: 03.09.2012 Сообщений: 133
	07.11.2016, 13:05 [ТС]
	LeniumSoft, Да, я знаю, в WPF все у меня отлично отрабатывает, поэтому и хочу понять в чем проблема..) Причем, если в консоли вместо самодельных MethodA и MethodB ждать просто Task.Delay(1000), то все отработает асинхронно, поэтому и хочется понять, что именно я делаю не так..( 0

@SunRain 13 / 13 / 2 Регистрация: 03.09.2012 Сообщений: 133
	07.11.2016, 14:06 [ТС]
	EveKS, Да, так асинхронность заработала, вопрос насколько good practice считается подобный код.. Кстати, почему метод MethodA() после await запускается в том же таске, что и MethodCaller()? Получается до первого явного запуска нового таска (как в MethodB()) реально все будет выполнятся синхронно? 0

@gvt 22 / 20 / 3 Регистрация: 12.10.2016 Сообщений: 62
	07.11.2016, 14:23
	SunRain, рекомендую изучить это Добавлено через 5 минут И это 1

@IamRain 4694 / 2702 / 734 Регистрация: 02.08.2011 Сообщений: 7,234
	07.11.2016, 15:28
	EveKS, насколько я помню, чтобы отменить таску, нужно вбросить исключение, у CancellationToken есть для этого специализированный метод Throwifcancellationrequested. Если таска уже отменена и при этом не успела запуститься - она и не запустится. Если же уже запущена - то сама логика в таске должна явно поддерживать операцию отмены. (С) Рихтер. И единственный способ прервать выполнение и уведомить клиентский код об отмене - вбросить исключение. 0