#include <iostream>

#include <thread>

#include <mutex>

#include <condition_variable>

#include <queue>

#include <string>

#include <chrono>

 

std::mutex mtx; // мьютекс для синхронизации доступа к базе данных

std::condition_variable cv; // условная переменная для сигнализации о доступности новых данных в базе

std::queue<std::string> data; // очередь для хранения данных из базы

bool finished = false; // флаг для остановки потока обработки данных

 

// функция для обработки базы данных в отдельном потоке

void database_thread() {

  while (true) {

    std::unique_lock<std::mutex> lock(mtx);

    cv.wait(lock, [](){ return !data.empty() || finished; }); // ожидание доступности новых данных или завершения работы

    if (finished && data.empty()) {

      return;

    }

    std::string item = data.front(); // получение новых данных из очереди

    data.pop();

    lock.unlock();

 

    // обработка данных из базы данных

    std::cout << "Processing item: " << item << std::endl;

    std::this_thread::sleep_for(std::chrono::milliseconds(500));

  }

}

 

int main() {

  // запуск потока для обработки базы данных

  std::thread t(database_thread);

  

  // симуляция добавления новых данных в базу

  for (int i = 0; i < 10; i++) {

    std::string item = "Data item " + std::to_string(i);

    std::lock_guard<std::mutex> lock(mtx);

    data.push(item);

    cv.notify_one(); // оповещение потока о доступности новых данных

  }

 

  // ожидание завершения работы потока

  finished = true;

  cv.notify_one();

  t.join();

 

  return 0;

}