Синхронный вызов асинхронной функции

@John Prick · Регистрация: 27.07.2012

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

Всем привет!

Внезапно запутался в трёх соснах. Есть некоторая очередь обработчиков событий, часть из которых может быть асинхронными. Но надо, чтобы они всё-таки выполнялись из очереди последовательно. Вот что-то не соображу, как это сделать.

Небольшой пример.

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
40
41
42
43
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
 
interface IMenuItem
{
    void Execute();
}
 
class ActionMenuItem : IMenuItem
{
    public ActionMenuItem(Action a) => action = a;
    public void Execute() => action();
    private Action action;
}
 
class Program
{
    static void Main()
    {
        List<IMenuItem> menu = new List<IMenuItem>
        {
            new ActionMenuItem(AsyncMethod),
            new ActionMenuItem(SyncMethod)
        };
        
        menu[0].Execute();
        menu[1].Execute();
        
        Console.ReadLine();
    }
    
    static async void AsyncMethod()
    {
        await Task.Delay(1000);
        Console.WriteLine("async");
    }
    
    static void SyncMethod()
    {
        Console.WriteLine("sync");
    }
}

Он выведет на печать сначала "sync", а потом "async", что логично, так как асинхронный метод здесь выполняется дольше, хотя методы вызваны в другом порядке. Во что можно обернуть AsyncMethod, чтобы он всё же был вызван синхронно?

@Элд Хасп · 21.09.2022, 13:09

Сообщение от John Prick

Во что можно обернуть AsyncMethod, чтобы он всё же был вызван

C#
23
           new ActionMenuItem(() =>AsyncMethod().Wait()),

@kolorotur · 21.09.2022, 16:57

John Prick, я бы сделал наоборот: по умолчанию предполагать, что обработчик асинхронный (т.е. Func<Task> вместо Action и await в цикле), а синхронные реализации могут вернуть завершенную таску.
Многих проблем избежите, плюс не придется потоки по чем зря блочить.

@Элд Хасп · 21.09.2022, 17:11

John Prick, кстати, обратил внимание только после сообщения от kolorotur.
У вас метод AsyncMethod() void, а не Task.
Wait() можно применить только к Task.
Узнать когда завершиться void асинхронный метод, насколько знаю, нельзя.

@John Prick · 21.09.2022, 21:08 **[ТС]**

Сообщение от Элд Хасп

У вас метод AsyncMethod() void, а не Task.
Wait() можно применить только к Task.

Да, это я, конечно, понял. Ваш вариант работает, это хорошо. Другое дело, что в реальном коде для action перехватываются исключения, а в таком варианте они выпускаются наружу.

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

я бы сделал наоборот: по умолчанию предполагать, что обработчик асинхронный (т.е. Func<Task> вместо Action и await в цикле), а синхронные реализации могут вернуть завершенную таску.

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

Добавлено через 4 минуты
Как-то так:

Кликните здесь для просмотра всего текста

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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
 
interface IMenuItem
{
    Task Execute();
}
 
class FuncTaskMenuItem : IMenuItem
{
    public FuncTaskMenuItem(Func<Task> f) => func = f;
    public string Name { get; set; }
    public async Task Execute()
    {
        try
        {
            await func();
        }
        catch (Exception)
        {
            Console.WriteLine("Error");
        }
    }
    private Func<Task> func;
}
 
class Program
{
    static void Main()
    {
        MainBody();
        Console.ReadLine();
    }
    
    static async void MainBody()
    {
        List<IMenuItem> menu = new List<IMenuItem>
        {
            new FuncTaskMenuItem(AsyncMethod),
            new FuncTaskMenuItem(SyncMethod),
            new FuncTaskMenuItem(ExceptionMethod)
        };
        
        await menu[0].Execute();
        await menu[1].Execute();
        await menu[2].Execute();
    }
    
    static async Task AsyncMethod()
    {
        await Task.Delay(1000);
        Console.WriteLine("async");
    }
    
    static Task SyncMethod()
    {
        Console.WriteLine("sync");
        return Task.CompletedTask;
    }
    
    static Task ExceptionMethod()
    {
        throw new Exception();
    }
}

@Элд Хасп · 21.09.2022, 21:19

Сообщение от John Prick

Другое дело, что в реальном коде для action перехватываются исключения, а в таком варианте они выпускаются наружу.

Не понял.
Wait подымает исключение, если оно было в таске.
Покажите на простом примере, что вы имеете ввиду.

@John Prick · 21.09.2022, 21:26 **[ТС]**

Сообщение от Элд Хасп

Не понял.
Wait подымает исключение, если оно было в таске.

Да, пардон, это я не туда посмотрел. Не все исключения перехватывались, как оказалось.

Вот пример, для полноты картины:

Кликните здесь для просмотра всего текста

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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
 
interface IMenuItem
{
    void Execute();
}
 
class ActionMenuItem : IMenuItem
{
    public ActionMenuItem(Action a) => action = a;
    public void Execute()
    {
        try
        {
            action();
        }
        catch (Exception)
        {
            Console.WriteLine("Error");
        }
    }
    private Action action;
}
 
class Program
{
    static void Main()
    {
        List<IMenuItem> menu = new List<IMenuItem>
        {
            new ActionMenuItem(() => AsyncMethod().Wait()),
            new ActionMenuItem(SyncMethod),
            new ActionMenuItem(ExceptionMethod)
        };
        
        menu[0].Execute();
        menu[1].Execute();
        menu[2].Execute();
        
        Console.ReadLine();
    }
    
    static async Task AsyncMethod()
    {
        await Task.Delay(1000);
        Console.WriteLine("async");
    }
    
    static void SyncMethod()
    {
        Console.WriteLine("sync");
    }
    
    static void ExceptionMethod()
    {
        throw new Exception();
    }
}

@IamRain · 21.09.2022, 21:43

John Prick, видимо, проблема была в async void - эти методы должны сами обрабатывать возникающие исключения, так как они не пробрасывают исключения вверх по стеку. (так как они не await-ятся, а проброс реализован именно через механизм ожидания - await или Wait()).
Надо это просто помнить.

@Элд Хасп · 22.09.2022, 07:37

Сообщение от John Prick

Вот пример, для полноты картины:

Дополнил примером с исключением в задаче:

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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
using System.Runtime.CompilerServices;
 
namespace Core2022.JohnPrick
{
    public interface IMenuItem
    {
        void Execute();
    }
 
    public class ActionMenuItem : IMenuItem
    {
        public ActionMenuItem(Action a) => action = a;
        public void Execute()
        {
            try
            {
                action();
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
        }
        private Action action;
    }
 
    public class MenuItemTest
    {
        public static void Start()
        {
            List<IMenuItem> menu = new List<IMenuItem>
            {
                new ActionMenuItem(() => AsyncMethod().Wait()),
                new ActionMenuItem(() => AsyncExceptionMethod().Wait()),
                new ActionMenuItem(SyncMethod),
                new ActionMenuItem(ExceptionMethod)
            };
 
 
            for (int i = 0; i < menu.Count; i++)
            {
                Console.Write($"{i}) ");
                menu[i].Execute();
                Console.WriteLine();
            }
 
            Console.ReadLine();
        }
 
        static async Task AsyncMethod()
        {
            await Task.Delay(1000);
            MethodNameWrite();
        }
 
        static void SyncMethod()
        {
            MethodNameWrite();
        }
        static async Task AsyncExceptionMethod()
        {
            await Task.Delay(1000);
            MethodNameWrite();
            ExceptionMethod();
        }
 
        static void ExceptionMethod()
        {
            MethodNameWrite();
            throw new Exception();
        }
 
        public static void MethodNameWrite([CallerMemberName] string? memberName = null)
        {
            Console.WriteLine(memberName);
        }
    }
}

Консоль0) AsyncMethod

1) AsyncExceptionMethod
ExceptionMethod
One or more errors occurred. (Exception of type 'System.Exception' was thrown.)

2) SyncMethod

3) ExceptionMethod
Exception of type 'System.Exception' was thrown.

@Элд Хасп · 22.09.2022, 08:09

John Prick, кстати, добавьте перегрузку в ActionMenuItem:

C#
10
11
12
13
    public class ActionMenuItem : IMenuItem
    {
        public ActionMenuItem(Action action) => this.action = action;
        public ActionMenuItem(Func<Task> task) => action = () => task().Wait();

И его станет удобнее использовать для асинхронных методов:

C#
32
33
34
35
36
37
38
            List<IMenuItem> menu = new List<IMenuItem>
            {
                new ActionMenuItem(AsyncMethod),
                new ActionMenuItem(AsyncExceptionMethod),
                new ActionMenuItem(SyncMethod),
                new ActionMenuItem(ExceptionMethod)
            };

@John Prick · 22.09.2022, 09:01 **[ТС]**

Сообщение от Элд Хасп

добавьте перегрузку в ActionMenuItem

Да, я уже по-всякому тут поэкспериментировал ) Спасибо!

Новые блоги и статьи Все статьи Все блоги /
Уведомление о неверно выбранном значении справочника Maks 06.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа "НарядПутевка", разработанного в конфигурации КА2. Задача: уведомлять пользователя, если в документе выбран неверный склад. . .	Установка Qt Creator для C и C++: ставим среду, CMake и MinGW без фреймворка Qt 8Observer8 05.04.2026 Среду разработки Qt Creator можно установить без фреймворка Qt. Есть отдельный репозиторий для этой среды: https:/ / github. com/ qt-creator/ qt-creator, где можно скачать установщик, на вкладке Releases:. . .	AkelPad-скрипты, структуры, и немного лирики.. testuser2 05.04.2026 Такая программа, как AkelPad существует уже давно, и также давно существуют скрипты под нее. Тем не менее, прога живет, периодически что-то не спеша дополняется, улучшается. Что меня в первую очередь. . .	Отображение реквизитов в документе по условию и контроль их заполнения Maks 04.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа "ПланированиеСпецтехники", разработанного в конфигурации КА2. Данный документ берёт данные из другого нетипового документа. . .
Фото всей Земли с борта корабля Orion миссии Artemis II kumehtar 04.04.2026 Это первое подобное фото сделанное человеком за 50 лет. Снимок называют новым вариантом легендарной фотографии «The Blue Marble» 1972 года, сделанной с борта корабля «Аполлон-17». Новое фото. . .	Вывод диалогового окна перед закрытием, если документ не проведён Maks 04.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа "СписаниеМатериалов", разработанного в конфигурации КА2. Задача: реализовать программный контроль на предмет проведения документа. . .	Программный контроль заполнения реквизитов табличной части документа Maks 02.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа "СписаниеМатериалов", разработанного в конфигурации КА2. Задача: 1. Реализовать контроль заполнения реквизита. . .	wmic не является внутренней или внешней командой Maks 02.04.2026 Решение: DISM / Online / Add-Capability / CapabilityName:WMIC~~~~ Отсюда: https:/ / winitpro. ru/ index. php/ 2025/ 02/ 14/ komanda-wmic-ne-naydena/

@kolorotur 17823 / 12973 / 3382 Регистрация: 17.09.2011 Сообщений: 21,261
	21.09.2022, 16:57
	Сообщение было отмечено John Prick как решение Решение John Prick, я бы сделал наоборот: по умолчанию предполагать, что обработчик асинхронный (т.е. Func<Task> вместо Action и await в цикле), а синхронные реализации могут вернуть завершенную таску. Многих проблем избежите, плюс не придется потоки по чем зря блочить. 3

@Элд Хасп Модератор 16142 / 11265 / 2888 Регистрация: 21.04.2018 Сообщений: 33,127 Записей в блоге: 2
	21.09.2022, 17:11
	John Prick, кстати, обратил внимание только после сообщения от kolorotur. У вас метод `AsyncMethod()` `void`, а не `Task`. `Wait()` можно применить только к `Task`. Узнать когда завершиться `void` асинхронный метод, насколько знаю, нельзя. 1

@IamRain 4694 / 2702 / 734 Регистрация: 02.08.2011 Сообщений: 7,234
	21.09.2022, 21:43
	John Prick, видимо, проблема была в async void - эти методы должны сами обрабатывать возникающие исключения, так как они не пробрасывают исключения вверх по стеку. (так как они не await-ятся, а проброс реализован именно через механизм ожидания - await или Wait()). Надо это просто помнить. 1

Синхронный вызов асинхронной функции

Решение

Решение