VPF::Пул потоков... - Форум программистов

STRELOKBMSTU

Дата 11.1.2010, 12:06 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 138
Регистрация: 11.8.2007
Где: Russia.MR.Moscow( );

Репутация: нет
Всего: нет

Нужно создать что-то типа пула потоков внутри Win-сервиса. Пользователи будут подключаться к серверу, регистрироваться на нем, будет создаваться отдельный поток, а в нем сокет для дальнейшего обмена информацией... Соответственно на сервере должен быть список пользователей с ключами и информацией о пользователе, к примеру Dictionary<GUID,UserObject>... в случае необходимости отпраки сообщения по ключу, сервис обращается к нужному потоку и отправляет сообщения на нужный сокет...

В общем так мне видится реализация того чего хочу, но не разу не писал подобного, как реализовать подобное хранение потоков и обращение к ним???

mrbrooks

Дата 11.1.2010, 12:10 (ссылка)

(нет голосов)

Загрузка ...

трололомен

Профиль
Группа: Завсегдатай
Сообщений: 4259
Регистрация: 4.10.2006
Где: Дол Гулдур

Репутация: 7
Всего: 306

STRELOKBMSTU, посмотри в сторону класса ThreadPool камрад.

Добавлено через 1 минуту и 1 секунду
подробнее

STRELOKBMSTU

Дата 11.1.2010, 12:27 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 138
Регистрация: 11.8.2007
Где: Russia.MR.Moscow( );

Репутация: нет
Всего: нет

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

STRELOKBMSTU

Дата 11.1.2010, 13:16 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 138
Регистрация: 11.8.2007
Где: Russia.MR.Moscow( );

Репутация: нет
Всего: нет

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

STRELOKBMSTU

Дата 11.1.2010, 13:36 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 138
Регистрация: 11.8.2007
Где: Russia.MR.Moscow( );

Репутация: нет
Всего: нет

Можно ли создать как-нибудь список потоков?

mrbrooks

Дата 11.1.2010, 13:53 (ссылка)

(нет голосов)

Загрузка ...

трололомен

Профиль
Группа: Завсегдатай
Сообщений: 4259
Регистрация: 4.10.2006
Где: Дол Гулдур

Репутация: 7
Всего: 306

Цитата(STRELOKBMSTU @ 11.1.2010, 13:36

)

Можно ли создать как-нибудь список потоков?

в смысле - аля массив потоков? если необходимо - то конечно можно. используй те же коллекции.

Добавлено через 4 минуты и 27 секунд
но честно говоря теряюсь в догадках чем не подходит тот же ThreadPool.QueueUserWorkItem.

STRELOKBMSTU

Дата 11.1.2010, 14:02 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 138
Регистрация: 11.8.2007
Где: Russia.MR.Moscow( );

Репутация: нет
Всего: нет

Да я все никак не могу разобраться на каком этапе создавать новый поток, у меня слушается порт, соответственно сокет создается внутри самого сервиса а не в новом потоке... а чтобы он создавался в новом потоке, надо и слушать порт в отдельном потоке. Как организовать несколько висящих в памяти сокетов с регистрацией и разрегистрацией их? Вот немного текущего кода:

Код


        private void DoService()
        {
            _isAlive = true;
            
            MemoryStream stream = null;
            byte[] buffer;
            int length = 0;

            _workStarted.Set();

                                     
                try
                {
                    while (_isAlive)
                    {

                        _socket = _listener.AcceptSocket();


                        while (_socket.Connected && (_socket.Available > 0))
                        {
                           buffer = new byte[65535];
                           length = _socket.Receive(buffer);

                           if (length > 0)
                           {
                               stream = new MemoryStream(buffer);
                               XmlSerializer serializer = new XmlSerializer(typeof(MessageObject));
                               MessageObject messageObject = (MessageObject)serializer.Deserialize(stream);

                               if (messageObject != null)
                               {
                                   switch (messageObject.MessageType)
                                   {
                                       case MessageObject.Type.InputMessage:

                                           SendUserMessages(messageObject);
                                           break;

                                       case MessageObject.Type.Register:

                                           UserRegister(messageObject);
                                           break;

                                       case MessageObject.Type.Unregister:

                                           UserUnRegister(messageObject);
                                           break;
                                   }
                               }


                           }
                           else throw new SocketException();

                           _socket.Disconnect(false);
                        }

                       // Thread.Sleep(5);
                    }

                    _workStopped.Set();


                }        
                catch (SocketException e)
                {

                }

                if (_socket != null)
                {
                    _socket.Shutdown(SocketShutdown.Both);
                    _socket.Close();
                    _socket = null;
                }

              _workStopped.Set();

            }

PashaPash

Дата 11.1.2010, 14:45 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 1233
Регистрация: 3.1.2008

Репутация: 13
Всего: 49

STRELOKBMSTU, посмотри msdn по TcpListener.BeginAcceptSocket

--------------------

Bird's-eye View?

STRELOKBMSTU

Дата 11.1.2010, 15:13 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 138
Регистрация: 11.8.2007
Где: Russia.MR.Moscow( );

Репутация: нет
Всего: нет

PashaPash, пасиб, интересная вещь, сейчас ознакомлюсь...

Это сообщение отредактировал(а) STRELOKBMSTU - 11.1.2010, 15:16

STRELOKBMSTU

Дата 11.1.2010, 15:35 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 138
Регистрация: 11.8.2007
Где: Russia.MR.Moscow( );

Репутация: нет
Всего: нет

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

mrbrooks

Дата 11.1.2010, 16:21 (ссылка)

(нет голосов)

Загрузка ...

трололомен

Профиль
Группа: Завсегдатай
Сообщений: 4259
Регистрация: 4.10.2006
Где: Дол Гулдур

Репутация: 7
Всего: 306

да это обыкновенная асинхронная операция ожидающая входящее подключение. вообще кстати тов. Joseph Albahari советует использовать асинхронные методы в крайних случаях - заменив их использованием асинхронными делегатами. но это к слову.

я так понимаю работа идет с сервером. вообще классическая модель для сервера это использовать потоки + семафоры.

tol05

Дата 11.1.2010, 17:18 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Участник Клуба
Сообщений: 1632
Регистрация: 21.12.2006
Где: Харьков

Репутация: 63
Всего: 170

Цитата(PashaPash @ 11.1.2010, 13:45

)

STRELOKBMSTU, посмотри msdn по TcpListener.BeginAcceptSocket

Так называемая асинхронная модель программирования (Asynchronous Programming Model)

В двух словах - есть рабочие потоки (Thread-ы, как мы привыкли их понимать) и потоки ввода-вывода (они еще называются потоками завершения)
В стримах когда мы используем методы BeginХХХХ - мы активно используем потоки ввода\вывода, перекладывая тем самым часть нагрузки с процессора на драйвер устройства

Об этом хорошо написал Рихтер в своей книге "CLR via C#". В главе о асинхронных операциях. Приведу две цитаты

Цитата

В пуле различают два типа потоков: рабочие потоки и потоки ввода-вывода.
Первые используются, когда приложение запрашивает пул выполнить асинхронную вычислительную операцию (которая может включать инициацию операции ввода-вывода). А потоки ввода-вывода служат для уведомления кода о завершении асинхронной операции ввода-вывода. Это значит, что для выполнения запросов, например обращения к файлу, сетевому серверу, базе данных, Web-службе или
аппаратному устройству, используется модель АРМ (Asynchronous Programming Model).

О FileStream

Цитата

Вызов метода BeginRead дает Windows команду прочесть байты из файла в байтовый массив. Поскольку это операция ввода-вывода, метод BeginRead ставит этот запрос в очередь драйвера соответствующего аппаратного устройства. Вся работа ложится на аппаратное устройство, и потокам больше ничего не нужно делать — даже ждать результатов операции. Это очень эффективно!

Я могу ошибаться, но по-моему TcpListener.BeginAcceptSocket использует потоки ввода-вывода. Но даже если это не так.. то все равно, я бы любом случае использовал бы именно TcpListener.BeginAcceptSocket, а не создавал бы собственный (рабочий) поток.

--------------------

На хорошей работе и сны хорошие снятся.

PashaPash

Дата 11.1.2010, 17:44 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 1233
Регистрация: 3.1.2008

Репутация: 13
Всего: 49

Цитата(STRELOKBMSTU @ 11.1.2010, 15:35

)

BeginAcceptSocket возвращает управление сразу после вызова. После подключения клиента вызывается Сallback, в отдельном потоке из пула. Т.е. каждому клиенту - свой поток. Все получается.

Цитата(mrbrooks @ 11.1.2010, 16:21

)

вообще кстати тов. Joseph Albahari советует использовать асинхронные методы в крайних случаях - заменив их использованием асинхронными делегатами.

И чем он это мотивирует? smile

Внутри Begin/EndXXX - те же асинхронные делегаты. Никаких плюсов от ручного оборачивания BeginAcceptSocket в делегат, и вызова BeginInvoke быть не должно.

--------------------

Bird's-eye View?

STRELOKBMSTU

Дата 11.1.2010, 17:50 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 138
Регистрация: 11.8.2007
Где: Russia.MR.Moscow( );

Репутация: нет
Всего: нет

Т.е. если одновременно придет много запросов от клиентов, они все встанут в очередь на CallBack или будут выполняться параллельно?

Да, и на BeginAcceptSocket цикл не зависает и не ждет события прихода сокета, а выполняется бесконечно, процесс конечно не сильно нагружается, но что-то не нравится этот бесконечный цикл:

Код


                    while (_isAlive)
                    {

                        _listener.BeginAcceptSocket(new AsyncCallback(DoAcceptSocketCallback), _listener);

                        clientConnected.WaitOne();

                       // Thread.Sleep(5);
                    }

Код


        public void DoAcceptSocketCallback(IAsyncResult ar)
        {
            MemoryStream stream = null;
            byte[] buffer;
            int length = 0;

            TcpListener listener = (TcpListener)ar.AsyncState;

            Socket clientSocket = listener.EndAcceptSocket(ar);

            if (clientSocket.Connected && (clientSocket.Available > 0))
            {
                buffer = new byte[65535];
                length = clientSocket.Receive(buffer);

                if (length > 0)
                {
                    stream = new MemoryStream(buffer);
                    XmlSerializer serializer = new XmlSerializer(typeof(MessageObject));
                    MessageObject messageObject = (MessageObject)serializer.Deserialize(stream);

                    if (messageObject != null)
                    {
                        switch (messageObject.MessageType)
                        {
                            case MessageObject.Type.InputMessage:

                                AddUserMessage(messageObject);
                                break;

                            case MessageObject.Type.Register:

                                UserRegister(messageObject);
                                break;

                            case MessageObject.Type.Unregister:

                                UserUnRegister(messageObject);
                                break;
                        }
                    }


                }
                else throw new SocketException();

            }

            
            clientConnected.Set();
        }

Это сообщение отредактировал(а) STRELOKBMSTU - 11.1.2010, 18:31

PashaPash

Дата 11.1.2010, 19:14 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 1233
Регистрация: 3.1.2008

Репутация: 13
Всего: 49

Цитата(STRELOKBMSTU @ 11.1.2010, 17:50

)

Т.е. если одновременно придет много запросов от клиентов, они все встанут в очередь на CallBack или будут выполняться параллельно?

Параллельно, на потоках из пула.

Цитата(STRELOKBMSTU @ 11.1.2010, 17:50

)

Да, и на BeginAcceptSocket цикл не зависает и не ждет события прихода сокета, а выполняется бесконечно, процесс конечно не сильно нагружается, но что-то не нравится этот бесконечный цикл:

Используй семафор для ограничения на количество одновременно висящих BeginAcceptSocket. Или используй синхронный AcceptSocket, но вынеси обработку в отдельный поток. У того же Joseph Albahari есть пример: http://www.albahari.com/nutshell/ch20.aspx

--------------------

Bird's-eye View?

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Общие вопросы по .NET и C# \| Следующая тема »