#include #include #include #include #include #include #include #include using namespace std::chrono_literals; using namespace std; template class ThreadPool{ private: int numberThreads=0; mutex mutexQueue; queueworkQueue{}; vectorthreads{}; atomic looping = true; atomic threadsRunning = 0; public: void start(){ for(int i=numberThreads;i-->0;){ thread t(&ThreadPool:: worker,this); threads.push_back(move(t)); ++threadsRunning ; } } bool isWorking() const noexcept { return threadsRunning > 0; } void stop() noexcept { looping = false; } void join() noexcept { for(auto & t:threads) if(t.joinable()) t.join(); } void detach() noexcept { for(auto & t:threads) if(t.joinable()) t.detach(); } void push(T i) noexcept{ lock_guard lg(mutexQueue); workQueue.push(i); } bool queueIsEmpty() noexcept{ lock_guard lg(mutexQueue); return workQueue.empty(); } void setNumberOfThreads(int n) noexcept{ numberThreads = n; } T pop() { lock_guard lg(mutexQueue); if(workQueue.empty()) return {}; T value = workQueue.front(); workQueue.pop(); return value; } private: void worker(){ do{ task(); }while(looping); --threadsRunning ; } // this is the only method that needs be override by derived class virtual void task()=0; }; class MyThreadPool: public ThreadPool{ private: mutex mutexStdout; mutex mutexStderr; public: explicit MyThreadPool(int n) noexcept { setNumberOfThreads(n); } private: void task() override { auto isPrime = [](int n)->bool{ for(int j=2;j<=n/2;++j) if(n%j==0) return false; return true; }; int job = pop(); if (job==int{}) return; bool primity = isPrime(job); bool locked = false; while(!locked){ if(unique_lock lock2(mutexStdout,defer_lock); lock2.try_lock()){ fprintf(stdout, "%4d : %d : %llu\n", job, primity, this_thread::get_id() ); locked = true; }else if(unique_lock lock3(mutexStderr,defer_lock); lock3.try_lock()){ fprintf(stderr, "%4d : %d : %llu\n", job, primity, this_thread::get_id() ); locked = true; } } } }; int main() { cout<<"Nums Prime Thread_id"<

Threadpool