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

// 创建和启动线程

内容来自zvvq

std::thread thread1([]() { ... }); 内容来自samhan666

thread1.join();

// 使用 std::async 异步执行任务 本文来自zvvq

auto future = std::async([]() { return sqrt(2.0); }); 内容来自samhan666

double result = future.get();

// 分布式任务队列 zvvq好，好zvvq

class TaskQueue {

zvvq

public:

zvvq.cn

std::vector<std::thread> threads;

内容来自samhan

std::queue<std::function<void()>> tasks; 本文来自zvvq

TaskQueue(int numThreads) {

内容来自samhan

for (int i = 0; i < numThreads; i++) {

threads.push_back(std::thread([this]() {

while (true) {

std::function<void()> task;

copyright zvvq

{ zvvq

std::unique_lock<std::mutex> lock(mtx);

if (!tasks.empty()) {

task = std::move(tasks.front()); zvvq好，好zvvq

tasks.pop(); 内容来自zvvq，别采集哟

}

}

if (task) { zvvq.cn

task(); 内容来自samhan666

} else { 内容来自zvvq，别采集哟

break;

copyright zvvq

} zvvq好，好zvvq

}

}));

} zvvq

}

void addTask(std::function<void()> task) { copyright zvvq

std::unique_lock<std::mutex> lock(mtx); zvvq

tasks.push(task);

} 内容来自samhan666

void stop() { copyright zvvq

for (auto& thread : threads) { zvvq.cn

thread.join(); zvvq

} zvvq.cn

} copyright zvvq

private: 内容来自samhan

std::mutex mtx;

copyright zvvq

}; zvvq好，好zvvq

// 在客户端进程中 zvvq.cn

TaskQueue queue(4); copyright zvvq

queue.addTask([]() { / 执行任务 / });

内容来自samhan

queue.stop();