C++ 框架中并发和多线程处理与分布式系统

// 创建和启动线程
std::thread thread1([]() { ... });
thread1.join();

// 使用 std::async 异步执行任务
auto future = std::async([]() { return sqrt(2.0); });
double result = future.get();

// 分布式任务队列
class TaskQueue {
public:
    std::vector<std::thread> threads;
    std::queue<std::function<void()>> tasks;

    TaskQueue(int numThreads) {
        for (int i = 0; i < numThreads; i++) {
            threads.push_back(std::thread([this]() {
                while (true) {
                    std::function<void()> task;
                    {
                        std::unique_lock<std::mutex> lock(mtx);
                        if (!tasks.empty()) {
                            task = std::move(tasks.front());
                            tasks.pop();
                        }
                    }
                    if (task) {
                        task();
                    } else {
                        break;
                    }
                }
            }));
        }
    }

    void addTask(std::function<void()> task) {
        std::unique_lock<std::mutex> lock(mtx);
        tasks.push(task);
    }

    void stop() {
        for (auto& thread : threads) {
            thread.join();
        }
    }

private:
    std::mutex mtx;
};

// 在客户端进程中
TaskQueue queue(4);
queue.addTask([]() { /* 执行任务 */ });
queue.stop();