[SonicTel 0]

Всем привет

Требуется программист С# с отличным знанием сетевых протоколов, умением работать с ними, с сетевыми устройствами и т.п. Особенно протокол UDP. Нужны консультации на регулярной основе. За $$ конечно же.

 

[x893 35]

Огласите первый вопрос пожалуйста.

[antis 1]

Обращайтесь - antis00(собака)mail.ru

 

[ivnor 1]

а С++ не надо

[SonicTel 0]

23 hours ago, x893 said:

Огласите первый вопрос пожалуйста.

Без проблем - 

Есть конкурентная очередь - 

private readonly ConcurrentQueue<DataReceivedFromDeviceEventArgs> _receivedPackets =
            new ConcurrentQueue<DataReceivedFromDeviceEventArgs>();

туда добавляются пакеты UDP (пейлоад) оч быстро. Очередь растет.

 

И есть метод доставания от туда пакетов - 

 while (true)
            {
                
                _queuePacketsNotifier.WaitOne();

                bool packetReceived = _receivedPackets.TryDequeue(out data);
                
                if (packetReceived)
                {
                    что-то делаем.
                }

          }

 

Размер пакета 7кб.

Вот процесс доставания пакета (_receivedPackets.TryDequeue(out data);) - счетчик времени пока не ставил, просто обычный счетчик. и так ясно что ОЧЕНЬ медленно - примерно 200 пакетов в секунду уходят далее на обработку. А надо ну раз в 40-50 быстрее.

Вопрос - что я делаю не так)) 

[antis 1]

24 минуты назад, SonicTel сказал:

Вопрос - что я делаю не так)) 

 

Не показали весь код, что происходит в _queuePacketsNotifier.WaitOne(), знаете только вы.

Не понятно какая нагрузка на CPU.

Какую версию смотрите Debug или Release,

 

[x893 35]

Multi thread ?

Согласен с antis

что происходит в _queuePacketsNotifier.WaitOne()

Сделать свою ConcurrentQueue без сегментации по 32 элемента.

Изменено 14 августа, 2019 пользователем x893

[SonicTel 0]

1 hour ago, antis said:

 

Не показали весь код, что происходит в _queuePacketsNotifier.WaitOne(), знаете только вы.

Не понятно какая нагрузка на CPU.

Какую версию смотрите Debug или Release,

 

м...вообще-то WaitOne() это метод private AutoResetEvent _queuePacketsNotifier = new AutoResetEvent(false);

нужен чтобы while loop не кушал бестолку ресурсы. Ставится нотификация при получении пакета в очередь и далее тут ожидалка, которая срабатывает...

 

[x893 35]

                while (_receivedPackets.TryDequeue(out data))
                {
                    что-то делаем.
                }