Многопоточный чат с использованием пула потоков

@sergeu90 · Регистрация: 17.10.2009

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

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

Добавлено через 43 минуты
неужели никто не использовал пул потоков?

@DrOffset · 06.11.2022, 16:22

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

Спасибо, однако таки не понятно, каким образом "запихнуть" бустовский сокет в этот пул памяти.

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
inline pool_allocator<boost::asio::ip::tcp::socket> alloc;
 
template <typename ...Args>
boost::asio::ip::tcp::socket* new_socket(Args && ...args) {
    using boost::asio::ip::tcp::socket;
 
    void* mem = alloc.allocate(sizeof(socket));
    return ::new(mem) socket(std::forward<Args>(args)...);
}
 
void delete_socket(boost::asio::ip::tcp::socket* sock) {
    using boost::asio::ip::tcp::socket;
    sock->~socket();
    alloc.deallocate(sock);
}

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

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

Укажите пожалуйста на проблему.

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

Так что я предостерегаю от превратного понимания моих советов в этой теме. Они даны лишь для расширения, вашего и всех заинтересованных, кругозора, а не как руководство к действию. Так следует относиться вообще ко всем моим ответам на этом форуме. А то, я последняя время стал замечать, что не всем это очевидно.

@Optimus11 · 06.11.2022, 17:34

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

Я такие объекты еще на паскале в обычный массив ложил.
У вас проблема не в этом.

А Вы на С или С++ - положите

@SmallEvil · 06.11.2022, 18:06

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

А Вы на С или С++ - положите

Да хоть свой контейнер напишу для таких объектов.
DrOffset, уже привел вам пример и пула и размещающий new
Что вам еще нужно, вы же не слушаете

@Optimus11 · 06.11.2022, 19:28

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

Да хоть свой контейнер напишу для таких объектов.
DrOffset, уже привел вам пример и пула и размещающий new
Что вам еще нужно, вы же не слушаете

Я ни в коем случае не против того, что привел DrOffset.
Но Вы так на С/C++ и не положили

@SmallEvil · 06.11.2022, 19:40

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

Но Вы так на С/C++ и не положили

Потому что я ленивая жопа, хочу ложу, хочу не ложу.
Или вы думаете меня на "слабо" взять ?

Добавлено через 44 секунды
Optimus11, вся суть в том, что это вам ничем не поможет.
Ровно так же, как и примеры от DrOffset .

Добавлено через 9 минут
Я в душе не чаю что там у вас за пулы, чат и тиктоки.
Я вижу что ваша проблема в том, что вы не умеете работать с объектами классов с ограниченным набором специальных членов. Которые накладывают ограничения на их использование.
То есть, без конструктора по умолчанию, с запрещенным копированием, перемещением объектов.

А вы тут рассказываете всем про фрагментацию памяти.
Берем "книжку для чайников", и учимся работать с такими объектами.

@Optimus11 · 06.11.2022, 20:40

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

Я вижу что ваша проблема в том, что вы не умеете работать с объектами классов с ограниченным набором специальных членов. Которые накладывают ограничения на их использование.
То есть, без конструктора по умолчанию, с запрещенным копированием, перемещением объектов.

Именно так.

Вообще не пойму, как с ними работать.

@DrOffset · 06.11.2022, 21:16

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

my_vec[0] = boost::asio::ip::tcp::socket(io_context) ; //Так нельзя, так как буст сокет не поддерживает конструктор копирования

Вообще говоря так можно, т.к. у класса есть конструктор перемещения и оператор перемещения. Если у вас не работает это, то вероятно у вас старая версия буста, либо вы используете С++03.

@Optimus11 · 06.11.2022, 21:49

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

Вообще говоря так можно, т.к. у класса есть конструктор перемещения и оператор перемещения. Если у вас не работает это, то вероятно у вас старая версия буста, либо вы используете С++03.

Я использую с++17. И Visual Studio 2022 - так и пишет, что отсутствует конструктор копирования.

Добавлено через 13 минут
Версия буста последняя - позавчера скаченная.

@DrOffset · 06.11.2022, 22:43

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

Я использую с++17. И Visual Studio 2022 - так и пишет, что отсутствует конструктор копирования.

Вот код. Он работает.

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
#include <boost/asio/io_service.hpp>
#include <boost/asio/ip/tcp.hpp>
#include <vector>
 
int main()
{
    using boost::asio::ip::tcp;
    
    boost::asio::io_service io_service;
    
    std::vector<tcp::socket> sockets;
    sockets.emplace_back(io_service, tcp::v4());
    
    sockets[0] = tcp::socket(io_service); // работает
}

Пруф 1: https://rextester.com/GNH70776
Пруф 2: https://www.boost.org/doc/libs... ocket.html
Пруф 3: https://www.boost.org/doc/libs... r_eq_.html

Напомню вашу цитату:

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

C++
1
my_vec[0] = boost::asio::ip::tcp::socket(io_context); //Так нельзя, так как буст сокет не поддерживает конструктор копирования

Да, именно этот код будет работать. Если у вас не работает, и при этом у вас С++17 и последняя версия буста, то у вас другой код. Другой. Внимательно смотрите и проверяйте.

@Optimus11 · 06.11.2022, 22:57

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

Вот код. Он работает.

Да, именно этот код будет работать. Если у вас не работает, и при этом у вас С++17 и последняя версия буста, то у вас другой код. Другой. Внимательно смотрите и проверяйте.

Вот скриншот студии:

Многопоточный чат с использованием пула потоков

@DrOffset · 06.11.2022, 22:59

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

Вот скриншот студии:

И? Это другая ошибка. Ошибка про конструктор по умолчанию (из-за resize), а не про конструктор копирования.

@Optimus11 · 06.11.2022, 23:10

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

И? Это другая ошибка. Ошибка про конструктор по умолчанию (из-за resize), а не про конструктор копирования.

Я уже совсем запутался. Да, если сделать push_back, а потом на это место заменить boost::socket - работает.
Если resize не работает, то теперь я не понимаю, как собственно работает push_back - внутри. Думал понимаю, теперь понял, что не понимаю.

@DrOffset · 06.11.2022, 23:21

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

как собственно работает push_back - внутри.

Если памяти хватает, то создает в ней новый объект.
Если памяти не хватает, то увеличивает ее, выделяя новый непрерывный кусок, копирует или перемещает туда существующие объекты (копирующее или перемещающее конструирование новых объектов) из старой памяти и создает еще один новый объект в свободном месте. Объекты в старой памяти уничтожаются, затем старая память освобождается.

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

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

resize не работает

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

@Optimus11 · 06.11.2022, 23:39

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

Если памяти хватает, то создает в ней новый объект.
Если памяти не хватает, то увеличивает ее, выделяя новый непрерывный кусок, копирует или перемещает туда существующие объекты (копирующее или перемещающее конструирование новых объектов) из старой памяти и создает еще один новый объект в свободном месте. Объекты в старой памяти уничтожаются, затем старая память освобождается.

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

Но ведь push_back, когда памяти под новый элемент не хватает - вероятнее всего делает resize/realloc - и это, как то работает.

@DrOffset · 07.11.2022, 00:07

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

Но ведь push_back, когда памяти под новый элемент не хватает - вероятнее всего делает resize/realloc - и это, как то работает.

Я написал что он делает. Почему нужно повторять?
Он выделяет новый непрерывный кусок, копирующим или перемещающим конструированием создает в нем столько объектов, сколько было в старом куске, затем создает еще один объект, который был запрошен через push_back. В старом куске памяти объекты уничтожаются, а сам кусок освобождается.

Добавлено через 3 минуты
resize - это точно такая же высокоуровневая операция, как и push_back.
Внутри resize использует тот же описанный выше механизм, только в дополнительно выделенной памяти объекты создаются конструктором по умолчанию. Уже существующие объекты, при увеличении размера, точно также копирующим\перемещающим конструированием воссоздаются в новой памяти.

Добавлено через 9 минут
Optimus11, удивительно, но когда я писал этот ответ, меня не покидало ощущение, что все это мы уже проходили. И точно, вот тема 2021 года, где это уже разъяснялось:
Нарушении прав доступа к указателю на структуру

@Kuzia domovenok · 07.11.2022, 01:22

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

Но ведь push_back, когда памяти под новый элемент не хватает - вероятнее всего делает resize/realloc - и это, как то работает.

делает reserve, а не resize.

Новые блоги и статьи Все статьи Все блоги /
сукцессия 14. Обновленная схема модели anaschu 28.06.2026 ГЛОБАЛЬНАЯ ОПИСАТЕЛЬНАЯ СПЕЦИФИКАЦИЯ ЭКОСИСТЕМНОЙ МОДЕЛИ «SOIL CHEMISTRY & MYCORRHIZA 2. 0» https:/ / ibb. co/ NnkGpfMd Представленная интегрированная схема описывает непрерывную нелинейную. . .	сукцессия 13. Питон модель трехзонного мицелия, пока что в основном арбускулярного anaschu 28.06.2026 ## Разработка агентной модели микоризной сукцессии: от выявления артефактов к созданию комплексной системы ### Аннотация Представлено исследование по разработке агентной модели микоризной. . .	сукцессия 12. краткий список проверок модели перед запуском. anaschu 28.06.2026 Скрытые отказы в моделях систем динамики (SD-models) экологических систем: два случая из практики Контекст Разбирался прототип модели систем динамики (SD-модели) микоризной сукцессии: пять. . .	Сукцессия 11. Проверка орудий перед войной: разработка через тестирование anaschu 28.06.2026 Как не дать модели соврать самой себе: проверки для симуляции микоризной сукцессии Введение Когда вы строите математическую модель живой системы — грибов, растений, почвы — главная опасность. . .
10 сукцессия. Питон код войны грибов и растений anaschu 27.06.2026 import numpy as np class PlantAgent: def __init__(self, name, strategy, initial_biomass): self. name = name self. strategy = strategy # "greedy" (широколиственные) или. . .	сукцессия 9. Математика подлости: как растения предали грибных друзей anaschu 27.06.2026 Статья 2. Глобальная фосфорная война: эволюционно-экономические механизмы распределения биомов Земли Введение: Экологический рынок как игра с нулевой суммой Традиционная экология долгое время. . .	сукцессия 8. Как я спорил с ИИ, которые - агенты растений и ненавистники грибов! anaschu 27.06.2026 Статья 1. Хроники грибного восстания: как Сократов диалог разрушил академические догмы ИИ Введение: Синдром «цифрового учебника» Современные большие языковые модели (LLM) обладают колоссальным. . .	Главный вопрос моделирования сукцессии anaschu 27.06.2026 главный вопрос. Если эктомикориза лучше добывает недоступный фосфор. И ее масса максимальна из всех. А широколиственный лес тоже имеет самую крутую биомассу. То почему не возникло их симбиоза? Это. . .

@sergeu90 28 / 29 / 5 Регистрация: 17.10.2009 Сообщений: 739

	Многопоточный чат с использованием пула потоков 23.03.2014, 19:10. Показов 6039. Ответов 55 Метки нет (Все метки) есть вопрос как реализовать можно чат с использованием пулов потоков.Без пула все понятно на каждого клиента создается поток и потоки висят и делают свои дела,в пуле я читал создается n-ое количество потоков и они обрабатывают свои задачи,тоесть если у меня 4 потока в пуле то только 4 пользователя смогут работать и все,а остальные будут в очереди или я не правильно что то понимаю Добавлено через 43 минуты неужели никто не использовал пул потоков? 0