28 / 29 / 5
Регистрация: 17.10.2009
Сообщений: 739
|
|
1 | |
Многопоточный чат с использованием пула потоков23.03.2014, 19:10. Показов 4674. Ответов 55
Метки нет (Все метки)
есть вопрос как реализовать можно чат с использованием пулов потоков.Без пула все понятно на каждого клиента создается поток и потоки висят и делают свои дела,в пуле я читал создается n-ое количество потоков и они обрабатывают свои задачи,тоесть если у меня 4 потока в пуле то только 4 пользователя смогут работать и все,а остальные будут в очереди или я не правильно что то понимаю
Добавлено через 43 минуты неужели никто не использовал пул потоков?
0
|
23.03.2014, 19:10 | |
Ответы с готовыми решениями:
55
Вызов конструктора и деструктора с использованием пула Помощь с использованием потоков Обработка матриц с использованием файлов и потоков Максимальный элемент матрицы с использованием потоков |
654 / 575 / 164
Регистрация: 13.12.2012
Сообщений: 2,124
|
|
25.03.2014, 14:00 | 21 |
1
|
70 / 47 / 5
Регистрация: 10.01.2017
Сообщений: 1,849
|
|
05.11.2022, 21:38 | 22 |
Интересует момент "если свободного потока нету, поставили клиента в очередь" - как он по Вашему реализуется ?
Предположим созданы 10 потоков, усыплены, потом предположим подключились 10 клиентов и просто условно 5 минут занимают каждый по своему соединению, то есть свободных потоков нет. И как это реализуется ? Вам же все равно нужно вызвать фикцию прослушивать "accept", а для нее создать сокет, но ведь все 10 сокетов уже созданы и заняты, а значит 11 сокет создавать нельзя. Что именно Вы советовали поместить в очередь ?
0
|
18840 / 9839 / 2408
Регистрация: 30.01.2014
Сообщений: 17,280
|
|
05.11.2022, 21:47 | 23 |
Не по теме: Optimus11, у человека последняя активность в 2017. Он вам не ответит. Тем не менее я ответить могу, потому что это известный паттерн и не он его придумал. Чего эт нельзя? Сокет - это ведь не поток. Потоков, допустим, 10, а сокетов может быть сколько нужно. Только часть из них будут в очереди после подключения.
1
|
70 / 47 / 5
Регистрация: 10.01.2017
Сообщений: 1,849
|
|
05.11.2022, 22:50 | 24 |
А если постоянно выделять память под сокеты, а потом эту память освобождать - фрагментации памяти рано или поздно не случится ?
0
|
18840 / 9839 / 2408
Регистрация: 30.01.2014
Сообщений: 17,280
|
|
05.11.2022, 23:06 | 25 |
Зачем выделять память под сокеты? Кроме места в очереди, память которой может быть в пуле, никакой памяти для этого не нужно.
0
|
70 / 47 / 5
Регистрация: 10.01.2017
Сообщений: 1,849
|
|
06.11.2022, 12:46 | 26 |
После закрытия сокета, он уже не валидный и использовать его для accept-прослушивателя уже не получается, а значит нужно создать новый сокет, а значит нужно выделить под него память и поместить указатель на него в очередь.
Или я просто не понимаю тогда, как по другому.
0
|
18840 / 9839 / 2408
Регистрация: 30.01.2014
Сообщений: 17,280
|
|
06.11.2022, 13:06 | 27 |
В какой момент предполагается его закрывать?
Если это новый клиент, то под него будет новый сокет. Естественно он будет открыт. Если этой старый клиент в очереди, то сокет под него не закрыт. Клиент просто ждет, когда его обслуживание на сервере начнется. Это активное ожидание. Итого не понятно в чем вы видите проблему.
0
|
70 / 47 / 5
Регистрация: 10.01.2017
Сообщений: 1,849
|
|
06.11.2022, 13:15 | 28 |
Когда или Сервер отдал все что нужно или когда Клиент закрыл соединение.
Я имел ввиду: -Я создаю-выделяю память под сокет и ставлю его на прослушивание. -Приходит Входящие "сообщение" от Клиента - я читаю и отвечаю - после чего закрываю сокет и освобождаю ранее выделенную под него память. -Создаю-выделяю новый сокет и ставлю его на прослушивание ... -Приходит Входящие "сообщение" -итд итд Вот эти непрерывные выделения памяти и освобождение под непрерывно создающиеся и уничтожающиеся сокеты - к фрагментации памяти в итоге не приведут ?
0
|
18840 / 9839 / 2408
Регистрация: 30.01.2014
Сообщений: 17,280
|
|
06.11.2022, 13:32 | 29 |
Если память будет в пуле, то нет. Размеры объектов всегда одинаковые. Я же написал об этом выше.
Сокет - это объект ядра. В общем случае ничего кроме этого числа под него на стороне пользователя выделять не надо. На стороне пользователя это просто число\структура. Возможно вы имеется в виду объект-обертку над сокетом? В целом схема разрывать соединение после каждого законченного цикла обмена применяется, но совсем не обязательна. В условном "чате" так она скорее вредна. Можно ведь сохранять соединение активным и только переводить клиента в режим ожидания, если от него нет сообщений. Отключить его можно, например, по прошествии определенного времени, как длительно неактивного. С другой стороны в условном "чате" какая-то особенная многопоточность тоже не нужна. Как вариант можно сделать пулы клиентов на N штук в каждом, каждый пул - это отдельный поток. Пихать одного клиента чата в отдельный поток, даже временно, это расточительно. Нет там такой нагрузки.
0
|
70 / 47 / 5
Регистрация: 10.01.2017
Сообщений: 1,849
|
||||||
06.11.2022, 13:40 | 30 | |||||
Да, но это касается чистых сокетов видимо.
Да я имел ввиду: boost::asio::ip::tcp::socket - который еще и требует указать параметры при создании - поэтому его в пул - в вектор или список поместить и не удается, а удается создать только через new и сохранить указатель:
Может быть ранее закрытий сокет можно переиспользовать для нового соединения ? Можно ли его как то "сбросить" в первоначальное состояние, как будто бы его только что создали ?
0
|
18840 / 9839 / 2408
Регистрация: 30.01.2014
Сообщений: 17,280
|
|
06.11.2022, 13:52 | 31 |
Не вижу причин почему его нельзя поместить в пул.
Конечно можно. Но не в вектор, естественно, а в правильно написанный пул памяти. В том же бусте есть аллокаторы на пулах. Нет, это и всяких оберток тоже касается. Добавлено через 2 минуты Безотносительно этой задачи, в целом, всегда лучше работать с новым объектом, чем переиспользовать старый. Однако новый объект может быть в старой памяти, но это уже уровнем ниже и на описываемой логике на сказывается.
0
|
70 / 47 / 5
Регистрация: 10.01.2017
Сообщений: 1,849
|
||||||
06.11.2022, 13:55 | 32 | |||||
А чем принципиально правильно написанный пул памяти - будет отличатся от вектора ?
Почему в вектор поместить объект бустовского сокета нельзя, а в специально написанный можно ?
0
|
18840 / 9839 / 2408
Регистрация: 30.01.2014
Сообщений: 17,280
|
|
06.11.2022, 14:00 | 33 |
0
|
70 / 47 / 5
Регистрация: 10.01.2017
Сообщений: 1,849
|
|
06.11.2022, 14:06 | 34 |
А Вы можете подсказать, что мне нужно почитать, чтобы понять, что же это за пул-памяти в который можно будет "создавать" бустовский-сокет ? На данный момент, что то совершенно не соображу о чем речь.
0
|
18840 / 9839 / 2408
Регистрация: 30.01.2014
Сообщений: 17,280
|
||||||
06.11.2022, 14:23 | 35 | |||||
http://dmitrysoshnikov.com/com... allocator/
https://www.boost.org/doc/libs... index.html https://en.wikipedia.org/wiki/Free_list Еще есть вот такая вариация на тему:
1
|
70 / 47 / 5
Регистрация: 10.01.2017
Сообщений: 1,849
|
||||||
06.11.2022, 15:24 | 36 | |||||
Спасибо, однако таки не понятно, каким образом "запихнуть" бустовский сокет в этот пул памяти.
Если бустовский сокет можно создать только таким образом:
0
|
2832 / 2337 / 707
Регистрация: 29.06.2020
Сообщений: 8,658
|
|
06.11.2022, 15:35 | 37 |
0
|
70 / 47 / 5
Регистрация: 10.01.2017
Сообщений: 1,849
|
||||||
06.11.2022, 15:42 | 38 | |||||
Ну так создайте таким образом бустовский сокет, чтобы он создался в выделенном пуле памяти, а не абы где.
0
|
2832 / 2337 / 707
Регистрация: 29.06.2020
Сообщений: 8,658
|
|
06.11.2022, 16:01 | 39 |
Я такие объекты еще на паскале в обычный массив ложил.
У вас проблема не в этом.
0
|
70 / 47 / 5
Регистрация: 10.01.2017
Сообщений: 1,849
|
|
06.11.2022, 16:08 | 40 |
0
|
06.11.2022, 16:08 | |
06.11.2022, 16:08 | |
Помогаю со студенческими работами здесь
40
Поиск в бинарном файле с использованием файловых потоков Сервер с использованием пула потоков для параллельной обработки запросов клиентов Синхронизация пула потоков Ожидание завершения пула потоков Искать еще темы с ответами Или воспользуйтесь поиском по форуму: |