Потоки и очередь заданий - C++ - Ответ 17338159

#include <iostream>
#include <thread>
#include <memory>
#include <mutex>
#include <vector>
#include <string>
#include <sstream>
#include <iomanip>
#include <ctime>
 
constexpr int NumberOfThreads = 2;
 
class Request
{
    public:
    size_t index{};
};
 
std::mutex list_mutex;
std::vector<std::unique_ptr<Request>> list;
 
// возвращает nullptr если нужно завершить процесс
std::unique_ptr<Request> GetRequest() noexcept
{
    std::unique_ptr<Request> ptr;
    
    std::scoped_lock(list_mutex);
    if(list.size())
    {
        ptr=std::move(list.front());
        list.erase(list.begin());
    }
    
    return ptr;
}
 
// обрабатывает запрос, но память не удаляет
void ProcessRequest(Request* request) noexcept
{
    double acc{};
    for(int i=0; i<10000; acc+=rand(),i++);
    std::ostringstream oss;
    oss<<"task #"<<std::setw(2)<<request->index<<" processed by "<<std::this_thread::get_id()<<" result="<<acc<<"\n";
    std::cout<<oss.str();
}
 
int main()
{
    srand(time({}));
    
    std::vector<std::thread> trds;
    
    for(size_t i=0; i<100; i++)list.emplace_back(new Request{i});
    
    for(int i=0; i<NumberOfThreads; i++)
    {
        trds.push_back(std::thread([]
        {
            while(auto ptr=GetRequest())ProcessRequest(ptr.get());
        }));
    }
    
    for(auto& i:trds)i.join();
}