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

@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

@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

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

Решение