Мини-пул потоков на std::jthread

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

class ThreadPool {
    std::queue<std::function<void()>> jobs;  // очередь заданий
    std::mutex              m;
    std::condition_variable cv;
    bool                    stop = false;
    std::vector<std::jthread> workers;       // jthread = RAII-join

Храним очередь задач, мьютекс, условную переменную и вектор рабочих потоков. Флаг stop сигнализирует о завершении.

public:
    ThreadPool(size_t n = std::thread::hardware_concurrency()) {
        for (size_t i = 0; i < n; ++i)
            workers.emplace_back([this](std::stop_token st) {
                while (!st.stop_requested()) {
                    std::function<void()> job;
                    {   std::unique_lock lk(m);
                        cv.wait(lk, [this]{ return stop || !jobs.empty(); });
                        if (stop && jobs.empty()) return;
                        job = std::move(jobs.front()); jobs.pop();
                    }
                    job();                   // выполняем задачу
                }
            });
    }

Конструктор порождает n потоков. Каждый рабочий ждёт, пока в очереди появится задача, — или пока пулу не придёт сигнал остановиться.

    template<typename F>
    void enqueue(F&& f) {
        { std::lock_guard lk(m); jobs.emplace(std::forward<F>(f)); }
        cv.notify_one();                     // будим один поток
    }

enqueue кладёт новую лямбду в очередь и будит спящего воркера.

    ~ThreadPool() {
        { std::lock_guard lk(m); stop = true; }
        cv.notify_all();                     // будим всех для выхода
    }
};

Деструктор ставит флаг stop, будит все потоки, а std::jthread автоматически дожидается их завершения.

int main() {
    ThreadPool pool(4);                      // 4 рабочих потока
    for (int i = 0; i < 8; ++i)
        pool.enqueue([i]{ std::printf("job %d\n", i); });
}   // ← при выходе pool завершит все задачи

🔥 Чистый стандарт C++20 — ни Boost, ни сторонних либ!

📣 C++ Ready | #практика

📂 Напоминалка по HTTP vs HTTPS!

Например, HTTP передаёт данные в открытом виде, без шифрования. HTTPS работает поверх TLS и защищает соединение: выполняется проверка сертификата, обмен ключами и дальнейшая передача данных в зашифрованном виде.

На картинке — ключевые этапы установления соединения.

Сохрани, чтобы не забыть!

📣 C++ Ready | #ресурс

☕️ Red Blob Games — полезный сайт для визуального понимания алгоритмов!

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

📌 Оставляю ссылочку: redblobgames.com

📣 C++ Ready | #ресурс

👨👨👨👨👨👨👨👨👨👨

Каналы с IT мероприятиями

Подписывайся,
чтобы не пропустить 🤘

1. IT мероприятия для стажеров и студентов
2. IT мероприятия по РФ
3. IT мероприятия и хакатоны
4. Бесплатные IT мероприятия
5. IT мероприятия онлайн
6. IT мероприятия Москва
7. IT мероприятия Санкт-Петербург

Почему std::shared_ptr иногда тормозит даже без потоков?

На вид это просто умный указатель. Кажется, что раз всё в одном потоке — накладных расходов почти нет.

Но у shared_ptr есть счётчик ссылок в control block. Когда ты передаёшь shared_ptr по значению, на входе и выходе функции делается refcount++/refcount-- (обычно атомарно). В горячем коде это превращается в лишнюю работу, хотя логически ты “просто передал указатель”.

Из-за этого можно получить просадку там, где её не ждёшь: циклы, коллбеки, мелкие функции.

Если владение не шарится — лучше unique_ptr или значение. Если шаринг нужен — просто не копируй shared_ptr без причины.

void log(std::shared_ptr<Foo> p); // копия -> refcount++/--

void hot(const std::shared_ptr<Foo>& p) {
    for (int i = 0; i < 1'000'000; ++i)
        log(p);                   // лучше: log(const std::shared_ptr<Foo>&)
}

🔥 В hot path не передавай shared_ptr по значению — используй const std::shared_ptr<T>& (или unique_ptr, если шаринга нет).

📣 C++ Ready | #совет