2

У меня есть код, который по сокету принимает от клиентов пакеты обрабатывает их и отсылает ответ. Из основной нити (при подключении клиента) создается дочерняя (назову ее T1). Дочерняя нить создается 2 раза (2 клиента подключаются), то есть так же создается нить Т2.

clientListenThread = new Thread(RecieveClientPackage);
clientListenThread.Start();

Каждая из этих нитей создает еще дочернюю нить (Т1.1 и Т2.1)

public void RecieveClientPackage()
    {
        while (true)
        {
            byte[] buf = new byte[clientSocket.SendBufferSize];
            int receivedBytes = clientSocket.Receive(buf); // Получаем от клиента сериализованный пакет
            if (receivedBytes != 0)
            {
                package = new Package(buf); // В конструкторе пакет десериализуется/
                Thread dataProcessingThread = new Thread(DataProcessing);
                dataProcessingThread.Start();

            }
        }
    }

Мне нужно, чтобы код в методе DataProcessing выполнялся каждым потоком отдельно, поэтому я заворачиваю его в lock

void DataProcessing()
    {
        lock (locker)
        {
            Console.WriteLine("Функцию захватил поток {0}", Thread.CurrentThread.ManagedThreadId);
            new DataProcessor(this);
            Console.WriteLine("Поток {0} освободил функцию", Thread.CurrentThread.ManagedThreadId);
        }            
    }

В консоль для проверки вывожу какой поток зашел и вышел из lock. Вижу следующие:

введите сюда описание изображения

Объясните мне пожалуйста, что я делаю не так. Спасибо!

2
  • locker - what is it?
    – user176262
    6 апр 2021 в 14:49
  • private object locker = new object(); Поле класса
    – FelixTI
    6 апр 2021 в 14:55

1 ответ 1

5

Вы используете разные объекты в lock(...), а надо - один и тот же.

object static locker = new object();
       ^^^^^^
void DataProcessing() 
{
  ...
1
  • Классика, которую нужно знать.
    – A K
    6 апр 2021 в 20:28

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.