吉林大学软件学院卓班设计模式第一次作业

// T25.cpp : 此文件包含 "main" 函数。程序执行将在此处开始并结束。 //VS2019编译通过并可运行 #include <vector> #include <queue> #include <thread> #include <iostream> #include <stdexcept> #include <condition_variable> #include <memory> #include<string> const int MAX_THREADS = 10; //最大线程数目设定为n=10 template <typename T> class threadPool { public: threadPool(int number = 1); ~threadPool(); bool append(T* request);//向请求队列＜task_queue＞中添加任务<T *> private: static void* worker(void* s); void run();//从任务队列中取出并执行 private: std::vector<std::thread> work_threads; //工作线程 std::queue<T*> tasks_queue; //任务队列 std::mutex queue_mutex; std::condition_variable condition; bool stop; }; template <typename T> threadPool<T>::threadPool(int number) : stop(false) { if (number <= 0 || number > MAX_THREADS) throw std::exception(); for (int i = 0; i < number; i++) { std::cout << "创建第" << i << "个线程 " << std::endl; work_threads.emplace_back(worker, this); } } template <typename T> inline threadPool<T>::~threadPool() { { std::unique_lock<std::mutex> lock(queue_mutex); stop = true; } condition.notify_all(); for (auto& i : work_threads) i.join(); } template <typename T> bool threadPool<T>::append(T * request) { queue_mutex.lock();//由于工作队列被所有线程共享，操作时需要加锁 tasks_queue.push(request); queue_mutex.unlock(); condition.notify_one(); //线程池添加进去了任务，要通知等待的线程 return true; } template <typename T> void* threadPool<T>::worker(void* s) { threadPool* pool = (threadPool*)s; pool->run(); return pool; } template <typename T> void threadPool<T>::run() { while (!stop) { std::unique_lock<std::mutex> lk(this->queue_mutex); this->condition.wait(lk, [this] { return !this->tasks_queue.empty(); }); if (this->tasks_queue.empty())//如果任务队列不为空，需要停止等待唤醒 { continue; } else { T* request = tasks_queue.front(); tasks_queue.pop(); if (request) request->process(); } } } using namespace std; class Task { public: void process() { //cout << "running..." << endl; } }; int main(void) { threadPool<Task> pool(9); std::string str; while (1) { Task* task = new Task();//使用智能指针 pool.append(task); delete task; } }