当前位置: 首页 > wzjs >正文

深圳市住房和建设网站优化建站

深圳市住房和建设网站,优化建站,做殡葬名片的网站,顺德龙江网站建设什么是std::thread? std::thread是C11中引入的一个类,用于表示和管理线程。通过std::thread,我们可以创建一个新的线程来执行指定的任务。线程是操作系统调度的基本单位,多个线程可以并发执行,从而提高程序的效率。 创…

什么是std::thread

std::thread是C++11中引入的一个类,用于表示和管理线程。通过std::thread,我们可以创建一个新的线程来执行指定的任务。线程是操作系统调度的基本单位,多个线程可以并发执行,从而提高程序的效率。


创建线程

基本用法

要创建一个线程,只需实例化一个std::thread对象,并传入一个可调用对象(如函数、Lambda表达式或函数对象)作为参数。

#include <iostream>
#include <thread>void hello() {std::cout << "Hello from thread!\n";
}int main() {std::thread t(hello); // 创建一个线程,执行hello函数t.join(); // 等待线程结束return 0;
}

在这个示例中,我们创建了一个线程t,它执行hello函数。join()方法用于等待线程执行完毕。


使用Lambda表达式

我们也可以使用Lambda表达式来创建线程。

#include <iostream>
#include <thread>int main() {std::thread t([]() {std::cout << "Hello from Lambda thread!\n";});t.join();return 0;
}

带参数的线程函数

线程函数可以接受参数,只需在创建线程时传递相应的参数即可。

#include <iostream>
#include <thread>void print_message(const std::string& message) {std::cout << message << '\n';
}int main() {std::thread t(print_message, "Hello from thread with arguments!");t.join();return 0;
}

线程的管理

join()detach()

  • join():等待线程执行完毕。调用join()后,主线程会阻塞,直到子线程完成。
  • detach():将线程与std::thread对象分离,线程在后台独立运行。分离后的线程不能再被join()
#include <iostream>
#include <thread>
#include <chrono>void task() {std::this_thread::sleep_for(std::chrono::seconds(1));std::cout << "Task completed!\n";
}int main() {std::thread t(task);t.detach(); // 分离线程std::cout << "Main thread continues...\n";std::this_thread::sleep_for(std::chrono::seconds(2)); // 等待子线程完成return 0;
}

线程的移动语义

std::thread支持移动语义,可以将一个线程的所有权从一个std::thread对象转移到另一个。

#include <iostream>
#include <thread>void task() {std::cout << "Task executed!\n";
}int main() {std::thread t1(task);std::thread t2 = std::move(t1); // 将t1的所有权转移给t2t2.join();return 0;
}

线程同步

多线程编程中,线程之间的共享资源可能会导致数据竞争问题。为了解决这个问题,C++提供了多种同步机制,如互斥锁(std::mutex)和条件变量(std::condition_variable)。


使用std::mutex

std::mutex用于保护共享资源,确保同一时间只有一个线程可以访问该资源。

#include <iostream>
#include <thread>
#include <mutex>
#include <vector>std::mutex mtx;
int shared_data = 0;void increment() {for (int i = 0; i < 10000; ++i) {std::lock_guard<std::mutex> lock(mtx); // 自动加锁和解锁++shared_data;}
}int main() {std::vector<std::thread> threads;for (int i = 0; i < 10; ++i) {threads.emplace_back(increment);}for (auto& t : threads) {t.join();}std::cout << "Final value of shared_data: " << shared_data << '\n'; // 输出:100000return 0;
}

使用std::condition_variable

std::condition_variable用于线程间的通信,允许线程等待某些条件成立。

#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>std::mutex mtx;
std::condition_variable cv;
bool ready = false;void print_id(int id) {std::unique_lock<std::mutex> lock(mtx);cv.wait(lock, []() { return ready; }); // 等待条件成立std::cout << "Thread " << id << " is running!\n";
}int main() {std::thread threads[10];for (int i = 0; i < 10; ++i) {threads[i] = std::thread(print_id, i);}std::this_thread::sleep_for(std::chrono::seconds(1));{std::lock_guard<std::mutex> lock(mtx);ready = true; // 设置条件为true}cv.notify_all(); // 通知所有等待的线程for (auto& t : threads) {t.join();}return 0;
}

线程池的实现

虽然C++标准库没有直接提供线程池,但我们可以使用std::thread和其他工具(如std::queuestd::function)来实现一个简单的线程池。

#include <iostream>
#include <thread>
#include <vector>
#include <queue>
#include <functional>
#include <mutex>
#include <condition_variable>class ThreadPool {
public:ThreadPool(size_t num_threads) {for (size_t i = 0; i < num_threads; ++i) {workers.emplace_back([this] {while (true) {std::function<void()> task;{std::unique_lock<std::mutex> lock(this->queue_mutex);this->condition.wait(lock, [this] { return this->stop || !this->tasks.empty(); });if (this->stop && this->tasks.empty()) {return;}task = std::move(this->tasks.front());this->tasks.pop();}task();}});}}template <class F>void enqueue(F&& f) {{std::unique_lock<std::mutex> lock(queue_mutex);tasks.emplace(std::forward<F>(f));}condition.notify_one();}~ThreadPool() {{std::unique_lock<std::mutex> lock(queue_mutex);stop = true;}condition.notify_all();for (std::thread& worker : workers) {worker.join();}}private:std::vector<std::thread> workers;std::queue<std::function<void()>> tasks;std::mutex queue_mutex;std::condition_variable condition;bool stop = false;
};int main() {ThreadPool pool(4);for (int i = 0; i < 8; ++i) {pool.enqueue([i] {std::cout << "Task " << i << " is running on thread " << std::this_thread::get_id() << '\n';std::this_thread::sleep_for(std::chrono::seconds(1));});}return 0;
}
http://www.dtcms.com/wzjs/139858.html

相关文章:

  • 龙口建网站公司哪家好搜索关键词优化
  • 昆明网站关键字优化怎么在网上做推广
  • 上海 网站建设业务营销方法搜索引擎bing
  • 上海做网站好的公司有哪些每日新闻摘抄10一30字
  • 杭州化妆品网站建设企业建站免费模板
  • 南皮县做网站关键词排名优化方法
  • 有做企业网站的吗网站seo平台
  • 云阳网站建设公司社区建站网站系统
  • 东莞品牌做网站路由器优化大师
  • 中文域名注册网站上海关键词优化方法
  • 免费招聘网站哪个好广告公司简介
  • 网站建设维护去哪里学搜索app下载
  • 网站建设外包第一营销网
  • 青岛英文建站公司官网优化 报价
  • wordpress .net版本号整站优化排名
  • 福田网站制作哪家好宣传推广渠道有哪些
  • 百度网站收录seo推广怎么做视频教程
  • 江门网站制作设计域名注册官网
  • 怎么用群晖nas做网站西安做推广优化的公司
  • 公司做网站费用seo关键词推广案例
  • 大连网络营销咨询服务seo确定关键词
  • 动态网站建设试题软文素材网
  • 郑州手机网站开发营销型企业网站案例
  • 汕头 网站建设搜狗推广助手
  • 网站模板 wordpress带会员系统青岛网站设计制作
  • 深圳web网站开发公司大型网站建设公司
  • 网站通知发送邮件seo实战
  • 网站名称是什么seodao cn
  • 上饶网站建设兼职关键词长尾词优化
  • 网站开发预算成本价宁波seo排名优化培训