综合项目：高性能并发服务器

← 返回课程C++ 高级特性 › 第 10 关

进度 0%

第 10 关：综合项目：高性能并发服务器

C++高级

📖 本课目标

本关属于《C++ 高级特性》第 10 课。阅读右侧代码模板，理解每一行的作用，然后动手修改并完成练习。

🎯 本课要点

include <iostream>
include <vector>
include <thread>
include <mutex>
include <queue>
include <functional>
include <condition_variable>

🛠 学习方式

阅读右侧代码模板中的注释与实现
修改代码，尝试达成新的效果
点击「运行」查看实际输出
确认理解后点击「提交」标记本关完成

💡 说明

本关为 C++，浏览器内无法真正执行该语言。当前「运行」输出为演示结果，请在本地环境中编译运行以验证代码。

main.pytest.py

#include <iostream>
#include <vector>
#include <thread>
#include <mutex>
#include <queue>
#include <functional>
#include <condition_variable>
using namespace std;

// 简单的线程池实现
class ThreadPool {
private:
    vector<thread> workers;
    queue<function<void()>> tasks;
    mutex queueMutex;
    condition_variable condition;
    bool stop;
    
public:
    ThreadPool(size_t numThreads) : stop(false) {
        for (size_t i = 0; i < numThreads; i++) {
            workers.emplace_back([this] {
                while (true) {
                    function<void()> task;
                    {
                        unique_lock<mutex> lock(queueMutex);
                        condition.wait(lock, [this] { return stop || !tasks.empty(); });
                        if (stop && tasks.empty()) return;
                        task = move(tasks.front());
                        tasks.pop();
                    }
                    task();
                }
            });
        }
    }
    
    template<class F>
    void enqueue(F&& task) {
        {
            unique_lock<mutex> lock(queueMutex);
            tasks.emplace(forward<F>(task));
        }
        condition.notify_one();
    }
    
    ~ThreadPool() {
        {
            unique_lock<mutex> lock(queueMutex);
            stop = true;
        }
        condition.notify_all();
        for (auto& worker : workers) {
            worker.join();
        }
    }
};

// 模拟请求处理
void handleRequest(int id) {
    this_thread::sleep_for(chrono::milliseconds(100));
    cout << "请求 " << id << " 处理完成 (线程 " << this_thread::get_id() << ")" << endl;
}

int main() {
    cout << "=== 高性能并发服务器 ===" << endl;
    
    ThreadPool pool(4); // 4个工作线程
    
    cout << "提交 20 个请求..." << endl;
    for (int i = 1; i <= 20; i++) {
        pool.enqueue([i] { handleRequest(i); });
    }
    
    // 等待所有任务完成
    this_thread::sleep_for(chrono::seconds(3));
    
    cout << "\n所有请求处理完成" << endl;
    
    return 0;
}

点击「运行」或「提交代码」查看结果

📖 查看本课说明

第 10 关：综合项目：高性能并发服务器

C++ · 高级 · 《C++ 高级特性》

include <iostream>
include <vector>
include <thread>
include <mutex>
include <queue>
include <functional>
include <condition_variable>

本关为 C++，浏览器无法真正编译运行，请在本地环境验证代码。