Как десериализовать в отдельном потоке ?

@Bespredeliwe · Регистрация: 10.04.2015

Author24 — интернет-сервис помощи студентам

Метод MessageReceiverFirst принимает сокет и потом в отдельном потоке десериализует объект который передает этот же клиент. Когда делаю все в главном потоке все работает, как только я выполняю все это в отдельном потоке нечего не выходит глобальная переменная для десериализации всегда null.
Подскажите что я упустил, не могу сообразить...
Метод ацептера:

C#

  private void SocketAccepter()
        {
            Thread th = new Thread(delegate ()
            {
                Socket cl;
                Client cli;
                int Cur = 0;
                while (isServerRunning)
                {
                    try
                    {
                        MyMSG += new Action<MessageLib.Message>(MyEvMeth);
                        cl = listener.Accept();
                        isDone = true;
                        //MSGEvent();
                        MessageReceiverFirst(cl);
                        cli = new Client(cl, msg);
 
                      if (MyEvent1 != null)
                        {
                            
                            MyEvent1("\n\r" + "Client connected: ID:" + Cur.ToString() + "\n\r");
                        }
 
                        if (MyEvent != null)
                        {
                            MyEvent(cli);
                        }
}
                    catch (Exception e)
                    {
                        MyEvent1("Exeption: "+e.ToString());
                    }
                }
            });
            th.IsBackground = true;
            th.Start();
        }

Метод приема сообщения для десериализации

C#

private void MessageReceiverFirst(Socket r_client)
        {
 
            //Для каждого нового подключения, будет создан свой поток для приема пакетов
            Thread th = new Thread( (object msg) =>
            {
                while (isDone)
                {
                   
                    //if (r_client.Connected)
                    //{
                    // Сюда будем записывать принятые байты
                    byte[] bytes = new byte[1024];
                        // Принимаем 
                        r_client.Receive(bytes);
                        if (bytes.Length != 0)
                        {                        
                        msg = ((MessageLib.Message)Deserialize(bytes));
                        
                    }
                        isDone = false;
                       
                    //}
                }
            Thread e = Thread.CurrentThread;
            e.Abort();
 
        });
          
            th.IsBackground = true;
            th.Start(msg);
        }

Метод десериализации:

C#

public static object Deserialize(byte[] data)
        {
            using (var memoryStream = new MemoryStream(data))
                return (new BinaryFormatter()).Deserialize(memoryStream);
        }

@EveKS · 21.10.2016, 21:03

Bespredeliwe, как это вообще компилится?
Может через Task всё это осуществить, и чтоб не висло, пока всё это происходит, еще и async?
Сразу бросается в глаза:

C#

         Thread th = new Thread( (object msg) =>
            {
                 // ToDo
            }); //th
            th.IsBackground = true;
            th.Start(msg);// откуда тут msg взялось??????????????

@Bespredeliwe · 21.10.2016, 21:10 **[ТС]**

Тут естественно не весь код, msg это глобальная переменная, куда я записываю десериализырованный объект. По моему разницы с помощью какого класса я буду создавать поток вообще нету, суть в том что в отдельном нечего не десериализуется.

@OwenGlendower · 21.10.2016, 21:15

Bespredeliwe, переменная msg не меняется по той же причине по которой в примере ниже не меняется массив.

C#

static int[] arr;
static void Main()
{
    arr = new int[]{10,20,30,40};
    Console.WriteLine(arr[0]); // 10
    DoSmth(arr);
    Console.WriteLine(arr[0]); // Все еще 10
}
 
static void DoSmth(object obj)
{
    obj = new int[] {-10,-20,-30,-40};
}

Кликните здесь для просмотра всего текста

Меняется локальная переменная ссылочного типа

@Bespredeliwe · 21.10.2016, 21:29 **[ТС]**

Сообщение от OwenGlendower

Bespredeliwe, переменная msg не меняется по той же причине по которой в примере ниже не меняется массив.

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

@EveKS · 21.10.2016, 21:31

Bespredeliwe, предположим, что наш метод выглядит так:

C#

        private void MessageReceiverFirst(Socket r_client)
        {
 
            //Для каждого нового подключения, будет создан свой поток для приема пакетов
            Thread th = new Thread(() =>
            {
                while (isDone)
                {
 
                    //if (r_client.Connected)
                    //{
                    // Сюда будем записывать принятые байты
                    byte[] bytes = new byte[1024];
                    // Принимаем 
                    r_client.Receive(bytes);
                    if (bytes.Length != 0)
                    {
                        this.msg = ((MessageLib.Message)Deserialize(bytes));
 
                    }
                    isDone = false;
 
                    //}
                }
                Thread e = Thread.CurrentThread;
                e.Abort();
 
            });
 
            th.IsBackground = true;
            th.Start(msg);
        }

То как только тут:

C#

1 2	//if (r_client.Connected) //{

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

@Bespredeliwe · 21.10.2016, 21:36 **[ТС]**

Сообщение от EveKS

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

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

@EveKS · 21.10.2016, 21:38

Bespredeliwe, раз нету смысла в проверке, то зачем цикл с одной итерацией)?
Как метод без Thread выглядит?

@Bespredeliwe · 21.10.2016, 21:45 **[ТС]**

Сообщение от EveKS

Bespredeliwe, раз нету смысла в проверке, то зачем цикл с одной итерацией)?
Как метод без Thread выглядит?

Там вместо цикла можно использовать if... пока не суть важно. Общий смысл метода: как только подключатся новый клиент мы создаем поток и в нем сразу же получаем объект (в 1м сообщении на 1024 байта), который десиарелизируем и помещаем в специальный класс с сокетом (для соединения с клиентом) и параметрами которые были получены 1м сообщением. Без Thread метод выглядит так же просто убери лямбду

@EveKS · 21.10.2016, 22:26

Bespredeliwe,

C#

        private async Task MessageReceiverFirst(Socket r_client)
        => await Task.Run(()=>
        {
            if (isDone)
            {
                byte[] bytes = new byte[1024];
 
                r_client.Receive(bytes);
                if (bytes.Length != 0)
                {
                    this.msg = ((MessageLib.Message)Deserialize(bytes));
                }
                isDone = false;
            }
        });

Message msg.

Добавлено через 10 минут

C#

        private async Task SocketAccepter()
        => await Task.Run(async ()=>
        { 
                Socket cl;
                Client cli;
                int Cur = 0;
                while (isServerRunning)
                {
                    try
                    {
                        MyMSG += new Action<MessageLib.Message>(MyEvMeth);
                        cl = listener.Accept();
                        isDone = true;
                        //MSGEvent();
                        await MessageReceiverFirst(cl);
                        cli = new Client(cl, msg);
 
                        MyEvent1?.Invoke("\n\r" + "Client connected: ID:" + Cur + "\n\r");
                        MyEvent?.Invoke(cli);
                    }
                    catch (Exception e)
                    {
                        MyEvent1("Exeption: " + e.ToString());
                    }
                }
            });

Добавлено через 30 минут

Не по теме:

Или мне кажется, или там куча лишних действий.

@Bespredeliwe · 21.10.2016, 22:31 **[ТС]**

EveKS, Спасибо, все работает. Понял в чем была проблема... Поток не успевал отработать и записать в глобальную переменную наш объект, таким образом не дождавшись завершения потока в метод попадал null... С asnyc/await все работает!

@Bespredeliwe 7 / 7 / 3 Регистрация: 10.04.2015 Сообщений: 57
	21.10.2016, 22:31 [ТС]	11
	EveKS, Спасибо, все работает. Понял в чем была проблема... Поток не успевал отработать и записать в глобальную переменную наш объект, таким образом не дождавшись завершения потока в метод попадал null... С asnyc/await все работает! 0

Новые блоги и статьи
Книги и учебные ресурсы по C# InfoMaster 08.01.2025 Базовые учебники и руководства Одной из лучших книг для начинающих является "C# 10 и . NET 6 для начинающих" Эндрю Троелсена и Филиппа Джепикса . Книга последовательно раскрывает основные концепции. . .	Что такое NullReferenceException и как исправить? InfoMaster 08.01.2025 NullReferenceException - одно из самых распространенных исключений, с которым сталкиваются разработчики на C#. Это исключение возникает при попытке обратиться к членам объекта (методам, свойствам или. . .	Что такое Null Pointer Exception (NPE) и как это исправить? InfoMaster 08.01.2025 Null Pointer Exception (NPE) - это одно из самых распространенных исключений в Java, которое возникает при попытке использовать ссылку на объект, значение которой равно null. Это исключение относится. . .	Русский язык в консоли C++ InfoMaster 08.01.2025 При разработке программ на C++ одной из частых проблем, с которой сталкиваются русскоязычные программисты, является корректное отображение кириллицы в консольных приложениях. Эта проблема особенно. . .	Telegram бот на C# InfoMaster 08.01.2025 Разработка ботов для Telegram стала неотъемлемой частью современной экосистемы мессенджеров. C# предоставляет мощный и удобный инструментарий для создания разнообразных ботов, от простых. . .	Использование GraphQL в Go (Golang) InfoMaster 08.01.2025 Go (Golang) является одним из наиболее популярных языков программирования, используемых для создания высокопроизводительных серверных приложений. Его архитектурные особенности и встроенные. . .
Что лучше использовать при создании класса в Java: сеттеры или конструктор? Alexander-7 08.01.2025 Вопрос подробнее: На вопрос: «Когда одновременно создаются конструктор и сеттеры в классе – это нормально?» куратор уточнил: «Ваш класс может вообще не иметь сеттеров, а только конструктор и геттеры. . .	Как работать с GraphQL на TypeScript InfoMaster 08.01.2025 Введение в GraphQL и TypeScript В современной разработке веб-приложений GraphQL стал мощным инструментом для создания гибких и эффективных API. В сочетании с TypeScript, эта технология. . .	Счётчик на базе сумматоров + регистров и генератора сигналов согласования. Hrethgir 07.01.2025 Создан с целью проверки скорости асинхронной логики: ранее описанного сумматора и предополагаемых fast регистров. Регистры созданы на базе ранее описанного, предполагаемого fast триггера. То-есть. . .	Как перейти с Options API на Composition API в Vue.js BasicMan 06.01.2025 Почему переход на Composition API актуален В мире современной веб-разработки фреймворк Vue. js продолжает эволюционировать, предлагая разработчикам все более совершенные инструменты для создания. . .	Архитектура современных процессоров inter-admin 06.01.2025 Процессор (центральный процессор, ЦП) является основным вычислительным устройством компьютера, которое выполняет обработку данных и управляет работой всех остальных компонентов системы. Архитектура. . .	История создания реляционной модели баз данных, правила Кодда Programming 06.01.2025 Предпосылки создания реляционной модели В конце 1960-х годов компьютерная индустрия столкнулась с серьезными проблемами в области управления данными. Существовавшие на тот момент модели данных -. . .

@Bespredeliwe 7 / 7 / 3 Регистрация: 10.04.2015 Сообщений: 57
	21.10.2016, 21:10 [ТС]	3
	Тут естественно не весь код, msg это глобальная переменная, куда я записываю десериализырованный объект. По моему разницы с помощью какого класса я буду создавать поток вообще нету, суть в том что в отдельном нечего не десериализуется. 0

@Bespredeliwe 7 / 7 / 3 Регистрация: 10.04.2015 Сообщений: 57
	21.10.2016, 21:29 [ТС]	5
	Сообщение от OwenGlendower Bespredeliwe, переменная msg не меняется по той же причине по которой в примере ниже не меняется массив. Хорошо, если я просто запускаю поток (без параметров) и передаю ему глобальную переменную msg то тоже нечего не происходит, так же и с событиями. 0

@Bespredeliwe 7 / 7 / 3 Регистрация: 10.04.2015 Сообщений: 57
	21.10.2016, 21:36 [ТС]	7
	Сообщение от EveKS мы раскомментируем, msg будет каждую итерацию присваиваться новое значение, возможно в этом и есть задумка, выйти из цикла с нужным значением msg. Нету там никакой задумки, это обычное свойство сокета которое я закоментил так как там нету смысла в такой проверке. Просто как бы я не хотел передать значение десериализации главному потоку, оно не передается... Повторюсь, когда запускаю все в одном потоке, все работает как часы. 0

@EveKS 601 / 485 / 185 Регистрация: 19.04.2016 Сообщений: 1,885
	21.10.2016, 21:38	8
	Bespredeliwe, раз нету смысла в проверке, то зачем цикл с одной итерацией)? Как метод без Thread выглядит? 0

@Bespredeliwe 7 / 7 / 3 Регистрация: 10.04.2015 Сообщений: 57
	21.10.2016, 21:45 [ТС]	9
	Сообщение от EveKS Bespredeliwe, раз нету смысла в проверке, то зачем цикл с одной итерацией)? Как метод без Thread выглядит? Там вместо цикла можно использовать if... пока не суть важно. Общий смысл метода: как только подключатся новый клиент мы создаем поток и в нем сразу же получаем объект (в 1м сообщении на 1024 байта), который десиарелизируем и помещаем в специальный класс с сокетом (для соединения с клиентом) и параметрами которые были получены 1м сообщением. Без Thread метод выглядит так же просто убери лямбду 0

Как десериализовать в отдельном потоке ?

Решение