1

У меня есть следующая задача: необходимо в синхронной манере отправить запрос через шину данных и дождаться ответа, после чего вернуть управление вызывающему коду. А могу делать это асинхронно, давая возможность потоку выполнять другую работу. Количество слоев между вызывающим кодом(бизнес-логика) и диспетчером взаимодействия с шиной данных, к примеру, 5. Если я хочу использовать Async/Await, это значит, что на каждом уровне я должен пронести ключевые слова до первого void метода на самом верху. На каждом уровне теперь таск. Вопрос такой: Если в самом низу я реализую ожидание получения ответа через Task.Wait(а не комплишнСорс к примеру, то есть я буду ожидать ответа, блокируя поток), имеет ли какой-нибудь смысл весь этот синтаксический сахар наверху, ведь поток я все-равно заблокирую? Правильно ли я понимаю, что я сам должен побеспокоиться о том, чтобы мой код в самом низу(взаимодействие с шиной данных, жестким диском и пр..) был неблокирующим? В документации написано, что await не блокирует поток, при этом нет никакой доп. информации о том, что мне самому нужно делать соответствующую реализацию и беспокоиться об этом.

12
  • Если вы все равно будете блокировать поток, то смысл возиться с async\await нет. Если вызывающий сверху код хочет дождаться окончания асинхронной операции, то он должен либо как то шаманить с таском (например, вручную налепив ему продолжение или заблочить поток для ожидания), либо должен сам стать асинхронным. Я, например, сейчас делаю подобное - добавляю асинхронщину в старый проект, так у меня все вызовы в стеке до самого верхнего User_Button_Pressed(...) становятся асинхронными.
    – tym32167
    4 мар 2018 в 21:26
  • Тогда зачем мне использовать Async/Await, если я в самом низу реализую асинхронное ожидание, а вызов метода будет обычным. Зачем по всему стеку проносить?
    – Sleeeper
    4 мар 2018 в 21:51
  • Ну вот есть у вас метод Foo(), который вызывает внутри себя метод Bar() ===> Foo(){ Bar(); } И где то внутри вызова метода Bar() происходит что то асинхронное. Как метод Foo() узнает, когда асинхронная операция завершилась?
    – tym32167
    4 мар 2018 в 21:54
  • Он об этом узнает тогда, когда к нему вернется управление. То есть ожидание будет, но неблокирующее, тот же TaskCompetionSource. Снаружи я просто вызываю метод, внутри асинхронно ожидаю, когда верну управление - тогда все и закончится.
    – Sleeeper
    4 мар 2018 в 21:56
  • использовать TaskCompetionSource ещё не значит делать что то асинхронно или неблокирующе. Если метод Foo() вызвал метод Bar() и ждет его завершения, пока происходит асинхронная операция, то поток, в котором происходит ожидание, заблокирован, не зависимо от того, используете вы TaskCompetionSource или нет.
    – tym32167
    4 мар 2018 в 21:59

1 ответ 1

3

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

Если же на самом низком уровне все синхронно - то нет никакого смысла делать все асинхронным.

Иными словами, пляшите от кода низкого уровня, как вам удобнее его писать. А на верхнем уровне просто используйте то, что написано на нижнем. Ну и не забывайте про требования к быстродействию - в том случае когда нижний уровень предоставляет несколько вариантов API.


Рассмотрим ваш пример с шиной. Шина данных (если вы имеете в виду интеграционную шину) может работать несколькими способами. Самый простой из них - синхронные запросы по некоторому протоколу - вы просто делаете запрос и получаете ответ. Если это происходит по HTTP или TCP - то в стандартной библиотеке есть оба варианта API - синхронной и асинхронный. Нужно выбирать тот, который отвечает требованиям по быстродействию. Если у вас одновременно идут сотни или тысячи исходящих запросов - нужно использовать асинхронный вариант (и, конечно же, никаких блокировок на верхнем уровне!). Если вы делаете все запросы последовательно - то синхронного варианта вполне достаточно.

Но у вас упомянут какой-то диспетчер взаимодействия с шиной, значит все не так просто. Значит, шина возвращает ответы на запросы асинхронно и вперемешку, и вам необходимо их прослушивать в отдельном потоке. В таком случае у задачи очевидно асинхронная природа - и вам в любом случае нужна синхронизация. И TaskCompletionSource дает ее близким к оптимальному способом; странно его не использовать:

public Task<Response> SendRequestAsync (Request req)
{
    var tcs = new TaskCompletionSource<Response>(TaskCreationOptions.RunContinuationsAsynchronously);
    lock(requests) requests.Add(request.Id, tcs);
    // ...
    return tcs.Task;
}

public Response SendRequest (Request req) => SendRequestAsync(req).Result;

private void OnResponse(Response resp) 
{
    lock(requests)
    {
        TaskCompletionSource<Response> tcs;
        if (requests.TryGetValue(resp.RequestId, out tcs))
        {
            requests.Remove(resp.RequestId);
            tcs.SetResult(resp);
        }
    }
}

И нет никаких проблем с синхронным ожиданием через .Wait() или .Result если это необходимо (главное - следите в каком потоке вы это делаете).

16
  • Спасибо за ответ!. Интеграционная шина данных, которую я упомянул, работает последовательно и гарантирует правильный порядок прихода данных. Шина IBM. Мне по сути нужно что-то положить в очередь, далее - ожидать прихода ответа. TaskCompletionSource, как я понимаю, как раз и нужно использовать для имитации этого ожидания. Но причем тогда тут async/await?
    – Sleeeper
    5 мар 2018 в 8:17
  • @Sleeeper при том что async/await - это удобный способ работы с асинхронными задачами асинхронно же 5 мар 2018 в 8:21
  • @Sleeeper кстати, не рассчитывайте на правильный порядок прихода ответов если делаете запросы к разным получателям 5 мар 2018 в 8:23
  • Спасибо. То есть, насколько я понимаю, в рамках решаемой задачи поток будет блокироваться так или иначе, но TaskCompletionSource самый оптимальный вариант. Async/Await нужен тут лишь для того, чтобы на верхнем уровне писать в синхронном стиле. Сам по себе await никакой магии не делает.
    – Sleeeper
    5 мар 2018 в 8:33
  • @Sleeeper нет. Если вы протянете Async/Await до самого верхнего уровня - ваш основной поток блокироваться перестанет. 5 мар 2018 в 8:39

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

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