Добро пожаловать в форум, Guest  >>   Войти | Регистрация | Поиск | Правила | В избранное | Подписаться
Все форумы / WinForms, .Net Framework Новый топик    Ответить
Топик располагается на нескольких страницах: [1] 2 3   вперед  Ctrl      все
 async await что я делаю не так?  [new]
iskatelsql
Member

Откуда:
Сообщений: 867
был такой код:

static void Main(string[] args)
{
    List<Task> tasks = new List<Task>();
    Stopwatch sw = new Stopwatch();
    sw.Start();

    for (int i = 0; i < 100; i++)
    {
        tasks.Add(Task.Factory.StartNew(() =>
        {
        .........

            bytes = stream.Read(data, 0, data.Length);

        .........
        }));
    }
    Task.WaitAll(tasks.ToArray());

    sw.Stop();
    Console.WriteLine(sw.ElapsedMilliseconds);
    Console.ReadLine();
}


Мне нужно было сделать чтение асинхронным, и я переписал так:

static void Main(string[] args)
{
    List<Task> tasks = new List<Task>();
    Stopwatch sw = new Stopwatch();
    sw.Start();

    for (int i = 0; i < 100; i++)
    {
        tasks.Add(Task.Factory.StartNew(async () =>
        {
            .........

            Task<int> readtask = stream.ReadAsync(data, 0, data.Length);
            await readtask;
            bytes = readtask.Result;

            .........
        }));
    }
    Task.WaitAll(tasks.ToArray());

    sw.Stop();
    Console.WriteLine(sw.ElapsedMilliseconds);
    Console.ReadLine();
}


Задачи работают как нужно, с этим все ок. Hо вот теперь на Task.WaitAll(tasks.ToArray()); программе стало наплевать, сразу переходит к записи времени в консоль. Как это поправить?

Сообщение было отредактировано: 1 май 21, 15:37
1 май 21, 15:44    [22317238]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
fkthat
Member

Откуда:
Сообщений: 4880
Ты все делаешь не так.
1 май 21, 15:48    [22317241]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
Сон Веры Павловны
Member

Откуда:
Сообщений: 6192
https://www.sql.ru/forum/1335400/vyzov-asinhronnogo-metoda-iz-sinhronnogo
1 май 21, 16:20    [22317251]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
iskatelsql
Member

Откуда:
Сообщений: 867
Сон Веры Павловны,

Честно говоря я не понял что из того, что по ссылке, может помочь.
1 май 21, 17:25    [22317264]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
fkthat
Member

Откуда:
Сообщений: 4880
static async Task Main()
{
    Stopwatch sw = new Stopwatch();
    sw.Start();

    await Task.WhenAll(
        Enumerable.Repeat(0, 100)
             .Select(_ => stream.ReadAsync(data, 0, data.Length)));

    sw.Stop();
    Console.WriteLine(sw.ElapsedMilliseconds);
    Console.ReadKey(true);
}
1 май 21, 17:27    [22317265]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
iskatelsql
Member

Откуда:
Сообщений: 867
fkthat,

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

Мне нужно опросить 100 устройств, и секунд через 5 они вернут результаты измерений в том же соединении. Но запрос нужно подать одновременно на все, чтоб привязаться ко времени для статистики, графиков и т.п.

Для тестов утащил с метанита клиент - сервер. Сервер (многопоточный) изменил так, чтоб между запросом и ответом была задержка 5 секунд. Клиента сделал создающим собственно 100 задач. (для тестов опрашиваю один сервер 100 раз, а не 100 различных устройств)
Если в клиенте читать синхронно, то на эти пять секунд поток блочится, и пул неспешно обрабатывает все по очереди. Если чтение переделать на асинхронное - то все получается как нужно - уходят сразу 100 запросов, через 5 секунд приходят 100 ответов.

Вот полный код
клиент:

+
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;

namespace ConsoleApp1
{
    class Program
    {

        const int port = 8888;
        const string address = "127.0.0.1";
        static void Main(string[] args)
        {

            List<Task> tasks = new List<Task>();

            Stopwatch sw = new Stopwatch();
            sw.Start();


            for (int i = 0; i < 100; i++)
            {
                int tmp = i;

                tasks.Add(Task.Factory.StartNew(async () =>
               {
                   TcpClient client = null;
                   try
                   {
                       client = new TcpClient(address, port);
                       NetworkStream stream = client.GetStream();

                       string message = $"qwertyuiop {tmp}";
                       // преобразуем сообщение в массив байтов
                       byte[] data = Encoding.Unicode.GetBytes(message);
                       // отправка сообщения
                       stream.Write(data, 0, data.Length);

                       // получаем ответ
                       data = new byte[64]; // буфер для получаемых данных
                       StringBuilder builder = new StringBuilder();
                       int bytes = 0;
                       do
                       {
                           Task<int> readtask = stream.ReadAsync(data, 0, data.Length);
                           await readtask;
                           //bytes = stream.Read(data, 0, data.Length);
                           bytes = readtask.Result;
                           builder.Append(Encoding.Unicode.GetString(data, 0, bytes));
                       }
                       while (stream.DataAvailable);

                       message = builder.ToString();
                       Console.WriteLine("Сервер: {0}", message);

                   }
                   catch (Exception ex)
                   {
                       Console.WriteLine(ex.Message);
                   }
                   finally
                   {
                       client.Close();
                   }



               }));
            }
            Task.WaitAll(tasks.ToArray());

            sw.Stop();
            Console.WriteLine(sw.ElapsedMilliseconds);
            Console.ReadLine();
        }
    }

}


сервер:

+
using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;

namespace ConsoleServer
{
    public class ClientObject
    {
        public TcpClient client;
        public ClientObject(TcpClient tcpClient)
        {
            client = tcpClient;
        }

        public void Process()
        {
            NetworkStream stream = null;
            try
            {
                stream = client.GetStream();
                byte[] data = new byte[64]; // буфер для получаемых данных

                // получаем сообщение
                StringBuilder builder = new StringBuilder();
                int bytes = 0;
                do
                {
                    bytes = stream.Read(data, 0, data.Length);
                    builder.Append(Encoding.Unicode.GetString(data, 0, bytes));
                }
                while (stream.DataAvailable);

                string message = builder.ToString();

                Console.WriteLine(message);
                // отправляем обратно сообщение в верхнем регистре

                Thread.Sleep(5000);

                message = message.Substring(message.IndexOf(':') + 1).Trim().ToUpper();
                data = Encoding.Unicode.GetBytes(message);
                stream.Write(data, 0, data.Length);

            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
            finally
            {
                if (stream != null)
                    stream.Close();
                if (client != null)
                    client.Close();
            }
        }
    }

    class Program
    {
        const int port = 8888;
        static TcpListener listener;
        static void Main(string[] args)
        {
            try
            {
                listener = new TcpListener(IPAddress.Parse("127.0.0.1"), port);
                listener.Start();
                Console.WriteLine("Ожидание подключений...");

                while (true)
                {
                    TcpClient client = listener.AcceptTcpClient();
                    ClientObject clientObject = new ClientObject(client);

                    // создаем новый поток для обслуживания нового клиента
                    Thread clientThread = new Thread(new ThreadStart(clientObject.Process));
                    clientThread.Start();
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
            finally
            {
                if (listener != null)
                    listener.Stop();
            }
        }
    }



}
1 май 21, 17:57    [22317274]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
iskatelsql
Member

Откуда:
Сообщений: 867
Переделал вот так. Не знаю правильней так или нет... Кстати заметил что в обоих вариантах что-то не то с циклом приема, если буфер меньше сообщения ерунда получается :(

using System;
using System.Diagnostics;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;

namespace ConsoleApp1
{
    class Program
    {
        const int port = 8888;
        const string address = "127.0.0.1";
        const int num = 100;
        static void Main(string[] args)
        {
            Stopwatch sw = new Stopwatch();
            sw.Start();

            TcpClient[] clients = new TcpClient[num];
            Task[] tsk_write = new Task[num];
            Task<int>[] tsk_read = new Task<int>[num];

            for (int i = 0; i < num; i++)
            {
                int tmp = i;
                try
                {
                    clients[i] = new TcpClient(address, port);
                    NetworkStream stream = clients[i].GetStream();

                    string message = $"qwertyuiop {tmp}";

                    byte[] data = Encoding.Unicode.GetBytes(message);

                    tsk_write[i] = stream.WriteAsync(data, 0, data.Length);

                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                }
            }
            Task.WhenAll(tsk_write).Wait();

            for (int i = 0; i < num; i++)
            {
                try
                {

                    byte[] data = new byte[64];
                    StringBuilder builder = new StringBuilder();
                    int bytes = 0;
                    do
                    {
                        tsk_read[i] = clients[i].GetStream().ReadAsync(data, 0, data.Length);
                        bytes = tsk_read[i].Result;
                        builder.Append(Encoding.Unicode.GetString(data, 0, bytes));
                    }
                    while (clients[i].GetStream().DataAvailable);

                    string message = builder.ToString();
                    Console.WriteLine("Сервер: {0}", message);

                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                }
                finally
                {
                    clients[i].Close();
                }
            }
            Task.WhenAll(tsk_read).Wait();
            sw.Stop();
            Console.WriteLine(sw.ElapsedMilliseconds);
            Console.ReadLine();
        }
    }
}
1 май 21, 19:19    [22317280]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
iskatelsql
Member

Откуда:
Сообщений: 867
Хотя в таком виде оно и в синхронном варианте нормально работает. Но это не совсем то, что я хотел - в таком виде придется дожидаться максимального по задержке запроса чтобы продолжить дальше. А в тасках можно было бы обрабатывать по приходу ответа.

Сообщение было отредактировано: 1 май 21, 19:31
1 май 21, 19:31    [22317283]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
iskatelsql
Member

Откуда:
Сообщений: 867
Если попытаться сформулировать... Мне нужно чтоб не блочился поток в пуле на время ожидания, но при этом чтоб прием данных происходил не в одном потоке, а в нескольких, в пуле. Ну то-есть разослали хоть тысячу запросов и ждем хоть год. А как пришел ответ (скажем пришли ответы от 10 одновременно) - получаем и обрабатываем его в несколько потоков (ну сколько там пул решит оптимальным)
1 май 21, 19:56    [22317290]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
Где-то в степи
Member

Откуда: Под Таганрогом
Сообщений: 4370
iskatelsql,
как бы немножко обескуражен, от вашего кода. Имхо возникает масса вопросов про таски, абстракция для работы с потоками,
вот такая вот обструкция, что у многих сностит голову. А сносит, имхо из-за того, что отстутствуют так назывые понятия thread
и как устроены пулы.
что любят потоки, - самодостаточность, все что нужно, лежит внутри, никакого общения с наружностью, никаких общих
переменных, только в крайнем случае, как пример отдать результат., все что нужно, он получает при создании..
вы пошли в поход, все что нужно взяли с собой, ну и спутник,( позвонить маме что вы на вершине), никаких петь ( взять веревку когда полезем в гору)
что делает поток - поток выпоняет осмысленный кусок кода ( есть начало и есть конец) ба да... да это фукция.
получается, что бы поток запустился, в него нужно передать указатель на этот кусок ( или название функции, или написать ее
в виде лямбды по месту обьявления ( я опуская слово делегат что бы не морочить вам голову))
у потока есть интересная особенность, когда он исполнит код, он умирает ( про поход пример неудачный), как правило, за редким исключением.
если создать массу потоков, ими можно упралять как стадом баранов (синхронизация потоков).
в контексте вышесказанного.
вы должны стереть все нах.
1 содать статическую функцию закачки данных. оттестировать ее, то есть,
в главном методе( точке входа) только вызов этой функции, никаких бл. бенчмаркеров, ничего статического, кроме этой функции.
можете передать в параметрах - куда лезем.
почему статик ( для верочки, что шалавливые ручки не сделали замыкание)
2 проверить.
если все нормально - вы доросли до потока.
потом проще
создаемем список, ( желательно реентерабельный) и только чтение ( защитимся комилятором от шаловливых рук), куда будем выводить результат, если хочешь его обрабатывать
делай очередь, с одного конца закидывай результат, с другого выгребай на обработку (если не пустая)
Одни поток - запускаем
внизу ставим цикл прослушки списка, если в списке нуль - крутимся если 1 - поток отработал.
если все ок, делаем 100 потоков, в прослушке уже ловим 100.
и не забывать, что ексепешн - тоже результат ( а то замерзнешь до второго пришествия)
хочешь запустить их по зеленому сигналу светофора - кури синхронизацию потоков.
бенчмарки свои - можно спрятать в поток и отдать с результатом ( имхо более приближенно)
забудь про таски, таски потом...
жаль студия на работе - показал бы механизм создания свой пула потоков (10 - 20 строк кода) и забыть про таски..
имхо может завтра..
1 май 21, 23:01    [22317324]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
fkthat
Member

Откуда:
Сообщений: 4880
iskatelsql
Task.WhenAll(tsk_write).Wait();

В печь.

iskatelsql
Task.WhenAll(tsk_read).Wait();

В печь.
2 май 21, 02:17    [22317352]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
fkthat
Member

Откуда:
Сообщений: 4880
Где-то в степи
А сносит, имхо из-за того, что отстутствуют так назывые понятия thread
и как устроены пулы.

Сносит, имхо, из-за того, что отсутствуют так называемые понятия асинхронности.

Тут сплошной i/o - все вообще можно в одном потоке сделать с той же эффективностью.
2 май 21, 02:20    [22317353]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
iskatelsql
Member

Откуда:
Сообщений: 867
Ну давайте, наседайте... Ваше право. Я вообще в первый раз с этой асинхронностью.
Сказал уже что нужно - обрабатывать результат во множестве потоков, но так чтоб пул не блокировался, и ожидающие шли ждать.
2 май 21, 02:51    [22317355]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
iskatelsql
Member

Откуда:
Сообщений: 867
Где-то в степи,

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

ЗЫ. воспользоваться тем механизмом, не переписывать его.

Сообщение было отредактировано: 2 май 21, 02:55
2 май 21, 03:00    [22317358]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
iskatelsql
Member

Откуда:
Сообщений: 867
как бы немножко обескуражен, от вашего кода.
я как- бы зашел спросить, то чего не знаю. По правилам нужно предоставить то, что сделал, что пытался сделать - я предоставил, оно работает даже. Что еще нужно?

Сообщение было отредактировано: 2 май 21, 03:03
2 май 21, 03:06    [22317360]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
iskatelsql
Member

Откуда:
Сообщений: 867
как бы немножко обескуражен, от вашего кода.


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

А даже не почти, а работает - конкретный вопрос был: от чего не ждет на Task.WaitAll(tasks.ToArray());

Так сложно именно на этот вопрос ответить?

Вы наверное забываете что разговариваете с самоучкой, а не с, как это называется, "сеньор разработчик" что-ли.

Сообщение было отредактировано: 2 май 21, 03:10
2 май 21, 03:12    [22317361]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
hVostt
Member

Откуда:
Сообщений: 19326
iskatelsql
А даже не почти, а работает - конкретный вопрос был: от чего не ждет на Task.WaitAll(tasks.ToArray());


Если в лоб.
Метод же возвращает Task.
Т.е. вернул запущенную асинхронно задачу.
А не результат выполнения.

Обращайте внимание не только на название метода, но и на то, что он возвращает.
По идее, асинхронные методы в названии должны иметь суффикс -Async, но не все и не всегда этому следуют.
2 май 21, 04:00    [22317370]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
hVostt
Member

Откуда:
Сообщений: 19326
iskatelsql,

Я минимально поправил код, приведённый в начале топика, добавленное выделено цветом.
Понятно, что выше приводили разные вариации, это именно минимальное исправленеи вашего кода, чтобы заработало. Но конечно есть к чему ещё придраться.

static async Task Main(string[] args)
{
    List<Task> tasks = new List<Task>();
    Stopwatch sw = new Stopwatch();
    sw.Start();

    for (int i = 0; i < 100; i++)
    {
        tasks.Add(Task.Run(async() =>  // убрал вот этоTask.Factory.StartNew(async () =>
        {
            .........

            Task<int> readtask = stream.ReadAsync(data, 0, data.Length);
            await readtask;
            bytes = readtask.Result;

            .........
        }));
    }
    await Task.WaitAll(tasks.ToArray());

    sw.Stop();
    Console.WriteLine(sw.ElapsedMilliseconds);
    Console.ReadLine();
}
2 май 21, 04:04    [22317371]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
iskatelsql
Member

Откуда:
Сообщений: 867
hVostt,

static async Task Main
Вот это обескураживающая меня конструкция, на которую компилятор ругается что нечего компилировать нет точки входа (vs 2019).
2 май 21, 04:12    [22317372]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
hVostt
Member

Откуда:
Сообщений: 19326
iskatelsql,

посмотрите здесь

https://docs.microsoft.com/ru-ru/dotnet/csharp/misc/cs4009

вам нужно настроить, что используется последняя версия языка C#

Картинка с другого сайта.

Картинка с другого сайта.

Сообщение было отредактировано: 2 май 21, 04:12
2 май 21, 04:17    [22317373]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
iskatelsql
Member

Откуда:
Сообщений: 867
iskatelsql
hVostt,

static async Task Main
Вот это обескураживающая меня конструкция, на которую компилятор ругается что нечего компилировать нет точки входа (vs 2019).


Хотя на пустом проекте сейчас это сработало. (раньше пытался изменить существующий)

Беру паузу, буду думать.
Спасибо Вам.

Сообщение было отредактировано: 2 май 21, 04:13
2 май 21, 04:20    [22317374]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
fkthat
Member

Откуда:
Сообщений: 4880
hVostt
await Task.WaitAll(tasks.ToArray());
fkthat
В печь.
2 май 21, 10:29    [22317387]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
fkthat
Member

Откуда:
Сообщений: 4880
fkthat
hVostt
await Task.WaitAll(tasks.ToArray());

fkthat
В печь.

А, все, понял. Ты просто перепутал WaitAll и WhenAll. У меня на Wait или Result уже просто рефлекторная реакция.
2 май 21, 10:31    [22317388]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
fkthat
Member

Откуда:
Сообщений: 4880
hVostt
но не все и не всегда этому следуют.

Знал одних уродов, которые принципиально -Async не дописывали. И я с их кодом провозился полчаса на вызове как-то так:
var userId = _userService.GetUser(...).Id;

Потому что GetUser возвращал Task. Сказано в букваре - дописывать -Async и ConfigureAwait, значит нехер какие-то свои половые фантазии выдумывать.
2 май 21, 10:37    [22317390]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
Где-то в степи
Member

Откуда: Под Таганрогом
Сообщений: 4370
iskatelsql,
да ничего вы не знаете, по этому разговариваю с вами как с ребенком,
гыгы знаю потоки но не могу писать асинхронный код.
ну да ладно, самое прикольное, когда вы пинками все исправите, и все будет партикулярно.
цена вашего кода будет меньше цены бумаги на которой он написан.
потому что: на простом декстопе на стандартным core5, нативные потоки будут исполняться быстрее примерно в 5 раз
чем пуловые, и вы виртуалного работатдателя введете в заблуждение. ( я кончно исключаю что это пром. решение)
зы гы
а еще, с вашими хотелками, (работать по свистку) тут ИМХО не совсем получится, и можно попасть в замок.

Сообщение было отредактировано: 2 май 21, 11:19
2 май 21, 11:19    [22317403]     Ответить | Цитировать Сообщить модератору
Топик располагается на нескольких страницах: [1] 2 3   вперед  Ctrl      все
Все форумы / WinForms, .Net Framework Ответить