SuvAlexander Mar 10 2016 at 17:34

Эмуляция async/await в Delphi

2 min

8.6K

Delphi*

Comments 17

Razaz Mar 10 2016 at 18:02

Странный у вас C# код:)

        async Task CalcAsync()
        {
            var aArg1  = await AddAsync(1, 2, 2000);      
            var aArg2  = await AddAsync(3, 4, 2000);      

            var aRes = MultiplyAsync(aArg1, aArg2, 1000); 

            Log($"{aArg1} * {aArg2} = {aRes}");
        }

Расскажите поподробнее про возврат в текущий поток и как передается управление. Как это внутри сделано? Используется IOCP?

-4

leschenko Mar 10 2016 at 18:05

Код на C# как раз нормальный. А вот на Delphi не сделано ровным счетом ничего. Визуально похоже, но работает совершенно не так.

Razaz Mar 10 2016 at 20:36

Видимо кого-то задело, что это все в 4 строки пишется, но код и в самом деле выглядит притянутым за уши для аналогии с Delphi. И как раз был вопрос про то как это работает.

leschenko Mar 10 2016 at 21:27

Так ведь весь прикол в том, что оно не работает. В C# между await'ами UI поток свободен и может выполнять другие задачи, а код Delphi вынес обработку в другой поток, но UI поток занят.

Razaz Mar 10 2016 at 22:28

Ну дак я и спрашиваю автора дальше об этом:

Управление передастся механизмом сообщений или в другом потоке — настраивается в окружении

Все это выглядит как Task.Result, но были упомянуты какие-то сообщения..

lair Mar 11 2016 at 00:03

Все это выглядит как Task.Result, но были упомянуты какие-то сообщения..

Ну вообще, SynchronizationContext.Post — это вполне себе сообщение, а именно так работает постановка continuation на определенный контекст (по умолчанию в await это включено).

Razaz Mar 12 2016 at 13:14

Ну и хотелось бы узнать как точно то работает на Delphi :)

lair Mar 12 2016 at 13:17

Из вашего коммента не очевидно, к какому коду был вопрос. Судя по количеству ответов — не мне одному.

Razaz Mar 12 2016 at 14:44

"Расскажите поподробнее про возврат в текущий поток и как передается управление. Как это внутри сделано? Используется IOCP?"

lair Mar 12 2016 at 14:45

… и все это под C#-ным кодом. Вот вам и рассказывают про C#-ный код.

Razaz Mar 12 2016 at 15:20

Я просто отформатировал код автора, что бы не пугало людей, которые с C# не сильно знакомы :) Извиняюсь ели ввел в заблуждение.

SuvAlexander Mar 14 2016 at 11:48

1) Покажите, пожалуйста, строчку кода, которая выполняется не в главном потоке.
2) Откуда информация, что главный поток занят? Что вам мешает повторно нажать на кнопочку "Async" во время "вычислений"?

Добавил логирование сообщения на выход из обработчика нажатия:
procedure TExample.btStartAsyncClick(Sender: TObject);
begin
// mmLog.Clear;
TCalcAsync.Create.Switch;
Log('btStartAsyncClick finish', []);
end;

Дважды быстро нажал на "Async". Получил лог (обратите внимание на положение этого сообщения — оно между сообщениями из TCalcAsync.Execute):

1 + 2 start
3 + 4 start
btStartAsyncClick finish
1 + 2 start
3 + 4 start
btStartAsyncClick finish
1 + 2 = 3
3 + 4 = 7
3 7 start
1 + 2 = 3
3 + 4 = 7
3 7 start
3 7 = 21
3 7 = 21

leschenko Mar 14 2016 at 16:07

Извиняюсь. Не туда посмотрел. Действительно, UI не занят.

Но все равно так писать — извражение.

lair Mar 14 2016 at 16:24

Покажите, пожалуйста, строчку кода, которая выполняется не в главном потоке.

Вы про свой код или про C#?

mayorovp Mar 11 2016 at 09:06

Оператор await работает следующим образом:

Проверяет, не выполнена ли уже задача. Если выполнена — то у нее просто извлекается значение (или исключение) и больше ничего не делается.
Захватывает текущий контекст синхронизации или планировщик задач.
У задачи вызывается метод ContinueWith, в который передается лямбда, указывающая на шаг 5.
Управление из метода возвращается.
(Вызывается асинхронно после выполнения задачи) Если на шаге 2 был захвачен контекст синхронизации — то шаг 8 алгоритма вызывается в нем асинхронно при помощи метода Post
Если на шаге 2 баз захвачен планировщик задач — то шаг 8 алгоритма запускается в нем как задача
если на шаге 2 ничего захвачено не было — то шаг 8 выполняется сразу же
Продолжается выполнение метода, начиная с текущего оператора await (т.е. с шага 1).

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

Большую часть реализации можно увидеть начиная отсюда: http://referencesource.microsoft.com/#mscorlib/system/runtime/compilerservices/AsyncMethodBuilder.cs,108

Также реализация await упрощенна расписана в комментарии к файлу http://referencesource.microsoft.com/#mscorlib/system/runtime/compilerservices/TaskAwaiter.cs

Магия шагов 1 и 8 (возобновление метода) реализуется компилятором.

Razaz Mar 12 2016 at 13:15

Зачем вы мне про C# И .Net? Это я и так знаю. Вопрос был к автору — как именно это реализовано на Delphi.

leschenko Mar 12 2016 at 14:22

Никак. Это не реализовано.

Show the best of all time