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

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

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 [заблокирован]

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

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

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

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

Откуда:
Сообщений: 4873
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

Откуда:
Сообщений: 862
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

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

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

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

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

Откуда:
Сообщений: 862
Если попытаться сформулировать... Мне нужно чтоб не блочился поток в пуле на время ожидания, но при этом чтоб прием данных происходил не в одном потоке, а в нескольких, в пуле. Ну то-есть разослали хоть тысячу запросов и ждем хоть год. А как пришел ответ (скажем пришли ответы от 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 [заблокирован]

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

В печь.

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

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

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

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

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

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

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

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

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

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

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

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

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


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

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

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

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

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

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


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

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

Откуда:
Сообщений: 19236
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

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

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

Откуда:
Сообщений: 19236
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

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

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


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

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

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

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

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

fkthat
В печь.

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

Откуда:
Сообщений: 4873
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]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
fkthat
Member [заблокирован]

Откуда:
Сообщений: 4873
Где-то в степи
нативные потоки будут исполняться быстрее примерно в 5 раз
чем пуловые

Ололо. А почему не в 50, а то и, бери больше, в 500? В пуле какие-то особые потоки, в которые рантайм сам вставляет в случайных местах пустые циклы?
2 май 21, 11:56    [22317420]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
Где-то в степи
Member

Откуда: Под Таганрогом
Сообщений: 4370
fkthat,
а ты попробуй его архитектуру.
2 май 21, 13:26    [22317443]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
fkthat
Member [заблокирован]

Откуда:
Сообщений: 4873
Где-то в степи
а ты попробуй его архитектуру.

Чью?
2 май 21, 13:28    [22317444]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
Где-то в степи
Member

Откуда: Под Таганрогом
Сообщений: 4370
fkthat,
у него закачка файлов, планировшик пула будет балансировать наргузку по минимальному количеству ядер,
 for (int d = 0; d < 100; d++)
 {
     Task.Run(() => { Thread.Sleep(200); Console.WriteLine($" done {++i}"); });
     //new Thread(() => { Thread.Sleep(200); Console.WriteLine($" done {++i}"); }).Start();
 }
            Console.Read();
2 май 21, 13:50    [22317448]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
fkthat
Member [заблокирован]

Откуда:
Сообщений: 4873
Где-то в степи
fkthat,
у него закачка файлов, планировшик пула будет балансировать наргузку по минимальному количеству ядер,
 for (int d = 0; d < 100; d++)
 {
     Task.Run(() => { Thread.Sleep(200); Console.WriteLine($" done {++i}"); });
     //new Thread(() => { Thread.Sleep(200); Console.WriteLine($" done {++i}"); }).Start();
 }
            Console.Read();


А ты вот так попробуй, и увидишь, как твой говнокод сосед три раза:

const int N = 100;
const int DELAY = 1000;

Stopwatch sw = new();

sw.Start();
List<Thread> threads = new();
for (int d = 0; d < N; d++)
{
     Thread thread  = new(() => { Thread.Sleep(DELAY); });
     threads.Add(thread);
     thread.Start();
}
threads.ForEach(t => t.Join());
sw.Stop();
Console.WriteLine(sw.Elapsed);
sw.Reset();

sw.Start();
await Task.WhenAll(Enumerable.Repeat(0, N).Select(_ => Task.Delay(DELAY)));
sw.Stop();
Console.WriteLine(sw.Elapsed);
sw.Reset();
2 май 21, 14:16    [22317461]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
Где-то в степи
Member

Откуда: Под Таганрогом
Сообщений: 4370
fkthat,
гы пробовать не начем, но имхо не убедительно.
2 май 21, 14:26    [22317468]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
fkthat
Member [заблокирован]

Откуда:
Сообщений: 4873
Где-то в степи
гы пробовать не начем,

Ну тогда и не пересказывай тут свои выдумки.
2 май 21, 14:30    [22317472]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
Roman Mejtes
Member

Откуда: г. Пермь
Сообщений: 4177
автор, если ты используешь ReadAsync, то накой хрен тебе весь этот цирк с созданием тасков и прочим?
конечный метод чтения уже поддерживает асинхронность, больше тебе ничего не надо.
2 май 21, 18:01    [22317564]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
hVostt
Member

Откуда:
Сообщений: 19236
fkthat
А, все, понял. Ты просто перепутал WaitAll и WhenAll. У меня на Wait или Result уже просто рефлекторная реакция.


Да, не обратил внимания, спасибо :)

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

Откуда:
Сообщений: 862
Где-то в степи
цена вашего кода будет меньше цены бумаги на которой он написан.


Цена помидорок, которые Вы вырастите на даче будет меньше, чем цена помидорок, выращенных профессиональным селекционером.
3 май 21, 02:02    [22317690]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
iskatelsql
Member

Откуда:
Сообщений: 862
del что-то странное - вместо правки добавляет новое сообщение

Сообщение было отредактировано: 3 май 21, 01:58
3 май 21, 02:05    [22317691]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
Сон Веры Павловны
Member

Откуда:
Сообщений: 6174
iskatelsql
Честно говоря я не понял что из того, что по ссылке, может помочь.

Там написано, что возвращает Task.Factory.StartNew, если ему скармливают делегат с async. И из этого напрямую следует, почему
iskatelsql
на Task.WaitAll(tasks.ToArray()); программе стало наплевать, сразу переходит к записи времени в консоль

iskatelsql
Цена помидорок, которые Вы вырастите на даче будет меньше, чем цена помидорок, выращенных профессиональным селекционером.

Это общераспространённое заблуждение. Себестоимость любого продукта, произведённого в промышленных масштабах, ниже себестоимости кустарного производства.
3 май 21, 05:04    [22317704]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
ВМоисеев
Member

Откуда: Редкино
Сообщений: 2510
>hVostt, вчера, 04:17 [22317373]
>посмотрите здесь
<
прибавление, и здесь
3 май 21, 11:19    [22317728]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
ВМоисеев
Member

Откуда: Редкино
Сообщений: 2510
>iskatelsql, 1 май 21, 15:44 [22317238]
>...Мне нужно было сделать чтение асинхронным, и я переписал так:
<
По идее должно работать. Посмотри здесь,
в части ReadAsync(Byte[], Int32, Int32). Примеры.
3 май 21, 13:21    [22317766]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
iskatelsql
Member

Откуда:
Сообщений: 862
Где-то в степи
и вы виртуалного работатдателя введете в заблуждение.

Да это на самом деле мое хобби, точнее приложение к хобби. Задачи типа переделать данные в формат, понятный какой ни будь программе. Мой код это топором переделанная копипаста из инета. Часто он нужен только один раз в жизни, и поэтому ни проверок ни юзер-интерфейсов не имеет - запускается из под отладчика. И если дважды два не намного больше пяти то сойдет :)

Где-то в степи
да ничего вы не знаете, по этому разговариваю с вами как с ребенком.

Да, не знаю, но давайте хотяб как со студентом-первокурсником. А то как с ребенком - это "туда не ходи сюда не лезь, брось бяку"...

Где-то в степи
а еще, с вашими хотелками

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

ЗЫ. я разбираюсь в отладчиках / дизассемблерах. Собственно мое знакомство с программированием началось с SoftIce. Понимать как все работает я умею, реверснуть несложную прогу без защит смогу, а вот красивый код писать - ну наверное не мое.

Сообщение было отредактировано: 4 май 21, 01:08
4 май 21, 01:10    [22318080]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
fkthat
Member [заблокирован]

Откуда:
Сообщений: 4873
Забудьте вы наконец все про эти Wait, Result, Run и подобное, как будто их и нет вовсе. Run иногда может быть нужен, но единственное для чего он нужен - это завернуть синхронный код, который by design невозможно переделать в асинхронный путем помещения его в поток из пула. Всё.
4 май 21, 11:46    [22318173]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
hVostt
Member

Откуда:
Сообщений: 19236
fkthat
Забудьте вы наконец все про эти Wait, Result, Run и подобное, как будто их и нет вовсе. Run иногда может быть нужен, но единственное для чего он нужен - это завернуть синхронный код, который by design невозможно переделать в асинхронный путем помещения его в поток из пула. Всё.


Сложна :)
4 май 21, 12:01    [22318184]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
iskatelsql
Member

Откуда:
Сообщений: 862
fkthat
Забудьте вы наконец все про эти Wait, Result, Run и подобное, как будто их и нет вовсе.


я с асинхронностью дела никогда не имел, может и не туда лезу (хотя неплохо было б разобраться)

Допустим потоки: Вот представьте торрент-клиент: нужно коннектиться ко многим. Если мало потоков поставишь - а они (сидеры) ограничение скорости настроили в 100 кбит- некачается... Много поставишь - а там волна пойдет больше чем пропускная способность - цирк с конями, разрывы по таймаутам.

Вот я и хотел от этой асинхронности чтоб те, что ожидают пакет, в очередь ставились, а те что пакет принимают - принимали.

Сообщение было отредактировано: вчера, 00:14
вчера, 00:20    [22318565]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
fkthat
Member [заблокирован]

Откуда:
Сообщений: 4873
iskatelsql
может и не туда лезу

Ты лезешь куда надо, только не с той стороны.
вчера, 07:04    [22318591]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
winsky!
Member

Откуда: Київ
Сообщений: 5139
fkthat,

автор
Сказано в букваре - дописывать -Async и ConfigureAwait,

ConfigureAwait прям везде?
вчера, 08:54    [22318602]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
fkthat
Member [заблокирован]

Откуда:
Сообщений: 4873
winsky!
ConfigureAwait прям везде?

Везде.

https://docs.microsoft.com/en-us/dotnet/fundamentals/code-analysis/quality-rules/ca2007

Сообщение было отредактировано: вчера, 09:41
вчера, 09:48    [22318629]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
hVostt
Member

Откуда:
Сообщений: 19236
fkthat
winsky!
ConfigureAwait прям везде?

Везде.

https://docs.microsoft.com/en-us/dotnet/fundamentals/code-analysis/quality-rules/ca2007


Для библиотек мы юзаем Fody :)
Честно говоря, не понимаю, почему эта фича не входит в коробку, я имею в виду глобальная настройка на уровне сборки.

Сообщение было отредактировано: вчера, 11:51
вчера, 11:59    [22318688]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
fkthat
Member [заблокирован]

Откуда:
Сообщений: 4873
hVostt
Честно говоря, не понимаю, почему эта фича не входит в коробку, я имею в виду глобальная настройка на уровне сборки.

Ну так она через инструментацию сборки ведь работает? Если так, то логичнее было бы её тогда вообще в сам компилятор встроить.
вчера, 12:03    [22318693]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
winsky!
Member

Откуда: Київ
Сообщений: 5139
fkthat,

в гнезде :)

не одним мсдном
вчера, 15:04    [22318818]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
fkthat
Member [заблокирован]

Откуда:
Сообщений: 4873
winsky!
fkthat,
в гнезде :)
не одним мсдном

Ты мне предлагаешь изучать по чьему-то блогу то, что я и так уже сто лет как знаю?
вчера, 15:09    [22318826]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
winsky!
Member

Откуда: Київ
Сообщений: 5139
fkthat,

нет, я тебе предлагаю не возводить ничего в абсолют.
и не ломать неокрепших умов.
вчера, 15:12    [22318834]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
winsky!
Member

Откуда: Київ
Сообщений: 5139
fkthat,

ну и если очень хочется официальной доки

автор
You should not use ConfigureAwait when you have code after the await in the method that needs the context. For GUI apps, this includes any code that manipulates GUI elements, writes data-bound properties or depends on a GUI-specific type such as Dispatcher/CoreDispatcher. For ASP.NET apps, this includes any code that uses HttpContext.Current or builds an ASP.NET response, including return statements in controller actions. Figure 7demonstrates one common pattern in GUI apps—having an async event handler disable its control at the beginning of the method, perform some awaits and then re-enable its control at the end of the handler; the event handler can’t give up its context because it needs to re-enable its control.


правда, твое "всегда" уже не всегда?
вчера, 15:18    [22318839]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
fkthat
Member [заблокирован]

Откуда:
Сообщений: 4873
автор
You should not use ConfigureAwait when you have code after the await in the method that needs the context.

Удивишься, но это эквивалентно вызову ConfigureAwait(true) потому что оно по-дефолту.
вчера, 15:29    [22318848]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
fkthat
Member [заблокирован]

Откуда:
Сообщений: 4873
winsky!
правда, твое "всегда" уже не всегда?

Можешь его не писать, лично тебе я разрешаю.
вчера, 15:30    [22318851]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
winsky!
Member

Откуда: Київ
Сообщений: 5139
fkthat,

ага. ну я понял. и ты тоже.
вчера, 15:32    [22318853]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
winsky!
Member

Откуда: Київ
Сообщений: 5139
автор
Можешь его не писать, лично тебе я разрешаю.

я-то как раз пишу. где надо. где не надо - не пишу.
вчера, 15:38    [22318859]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
hVostt
Member

Откуда:
Сообщений: 19236
fkthat
hVostt
Честно говоря, не понимаю, почему эта фича не входит в коробку, я имею в виду глобальная настройка на уровне сборки.

Ну так она через инструментацию сборки ведь работает? Если так, то логичнее было бы её тогда вообще в сам компилятор встроить.


Примерно так это и работает, сначала компилируется, потом Fody вносит изменения прям в сборку, добавляя везде ConfigureAwait()
вчера, 15:59    [22318870]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
fkthat
Member [заблокирован]

Откуда:
Сообщений: 4873
winsky!
я-то как раз пишу. где надо. где не надо - не пишу.

Забей, я же тебе дал карт-бланш писать как хочешь. Будут проблемы, например, с ревью - скажи, что я уже одобрил.

Сообщение было отредактировано: вчера, 16:15
вчера, 16:22    [22318887]     Ответить | Цитировать Сообщить модератору
 Re: async await что я делаю не так?  [new]
iskatelsql
Member

Откуда:
Сообщений: 862
fkthat
Ты лезешь куда надо, только не с той стороны.

Ну ЗБС теперь, его заблочили до того, как он мне объяснил с какой стороны лезть.

Разблочьте плиз, пусть по теме то ответит, раз среди вас желающих нет...

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