Задержки при ожидание ответа (Dataflow)

#c_sharp #async_await #tpl_dataflow

                    
В программе необходимо в отдельном потоке проводить некоторые операции, как например
отправлять запрос серверу и ждать от него ответ. Для реализации использую библиотеку
Dataflow, дабы выполнять это всё последовательно. 
Реализовал такой класс:

partial class PoolManager
{
    CancellationTokenSource CT;
    TransformBlock, string> ActionBlock;

    public PoolManager()
    {
        PM = this;
        CT = new CancellationTokenSource();
        ActionBlock = new TransformBlock, string>(async n =>
        {
            await Task.Delay(2000);
            string a = "";
            try
            {
                a =  n();
            }
            catch (Exception e) { }
            return a;
        },
        new ExecutionDataflowBlockOptions { CancellationToken = CT.Token });
    }

    public void Add(Action func, string message)
    {
        ActionBlock.Post(new Func(delegate () { func(); return message; }));
    }
}  


И целом работает как нужно, но когда я посылаю в него функцию, внутри которой есть
отправка и ожидание ответа, то на моменте ожидания, интерфейс программы подвисает.
В среднем это 100мс, иногда доходит и до 500мс или 1000мс, что становится очень заметно.
Не понимаю в чём причина, ибо он в отдельном потоке должен идти.
    

Ответы

Ответ 1

Вопрос решился сам собой.



В целом данный код работает вполне корректно, и проблема таилась глубже.
В конкретной задаче на которой я тестировал этот код, в TransformBlock отправлялась
функция находящаяся в элементе управления UserControl.
В этой функции вызывался метод экземпляра класса, и этот метод посылал запрос на
сервер и ожидал ответа. Метод был синхронный и потому поток в котором он вызывался
должен был блокироваться. Для того, что бы этого не было делал это в паралельном потоке,
но основной поток всё равно блокировался.

В итоге я обратил внимание, что код в посылаемой функции выполяется через Dispatcher,
дабы я мог выполнять заполнение ProgressBar, и следовательно проверив номер потока
через Thread.CurrentThread.ManagedThreadId, при входе в функцию и в диспетчер, понял
что код внутри Dispatcher выполняется в уже в потоке UI, а не в потоке TransformBlock,
от того запрос и проходил в потоке UI, что и вызывало подвисание.
Спасибо VladD, за помощь в решении данной проблемы.

Делать ли каскад методов асинхронными, если они могут возвращать просто Task<T>

#c_sharp #net #async_await #async #clr

Терзает вопрос, найти внятный ответ не могу. Гуглится не то.

Вот у меня есть действительно асинхронный метод, в котором несколько await'ов. Этот
метод вызывается на более верхнем уровне:

public async Task UpperLevelMethod()
{
    return await _component.RealyAsyncMethod();
}


Ну и так далее, по всем слоям приложения. 

Но ведь по идее, можно написать так:

public Task UpperLevelMethod()
{
    return _component.RealyAsyncMethod();
}


И вызов await UpperLevelMethod() будет корректно отрабатывать. И, на сколько я понимаю,
этот метод даже лучше, т.к. не будет создаваться дополнительные экземпляры IAsyncStateMachine,
поправьте, если я не прав.

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

Есть ли какие-то подводные камни, у такого вызова? Либо, в случаях, когда не нужно
делать асинхронное продолжение, можно (а возможно даже лучше) делать метод не асинхронным?

P.S. Тот же Скит описывает, что для проверки аргументов лучше делать так:

public Task UpperLevelMethod(string arg)
{
    /*
    Проверка аргумента и выброс исключения в случае ошибки
    */
    return _component.RealyAsyncMethod();
}


Но он говорит именно про проверку аргументов, чтобы она проходила в синхронном режиме.
Об оптимизации - ничего.

Update: 
Консольное приложение, собраное в релизе, с таким кодом:

static void Main(string[] args)
{
    Task.Run(Foo5);
}

static async Task Foo1() => await Task.FromResult(5);

static Task Foo2() => Foo1();

static Task Foo3() => Foo2();

static Task Foo4() => Foo3();

static Task Foo5() => Foo4();


весит 8 192 байт, при добавлении await'ов - 10 240 байт.
    

Ответы

Ответ 1

Совершенно верно, лучше не писать лишний раз async если код работает и без него.
Нет никаких причин писать лишние слова async и await.

Sockets client+server with await/async c# 5.0

#c_sharp #async_programming #async_await

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

Проблема такова. Хочу написать простое асинхронное клиент-серверное приложение с
банальной передачей байт. Удалось найти и реализовать 2 решения: колбэки и await/async
базирующиеся на tcplistener и networkStream. Но это все не то. Пытаюсь написать базируясь
на Task, Sockets и async/await без tcplistener и networkStream. Почитал некоторую литературу,
но необходимого ответа/примера не нашел. 

Знаю, что делается это базируясь на следующем:

public static Task ConnectAsync(this Socket socket, EndPoint remoteEP) {
    return Task.Factory.FromAsync(socket.BeginConnect, socket.EndConnect, remoteEP,
null);
}


но пока ничего не выходит. Даже сервер не могу "собрать" воедино. Прошу помощи.

Обновление

Удалось подключиться.А вот с передачей пока не получается.

private readonly Socket _server;
public ServerSocket(IPAddress ipAddress, int port) {
    _server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    _server.Bind(new IPEndPoint(ipAddress, port));
    _server.Listen(20);
    Console.WriteLine("Wait connection");
    Accept();
}
private async void Accept() {
    for (;;) {
        var socket = await Task.Factory.FromAsync < Socket > (_server.BeginAccept,
_server.EndAccept, true);
        Console.WriteLine("Connected");
    }
}

    

Ответы

Ответ 1

Для начала, правильный путь — это именно async/await.

По поводу работы с сокетами, вот есть хороший обзор.

Итак, создаём серверный сокет:

public ServerSocket(IPAddress ipAddress, int port)
{
    _server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    _server.Bind(new IPEndPoint(ipAddress, port));
    _server.Listen(20);
}


Здесь мы создали сокет, но основная работа у нас не мгновенна, поэтому выносим её
в метод Run.

Task AcceptAsync()
{
    return Task.Factory.FromAsync(
           _server.BeginAccept, _server.EndAccept, null);
}

public async Task Run()
{
    while (true)
    {
        var client = await AcceptAsync();
        var clientServeTask = ServeClient(client);
        // что дальше делать с этим заданием - ваше дело
        // например, вы можете просто записать его в список
    }
}


ConnectAsync для сервера не нужен.

В ServeClient инстанциируеем объект, представляющий клиента:

async Task ServeClient(Socket client)
{
    using (var c = new Client(client))
        await c.RunAsync();
}


В объект Client лежит собственно логика вашего сервера.

byte[] greeting = Encoding.UTF8.GetBytes("Hi, I'm server ru.SO/2015");
public async Task RunAsync()
{
    await SendAsync(greeting);
    var result = await ReceiveAsync(20);
    // ...
}


(Возможно, вам захочется вернуть результат.)

Ну и вспомогательные процедуры:

Task TrySendAsync(byte[] buffer, int offset, int size, SocketFlags flags)
{
    return Task.Factory.FromAsync(
        _clientSocket.BeginSend, _clientSocket.EndSend,
        buffer, offset, size, flags, null);
}

Task SendAsync(byte[] buffer)
{
    int sent = 0;
    int remaining = buffer.Length;
    while (remaining > 0)
    {
        var partSent = await TrySendAsync(data, sent, remaining, SocketFlags.None);
        sent += partSent;
        remaining -= partSent;
    }
}


Не забудьте закрыть клиентский сокет в Dispose.



Да, наверняка вам захочется суметь оборвать работу сервера. Для этого вам стоит протянуть
CancellationToken'ы через Task'и.


Ответ 2

Могу посоветовать пример из другого вопроса - https://ru.stackoverflow.com/a/516728/192004 . 

Там создается 10 клиентов, сервер поочередно принимает их и отправляет ответы. Сервер
работает в одном потоке (точнее, в одной Task), клиенты могут работать в разных потоках.
Всё на async/await + куча советов.

Использовать await как промис для пользовательского действия

#c_sharp #net #vbnet #async_await

Хочу использовать Task как промис. Т. е. вызываемая функция создаёт некий Task, а
вызывающая применяет к нему await. Тот таск ничего не делает и просто ждёт, пока кто-то
ещё его заресолвит. Примерно как с костылём в следующем коде:

Imports System.Threading

Public Class Form1
  Private Async Sub Form1_Load(sender As Object, e As EventArgs) Handles MyBase.Load
    Me.Text = "Click the button to continue"
    Await ClikTheButton()
    Me.Text = "Thanks for clicking"
  End Sub

  Private Function ClikTheButton() As Task
    Dim Sem As New SemaphoreSlim(0, 1)

    Dim Handler As EventHandler = Sub(sender As Object, e As EventArgs)
                                    Sem.Release()
                                    RemoveHandler Button1.Click, Handler
                                  End Sub

    AddHandler Button1.Click, Handler
    Return Sem.WaitAsync()
  End Function
End Class

    

Ответы

Ответ 1

Надо использовать TaskCompletionSource:

Task ClickTheButton(CancellationToken token) {
  var tcs = new TaskCompletionSource