C++程序在Ubuntu如何实现并发控制

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

想要在Ubuntu系统中掌握C++多线程编程与并发控制技术？这既是现代C++开发的核心技能，也是提升程序性能的关键手段。自C++11标准正式引入头文件以来，创建和管理线程变得前所未有的简洁高效。然而，仅仅启动多个线程并不足够，要确保它们协调工作、避免数据竞争和资源冲突，必须借助一系列同步原语：包括互斥锁（）、条件变量（）、原子操作（）在内的并发控制工具，共同构成了稳健多线程程序的基石。

免费影视、动漫、音乐、游戏、小说资源长期稳定更新！ 👉 点此立即查看 👈

理论阐述需要代码实践来印证。下面这个经典示例，清晰地演示了如何利用和实现基础的线程同步与互斥访问控制：

#include 
#include 
#include 

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

void print_block(int n, char c) {
    mtx.lock(); // 加锁
    for (int i = 0; i < n; ++i) {
        std::cout << c;
    }
    std::cout << '\n';
    mtx.unlock(); // 解锁
}

int main() {
    std::thread th1(print_block, 50, '*');
    std::thread th2(print_block, 50, '$');

    th1.join(); // 等待线程th1完成
    th2.join(); // 等待线程th2完成

    return 0;
}

这段代码的核心逻辑非常明确：我们定义了一个print_block函数用于循环打印指定字符。其中的关键在于，如果没有std::mutex互斥锁的保护，两个线程可能会同时向标准输出流写入数据，导致输出内容交错混乱，产生不可预知的结果。互斥锁的核心作用，就是为控制台输出这一“临界区”代码段提供独占访问保障，确保同一时刻只有一个线程能够执行该段代码，从而维护输出结果的正确性与顺序性。

当然，std::mutex仅仅是C++标准库提供的多种同步机制之一。针对不同的并发场景，开发者可以选用更合适的工具，它们各自拥有独特的设计目的与优势：

• std::lock_guard：采用RAII（资源获取即初始化）设计模式的智能锁管理器。它在构造时自动锁定关联的互斥量，在析构时自动释放，彻底避免了因忘记解锁而导致的死锁问题，是简单场景下的首选。
• std::unique_lock：功能更为强大的通用锁管理器。除了具备lock_guard的所有特性外，还支持延迟锁定、尝试锁定、锁定所有权转移以及与条件变量配合使用，灵活性极高。
• std::condition_variable：用于线程间通信的同步机制。它允许一个或多个线程阻塞等待，直到被其他线程通知（notify）某个条件成立，是实现生产者-消费者、任务队列等模式的利器。
• std::atomic：提供无需显式锁定的原子操作。对于整型、指针等基本数据类型，它能确保该类型上的操作（如读、写、递增）是不可分割的，从而在保证数据一致性的同时，往往能获得比互斥锁更高的性能。

为了加深理解，我们来看一个综合运用std::unique_lock与std::condition_variable的进阶案例，模拟多线程协调执行的场景：

#include 
#include 
#include 
#include 

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

void print_id(int id) {
    std::unique_lock lck(mtx);
    cv.wait(lck, []{return ready;}); // 等待直到ready为true
    std::cout << "Thread " << id << '\n';
}

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(print_id, i);

    std::cout << "10 threads ready to race...\n";
    go(); // go!

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

这个程序生动地模拟了“赛跑发令”过程：创建的10个工作线程（运动员）在启动后，立即通过cv.wait()进入等待状态，阻塞在条件变量上。主线程（发令员）随后调用go()函数，在持有锁的情况下将共享标志ready设置为true，并调用cv.notify_all()广播通知。所有等待中的线程被唤醒后，检查条件发现已满足，便同时继续执行，打印各自的ID。这种模式广泛应用于线程池调度、事件驱动编程等需要精确协调的并发场景。

最后，将编写好的并发程序成功编译运行是最终步骤。在Ubuntu上使用GCC/G++编译器时，需要确保使用正确的编译命令与链接选项：

g++ -std=c++11 -pthread your_program.cpp -o your_program

这条命令包含两个至关重要的参数：-std=c++11（或更高标准如c++14、c++17）用于启用对应的C++标准特性支持；而-pthread选项则是多线程程序编译链接的必需项，它确保正确链接到系统的POSIX线程库（pthread），并定义相关的宏，使得线程创建、同步等函数能够正常工作。掌握正确的编译方法，你的C++并发程序就能在Ubuntu Linux环境下稳定高效地运行了。