C++ Academy

🧠 C++ Задача для продвинутых: безопасный счётчик с автоматическим сбросом

Условие:
Реализуйте потокобезопасный счётчик, который:
1. Увеличивается при вызове increment()
2. Возвращает текущее значение при get()
3. Автоматически сбрасывается в 0 через N миллисекунд после последнего increment()
4. Не сбрасывается, если за это время пришёл новый increment()

🔧 Условия:
- Нельзя использовать сторонние библиотеки (только стандарт C++17+)
- Нельзя вручную управлять потоками (используйте std::thread, std::mutex, `std::condition_variable`)
- Нужно обеспечить корректный RAII (автоматическое завершение потоков при разрушении объекта)

🔍 Пример:


SafeCounter counter(1000); // сброс через 1000 мс
counter.increment();       // value = 1
std::this_thread::sleep_for(500ms);
counter.increment();       // value = 2, таймер сброса перезапускается
std::this_thread::sleep_for(1500ms);
std::cout << counter.get(); // value = 0

💡 Подсказка:
Нужно реализовать "отложенный сброс", который перезапускается при каждом increment(). Используйте фоновый поток и condition_variable.

✅ Ожидаемое решение (упрощённый скелет):


#include <iostream>
#include <thread>
#include <atomic>
#include <mutex>
#include <condition_variable>
#include <chrono>

class SafeCounter {
public:
    SafeCounter(int timeout_ms) : timeout(timeout_ms), value(0), stop(false) {
        worker = std::thread([this] { this->watch(); });
    }

    ~SafeCounter() {
        {
            std::lock_guard<std::mutex> lock(mtx);
            stop = true;
        }
        cv.notify_all();
        worker.join();
    }

    void increment() {
        {
            std::lock_guard<std::mutex> lock(mtx);
            ++value;
            last_action = std::chrono::steady_clock::now();
        }
        cv.notify_all();
    }

    int get() const {
        return value.load();
    }

private:
    void watch() {
        std::unique_lock<std::mutex> lock(mtx);
        while (!stop) {
            cv.wait_for(lock, timeout, [this] {
                return stop || std::chrono::steady_clock::now() - last_action >= timeout;
            });

            if (stop) break;

            if (std::chrono::steady_clock::now() - last_action >= timeout) {
                value = 0;
            }
        }
    }

    std::chrono::milliseconds timeout;
    std::chrono::steady_clock::time_point last_action = std::chrono::steady_clock::now();
    std::atomic<int> value;
    std::mutex mtx;
    std::condition_variable cv;
    std::thread worker;
    bool stop;
};

🎯 Отличная задача, чтобы потренировать:

понимание RAII

работу с condition_variable

атомарные переменные

и правильную остановку фоновых потоков

Можешь доработать под конкретные кейсы — например, логирование событий сброса или работу с несколькими счётчиками.

❤17👍5🔥2

3.15K views10:02