游乐游手机版
首页/编程语言/文章详情

Ubuntu C++如何实现并发控制

时间:2026-05-04 09:02
在Ubuntu上使用C++实现并发控制 想在Ubuntu环境下用C++玩转并发编程?这事儿说复杂也复杂,说简单也简单。自从C++11把标准线程库()纳入麾下,多线程开发的门槛就大大降低了,安全性和便捷性也上了一个台阶。今天,咱们就来聊聊几个核心的并发控制概念,并看看如何在Ubuntu上用C++把它们

在Ubuntu上使用C++实现并发控制

想在Ubuntu环境下用C++玩转并发编程?这事儿说复杂也复杂,说简单也简单。自从C++11把标准线程库()纳入麾下,多线程开发的门槛就大大降低了,安全性和便捷性也上了一个台阶。今天,咱们就来聊聊几个核心的并发控制概念,并看看如何在Ubuntu上用C++把它们实现出来。

Ubuntu C++如何实现并发控制

1. 创建线程

万事开头难?其实不然。创建一个新线程,用std::thread就能轻松搞定。下面这个例子,能让你直观地感受线程是怎么“跑”起来的。

#include 
#include 

void helloFunction() {
    std::cout << “Hello from a thread!” << std::endl;
}

int main() {
    std::thread t(helloFunction);
    t.join(); // 等待线程完成
    return 0;
}

2. 线程同步

线程一旦多起来,麻烦也就跟着来了。最典型的问题就是数据竞争:多个线程同时读写一块共享内存,结果很可能一团糟。这时候,同步机制就该登场了,互斥锁(std::mutex)就是其中最常用的一种“交通警察”。

#include 
#include 
#include 

std::mutex mtx; // 创建一个互斥锁

void printMessage(const std::string& msg) {
    mtx.lock(); // 锁定互斥锁
    std::cout << msg << std::endl;
    mtx.unlock(); // 解锁互斥锁
}

int main() {
    std::thread t1(printMessage, “Hello from thread 1”);
    std::thread t2(printMessage, “Hello from thread 2”);
    t1.join();
    t2.join();
    return 0;
}

3. 条件变量

光有锁还不够。有时候,线程需要等待某个条件成立才能继续执行,比如等待任务队列非空。这种场景下,条件变量(std::condition_variable)就是最佳拍档,它通常和互斥锁携手工作,实现更精细的线程间协调。

#include 
#include 
#include 
#include 

std::mutex mtx;
std::condition_variable cv;
bool ready = false;

void printId(int id) {
    std::unique_lock lck(mtx);
    cv.wait(lck, []{return ready;}); // 等待直到ready为true
    std::cout << “Thread ” << id << std::endl;
}

void go() {
    std::lock_guard lck(mtx);
    ready = true;
    cv.notify_all(); // 通知所有等待的线程
}

int main() {
    std::thread threads[10];
    // spawn 10 threads:
    for (int i = 0; i < 10; ++i)
        threads[i] = std::thread(printId, i);

    std::cout << “10 threads ready to race...” << std::endl;
    go(); // go!

    for (auto& th : threads) th.join();
    return 0;
}

4. 原子操作

锁用多了,性能难免受影响。对于一些简单的操作,比如计数器增减,有没有更轻量级的方案?答案是肯定的,那就是原子操作(std::atomic)。它能在硬件层面保证操作的不可分割性,从而实现高效的无锁编程。

#include 
#include 
#include 

std::atomic counter(0);

void incrementCounter() {
    for (int i = 0; i < 1000; ++i) {
        counter.fetch_add(1, std::memory_order_relaxed);
    }
}

int main() {
    std::thread t1(incrementCounter);
    std::thread t2(incrementCounter);
    t1.join();
    t2.join();
    std::cout << “Counter value: ” << counter.load() << std::endl;
    return 0;
}

编译和运行

纸上谈兵终觉浅。在Ubuntu上把代码变成可执行文件,这一步很关键。使用g++编译器时,记住要加上-pthread参数来链接线程库。

g++ -pthread your_program.cpp -o your_program
./your_program

以上这些,算是C++并发编程的“入门四式”。它们涵盖了创建、同步、协调和高效访问这几个基本维度。当然,实际项目中的挑战往往更复杂,需要根据具体的应用场景,灵活组合甚至设计更高级的并发控制策略。但万变不离其宗,理解了这些基础,后面的路就好走多了。

来源:https://www.yisu.com/ask/36866482.html
上一篇Ubuntu C++怎样使用第三方库 下一篇Ubuntu C++怎样优化循环语句
本站内容用于信息整理与展示,如有侵权或内容问题请及时联系处理。

相关推荐

补充同频道和同主题内容,方便继续浏览更多相关内容。

同类最新

继续查看同栏目最近更新的文章。

更多
如何在Go中安全地创建和使用time.Ticker最佳实践指南
编程语言 · 2026-07-06

如何在Go中安全地创建和使用time.Ticker最佳实践指南

在Go中,time Ticker的创建位置直接影响并发安全。最佳实践是在goroutine外创建或完全限定在单个goroutine内使用,严禁无保护跨goroutine共享。无论采用哪种方式,都必须在使用完毕后调用Stop()释放底层定时器资源,防止goroutine泄露。停止后的Ticker不应再调用Reset以避免竞态。

Go跨文件cgo结构体类型不兼容的解决方案
编程语言 · 2026-07-06

Go跨文件cgo结构体类型不兼容的解决方案

cgo为每个Go包生成独立的C命名空间,导致跨文件使用同一C结构体时类型不兼容。解决方案是在中心包中定义Go封装类型(如typePointC point_t),并将所有构造、访问和业务逻辑封装其中,其他包仅引用Go类型,避免直接暴露C类型。

Go语言有符号整数二进制补码的正确输出方法
编程语言 · 2026-07-06

Go语言有符号整数二进制补码的正确输出方法

Go语言fmt Printf的%b格式对负数输出带负号的绝对值二进制,而非底层补码位模式。需注意,通过将相同位宽的有符号整数转换为无符号类型(例如将int8转为uint8),可获取真实的二进制补码比特序列,如-5输出11111011,即其补码。

Python列表按出现顺序批量替换重复字符串
编程语言 · 2026-07-06

Python列表按出现顺序批量替换重复字符串

Python列表遍历中,使用计数器对重复字符串(如“latest png”)按出现顺序依次替换为带递增编号的新字符串(如“latest1 png”),保持原列表不变。该方法时间复杂度O(n),无需额外库,严格匹配避免误改,不修改原始列表。

Go语言中如何正确读取io.Reader避免重复与内存污染
编程语言 · 2026-07-06

Go语言中如何正确读取io.Reader避免重复与内存污染

Go开发者使用io Reader Read()手动读取HTTP响应体时,因忽略实际读取字节数n和未正确处理io EOF,导致内容重复、空字节污染等问题。必须使用buf[:n]追加有效数据,将io EOF视为正常终止信号,并检查其他错误,从而避免内存污染与panic风险。