Форум программистов, компьютерный форум, киберфорум
C# .NET
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.75/8: Рейтинг темы: голосов - 8, средняя оценка - 4.75
0 / 0 / 0
Регистрация: 13.08.2017
Сообщений: 13

Использование асинхронной функции синхронно

21.08.2018, 10:16. Показов 1782. Ответов 5

Студворк — интернет-сервис помощи студентам
Добрый день. Да, я знаю что так делать не желательно, но уже очень нужно. У меня на примете есть несколько вариантов, да и вообще хотелось бы узнать как в таких случаях избегать дэдлоков.

Асинхронный метод
C#
1
2
3
4
5
static async Task<int> MethodAsync(int arg)
{
    await Task.Delay(2500);
    return arg + 13;
}
1. Использование Task.Run()
C#
1
int res = Task.Run(() => MethodAsync(10)).GetAwaiter().GetResult();
2. Использование TaskFactory
C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
static TResult RunSync<TResult>(Func<Task<TResult>> func)
{
    TaskFactory _myTaskFactory = new 
          TaskFactory(CancellationToken.None, TaskCreationOptions.None, 
          TaskContinuationOptions.None, TaskScheduler.Default);
 
    CultureInfo cultureUi = CultureInfo.CurrentUICulture;
    CultureInfo culture = CultureInfo.CurrentCulture;
 
    return AsyncHelper._myTaskFactory.StartNew<Task<TResult>>(delegate
    {
        Thread.CurrentThread.CurrentCulture = culture;
        Thread.CurrentThread.CurrentUICulture = cultureUi;
        return func();
    }).Unwrap<TResult>().GetAwaiter().GetResult();
}
3. Использование autoResetEvent
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
static Result InvokeAsyncFuncSynchronously<TResult>(Func< Task<TResult>> func)
{
        TResult result = default(TResult);
        var autoResetEvent = new AutoResetEvent(false);
 
        Task.Run(async () =>
        {
            try
            {
                result = await func();
            }
            catch (Exception exc)
            {
                mErrorLogger.LogError(exc.ToString());
            }
            finally
            {
                autoResetEvent.Set();
            }
        });
        autoResetEvent.WaitOne();
 
        return result;
}
Слышал еще про SynchronizationContext, но никогда не использовал, потому пример привести не могу. И так, как лучше решить задачу?
0
cpp_developer
Эксперт
20123 / 5690 / 1417
Регистрация: 09.04.2010
Сообщений: 22,546
Блог
21.08.2018, 10:16
Ответы с готовыми решениями:

Как правильно блокировать повторный запуск асинхронной функции ?
Допустим есть асинхронная функция, вызываемая по нажатию кнопки пользователем. Функция не быстрая, ходит по http Как можно запретить...

Ожидание в асинхронной функции ввода текста в TextBox (наподобие консольной readline)
Есть асинхронная функция, в середине которой требуется дать пользователю доступ к текстбоксу и и ожидать допустим нажатия кнопки для...

Функции не хотят работать синхронно
Приветствую! У меня написаны две функции. Эта функция делает запрос в БД и возвращает массив полученных данных через return. ...

5
Эксперт .NET
 Аватар для kolorotur
17823 / 12973 / 3382
Регистрация: 17.09.2011
Сообщений: 21,261
21.08.2018, 11:32
Цитата Сообщение от Nisu Посмотреть сообщение
И так, как лучше решить задачу?
Перво-наперво, зачем в первом варианте вызов GetAwaiter?
Не первый раз это встречаю и ни разу еще внятно никто не дал ответ — зачем они это делают.

В целом лучше избегать вызовов асинхронных методов в синхронном коде, но если по-другому ну совсем никак, то первый вариант правильный, только без культа карго:
C#
1
int res = Task.Run(() => MethodAsync(10)).Result;
1
0 / 0 / 0
Регистрация: 13.08.2017
Сообщений: 13
21.08.2018, 11:58  [ТС]
kolorotur, кстати нашел еще вариант от Stephen Toub'a и немного его переделав:

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
 private sealed class SingleThreadSynchronizationContext : SynchronizationContext
        {
            /// <summary>The queue of work items.</summary>
            private readonly BlockingCollection<KeyValuePair<SendOrPostCallback, object>> m_queue =
                new BlockingCollection<KeyValuePair<SendOrPostCallback, object>>();
            /// <summary>The processing thread.</summary>
            private readonly Thread m_thread = Thread.CurrentThread;
            /// <summary>The number of outstanding operations.</summary>
            private int m_operationCount = 0;
            /// <summary>Whether to track operations m_operationCount.</summary>
            private readonly bool m_trackOperations;
 
            /// <summary>Initializes the context.</summary>
            /// <param name="trackOperations">Whether to track operation count.</param>
            internal SingleThreadSynchronizationContext(bool trackOperations)
            {
                m_trackOperations = trackOperations;
            }
 
            /// <summary>Dispatches an asynchronous message to the synchronization context.</summary>
            /// <param name="d">The System.Threading.SendOrPostCallback delegate to call.</param>
            /// <param name="state">The object passed to the delegate.</param>
            public override void Post(SendOrPostCallback d, object state)
            {
                if (d == null) throw new ArgumentNullException("d");
                m_queue.Add(new KeyValuePair<SendOrPostCallback, object>(d, state));
            }
 
            /// <summary>Not supported.</summary>
            public override void Send(SendOrPostCallback d, object state)
            {
                throw new NotSupportedException("Synchronously sending is not supported.");
            }
 
            /// <summary>Runs an loop to process all queued work items.</summary>
            public void RunOnCurrentThread()
            {
                foreach (var workItem in m_queue.GetConsumingEnumerable())
                    workItem.Key(workItem.Value);
            }
 
            /// <summary>Notifies the context that no more work will arrive.</summary>
            public void Complete() { m_queue.CompleteAdding(); }
 
            /// <summary>Invoked when an async operation is started.</summary>
            public override void OperationStarted()
            {
                if (m_trackOperations)
                    Interlocked.Increment(ref m_operationCount);
            }
 
            /// <summary>Invoked when an async operation is completed.</summary>
            public override void OperationCompleted()
            {
                if (m_trackOperations &&
                    Interlocked.Decrement(ref m_operationCount) == 0)
                    Complete();
            }
        }
 
 public static TResult ReturnFromAsync<TResult>(this Task<TResult> task)
        {
            var prevCtx = SynchronizationContext.Current;
            try
            {
                // Establish the new context
                var syncCtx = new SingleThreadSynchronizationContext(false);
                SynchronizationContext.SetSynchronizationContext(syncCtx);
 
                task.ContinueWith(delegate { syncCtx.Complete(); }, TaskScheduler.Default);
 
                // Pump continuations and propagate any exceptions
                syncCtx.RunOnCurrentThread();
                return task.GetAwaiter().GetResult();
            }
            finally { SynchronizationContext.SetSynchronizationContext(prevCtx); }
        }
Ну в коде собственно
C#
1
int y = MethodAsync(10).ReturnFromAsync();
Стоит ли так заморачиваться и если да, то зачем?
0
1152 / 860 / 263
Регистрация: 30.04.2009
Сообщений: 3,603
21.08.2018, 15:11
Цитата Сообщение от Nisu Посмотреть сообщение
Стоит ли так заморачиваться и если да, то зачем?
Не стоит заморачиваться. В данном примере использование SynchronizationContext вообще бессмысленно.
RunOnCurrentThread обрабатывает очередь сообщений, пока не окончится выполнения Task, но в эту очередь никто ничего не пишет - ccылка на этот SynchronizationContext не передается в Task, а SynchronizationContext.Current является thread static, поэтому к нему нет возможности обратиться из другого потока.
Т.е. вся эта возня сводится к использованию только сигнала EventWaitHandle.

Вообще деадлоки как раз и возникают, когда используется SynchronizationContext c однопоточной обработкой очереди, и во время обработки задания из этого задания еще раз вызывается SynchronizationContext.Send, а контекст то не освободится пока не обработано текущее задание. Как то так.
1
0 / 0 / 0
Регистрация: 13.08.2017
Сообщений: 13
21.08.2018, 15:46  [ТС]
nicolas2008, Спасибо за объяснения, кажется я начинал что-то понимать
Цитата Сообщение от nicolas2008 Посмотреть сообщение
В данном примере использование SynchronizationContext вообще бессмысленно
А если заменить пример с функцией, возвращающей значение по задержке, на асинхронное обращение к базе данных, я так понимаю ничего не изменится?

Вообще выглядит оно все так
C#
1
2
3
4
5
6
7
8
9
10
11
oldList.ForEach(x => 
{
     User user = new User
     {
          Name = x.Name,
          LastName = x.LastName,         
          Data = Task.Run(() => GetUserDataAsync(x.id)).Result
     };
 
     users.Add(user);
});
0
1152 / 860 / 263
Регистрация: 30.04.2009
Сообщений: 3,603
21.08.2018, 18:38
Цитата Сообщение от Nisu Посмотреть сообщение
А если заменить пример с функцией, возвращающей значение по задержке, на асинхронное обращение к базе данных, я так понимаю ничего не изменится?
Ничего не изменится. Как я уже писал, в приведенном примере создаваемый SynchronizationContext не используется по назначению.
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
raxper
Эксперт
30234 / 6612 / 1498
Регистрация: 28.12.2010
Сообщений: 21,154
Блог
21.08.2018, 18:38
Помогаю со студенческими работами здесь

Получить значение из асинхронной функции
Здравствуйте. Помогите мне пожалуйста. Нужно вернуть с помощью return значение глобальной переменной b. Но у меня return возвращает...

Как дождаться выполнения асинхронной функции?
Привет, Есть проэкт Node.js+angular+typescript. И у меня есть функция: window.speechSynthesis.speak(new...

Синхронно или асинхронно?
Приветствую. Настроился я тут познать асинхронную работу с COM портом, но немного подумав задался вопросом: а оно надо, когда заказчик...

Отмена асинхронной операции
Собственно сабж, требуется произвести загрузку файла из интернета, для этого я планирую использовать QNetworkAccessManager (ну или QHttp,...

Таймаут асинхронной операции
Добрый день! Хочу написать tcp-сервер с асинхронными операциями ввода-вывода (BeginReceive/EndReceive или async...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
6
Ответ Создать тему
Новые блоги и статьи
Новый ноутбук
volvo 07.12.2025
Всем привет. По скидке в "черную пятницу" взял себе новый ноутбук Lenovo ThinkBook 16 G7 на Амазоне: Ryzen 5 7533HS 64 Gb DDR5 1Tb NVMe 16" Full HD Display Win11 Pro
Музыка, написанная Искусственным Интеллектом
volvo 04.12.2025
Всем привет. Некоторое время назад меня заинтересовало, что уже умеет ИИ в плане написания музыки для песен, и, собственно, исполнения этих самых песен. Стихов у нас много, уже вышли 4 книги, еще 3. . .
От async/await к виртуальным потокам в Python
IndentationError 23.11.2025
Армин Ронахер поставил под сомнение async/ await. Создатель Flask заявляет: цветные функции - провал, виртуальные потоки - решение. Не threading-динозавры, а новое поколение лёгких потоков. Откат?. . .
Поиск "дружественных имён" СОМ портов
Argus19 22.11.2025
Поиск "дружественных имён" СОМ портов На странице: https:/ / norseev. ru/ 2018/ 01/ 04/ comportlist_windows/ нашёл схожую тему. Там приведён код на С++, который показывает только имена СОМ портов, типа,. . .
Сколько Государство потратило денег на меня, обеспечивая инсулином.
Programma_Boinc 20.11.2025
Сколько Государство потратило денег на меня, обеспечивая инсулином. Вот решила сделать интересный приблизительный подсчет, сколько государство потратило на меня денег на покупку инсулинов. . . .
Ломающие изменения в C#.NStar Alpha
Etyuhibosecyu 20.11.2025
Уже можно не только тестировать, но и пользоваться C#. NStar - писать оконные приложения, содержащие надписи, кнопки, текстовые поля и даже изображения, например, моя игра "Три в ряд" написана на этом. . .
Мысли в слух
kumehtar 18.11.2025
Кстати, совсем недавно имел разговор на тему медитаций с людьми. И обнаружил, что они вообще не понимают что такое медитация и зачем она нужна. Самые базовые вещи. Для них это - когда просто люди. . .
Создание Single Page Application на фреймах
krapotkin 16.11.2025
Статья исключительно для начинающих. Подходы оригинальностью не блещут. В век Веб все очень привыкли к дизайну Single-Page-Application . Быстренько разберем подход "на фреймах". Мы делаем одну. . .
Фото: Daniel Greenwood
kumehtar 13.11.2025
Расскажи мне о Мире, бродяга
kumehtar 12.11.2025
— Расскажи мне о Мире, бродяга, Ты же видел моря и метели. Как сменялись короны и стяги, Как эпохи стрелою летели. - Этот мир — это крылья и горы, Снег и пламя, любовь и тревоги, И бескрайние. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2025, CyberForum.ru