C++11 互斥锁

发布时间 2023-12-18 11:59:05作者: 蔡头一枚

1. lock_guard和unique_lock区别


下面是 lock_guard 和 unique_lock 的简单使用示例,可以看出二者在使用方法上的区别
示例:用std::lock_guard加互斥锁
示例:用std::unique_lock加互斥锁并手动释放锁
使用{}来控制轻锁lock_guard的生命周期
lock_guard和unique_lock区别
lock_guard 和 unique_lock 都是 C++ 标准库提供的互斥锁 RAII 封装工具,用于实现互斥访问,但它们有一些不同之处:

lock_guard 是基于互斥锁 std::mutex 实现的,unique_lock 是基于通用锁 std::unique_lock 实现的,unique_lock 可以实现比 lock_guard 更灵活的锁操作。
lock_guard 是不可移动的(moveable),即不能拷贝、赋值、移动,只能通过构造函数初始化和析构函数销毁,unique_lock 是可移动的,可以拷贝、赋值、移动。
unique_lock 提供了更多的控制锁的行为,比如锁超时、不锁定、条件变量等。
unique_lock 比 lock_guard 更重,因为它有更多的功能,更多的开销。如果只需要简单的互斥保护,使用 lock_guard 更好。

另外,unique_lock 支持手动解锁,而 lock_guard 不支持。

下面是 lock_guard 和 unique_lock 的简单使用示例,可以看出二者在使用方法上的区别

  1.  
    #include <iostream>
  2.  
    #include <mutex>
  3.  
    #include <thread>
  4.  
     
  5.  
    std::mutex m;
  6.  
     
  7.  
    void worker()
  8.  
    {
  9.  
        std::lock_guard<std::mutex> lg(m);  // lock_guard 方式上锁
  10.  
        std::cout << "worker thread is running..." << std::endl;
  11.  
        // 这里可以写一些需要互斥保护的代码
  12.  
        std::this_thread::sleep_for(std::chrono::seconds(1));
  13.  
        std::cout << "worker thread is done." << std::endl;
  14.  
    }  // lock_guard 不支持手动解锁,会在此自动释放锁
  15.  
     
  16.  
    void another_worker()
  17.  
    {
  18.  
        std::unique_lock<std::mutex> ul(m);  // unique_lock 方式上锁
  19.  
        std::cout << "another worker thread is running..." << std::endl;
  20.  
        // 这里可以写一些需要互斥保护的代码
  21.  
        std::this_thread::sleep_for(std::chrono::seconds(1));
  22.  
        std::cout << "another worker thread is done." << std::endl;
  23.  
        ul.unlock();  // 手动释放锁
  24.  
        //do something...
  25.  
    }  // 如果锁未释放,unique_lock 会在此自动释放锁
  26.  
     
  27.  
    int main()
  28.  
    {
  29.  
        std::thread t1(worker);
  30.  
        std::thread t2(another_worker);
  31.  
        t1.join();
  32.  
        t2.join();
  33.  
        return 0;
  34.  
    }

编译运行结果:

  1.  
    g++ test.cpp -lpthread && ./a.out 
  2.  
    1

在这里插入图片描述


2. 用std::lock_guard加互斥锁


std::lock_guard 是 C++11 中的标准库,是一个实现互斥锁的简单模板类。
它的使用方法很简单,只需要在代码中创建一个 std::lock_guard 对象,并传入一个互斥锁,在它的生命周期内,互斥锁的访问权限将被控制。 

  1.  
    #include <iostream>
  2.  
    #include <thread>
  3.  
    #include <mutex>
  4.  
    #include <chrono>
  5.  
    #include <vector>
  6.  
     
  7.  
    std::mutex mtx;
  8.  
    std::vector<int> data;
  9.  
     
  10.  
    void func1()
  11.  
    {
  12.  
        std::lock_guard<std::mutex> lock(mtx); // 创建 lock_guard 对象
  13.  
        for (int i = 0; i < 10; ++i)
  14.  
        {
  15.  
            data.push_back(i); 
  16.  
            std::cout << "func1: " << i << std::endl;
  17.  
            std::this_thread::sleep_for(std::chrono::seconds(1));
  18.  
        }
  19.  
    }
  20.  
     
  21.  
    void func2()
  22.  
    {
  23.  
        std::lock_guard<std::mutex> lock(mtx); // 创建 lock_guard 对象
  24.  
        for (int i = 100; i < 110; ++i)
  25.  
        {
  26.  
            data.push_back(i);
  27.  
            std::cout << "func2: " << i << std::endl;
  28.  
            std::this_thread::sleep_for(std::chrono::seconds(1));
  29.  
        }
  30.  
    }
  31.  
     
  32.  
    int main()
  33.  
    {
  34.  
        std::thread thrd1(func1);
  35.  
        std::thread thrd2(func2);
  36.  
     
  37.  
        thrd1.join();
  38.  
        thrd2.join();
  39.  
     
  40.  
        for (auto &i : data)
  41.  
        {
  42.  
            std::cout << i << " ";
  43.  
        }
  44.  
        std::cout << std::endl;
  45.  
        return 0;
  46.  
    }


编译运行:

  1.  
    g++ test.cpp -lpthread && ./a.out
  2.  
    1

在这里插入图片描述


3. 用std::unique_lock加互斥锁并手动释放锁


在 C++ 中,互斥锁通常是通过 RAII 机制来保证自动释放,即在锁对象的生命周期结束时自动释放锁。但是,在某些情况下,可能需要手动释放互斥锁。在 C++11 中,可以通过 std::unique_lock::unlock() 方法来手动释放互斥锁。

 

下面是一个简单的示例代码,演示了如何手动释放互斥锁:

  1.  
    #include <iostream>
  2.  
    #include <thread>
  3.  
    #include <mutex>
  4.  
    #include <chrono>
  5.  
     
  6.  
    std::mutex g_mutex;
  7.  
    int count = 0;
  8.  
     
  9.  
    void func()
  10.  
    {
  11.  
        std::unique_lock<std::mutex> lock(g_mutex);
  12.  
        std::cout << "Thread " << std::this_thread::get_id() << " acquired the lock." << std::endl;
  13.  
        count++;
  14.  
        std::cout << "Thread " << std::this_thread::get_id() << " count = " << count << std::endl;
  15.  
        lock.unlock(); // 手动释放互斥锁  //如果不手动释放,锁会在函数结束时自动释放
  16.  
        std::cout << "Thread " << std::this_thread::get_id() << " released the lock." << std::endl;
  17.  
        //do somethine...
  18.  
        std::this_thread::sleep_for(std::chrono::seconds(1));
  19.  
    }
  20.  
     
  21.  
    int main()
  22.  
    {
  23.  
        const int numThreads = 1000;
  24.  
     
  25.  
        std::thread threads[numThreads];
  26.  
        for (int i = 0; i < numThreads; ++i) {
  27.  
            threads[i] = std::thread(func);
  28.  
        }
  29.  
     
  30.  
        for (int i = 0; i < numThreads; ++i) {
  31.  
            threads[i].join();
  32.  
        }
  33.  
     
  34.  
        std::cout << "final count = " << count << std::endl;
  35.  
     
  36.  
        return 0;
  37.  
    }


编译运行结果:

  1.  
    g++ test.cpp -lpthread && ./a.out
  2.  
    1

在这里插入图片描述

 
4. 使用{}来控制轻锁lock_guard的生命周期


当使用{}括起来的代码块创建std::lock_guard对象时,std::lock_guard的生命周期将仅限于该代码块内部。

std::lock_guard是一个在构造函数中获取互斥锁,在析构函数中释放互斥锁的RAII类。当std::lock_guard对象的生命周期结束时,它会自动释放所持有的互斥锁,以避免出现死锁和其他相关的问题。

当您在代码块中创建std::lock_guard对象时,它的析构函数将在代码块结束时自动调用,从而释放锁。这意味着锁的作用范围将仅限于该代码块内部,并且在代码块外部无法访问该锁。

下面是一个示例代码,演示了如何在代码块内使用std::lock_guard对象:

  1.  
    #include <mutex>
  2.  
     
  3.  
    std::mutex m; // 互斥锁
  4.  
     
  5.  
    void foo()
  6.  
    {
  7.  
        {
  8.  
            std::lock_guard<std::mutex> guard(m); // 创建 std::lock_guard 对象
  9.  
            // 在这个代码块中,互斥锁 m 被锁定
  10.  
            // 执行一些需要互斥访问的代码
  11.  
        } // std::lock_guard 对象在这里销毁,互斥锁 m 被解锁
  12.  
        // 在这个代码块外,无法访问锁 m
  13.  
    }


完整测试代码:

  1.  
    #include <iostream>
  2.  
    #include <thread>
  3.  
    #include <mutex>
  4.  
    #include <chrono>
  5.  
     
  6.  
    std::mutex m; // 互斥锁
  7.  
    int shared_data = 0; // 共享数据
  8.  
     
  9.  
    void worker(int id)
  10.  
    {
  11.  
        // 在循环中修改共享数据
  12.  
        for (int i = 0; i < 5; ++i) 
  13.  
        {
  14.  
            {
  15.  
                std::lock_guard<std::mutex> guard(m); // 创建 std::lock_guard 对象
  16.  
                shared_data++; // 修改共享数据
  17.  
                std::cout << "Worker " << id << " modified shared data to " << shared_data << std::endl;
  18.  
            } //销毁lock_guard,释放锁
  19.  
            printf("Worker %d relead lock.......................................\n", id);
  20.  
            std::this_thread::sleep_for(std::chrono::seconds(1));
  21.  
            printf("Worker %d has sleep 1 second.......................................\n", id);
  22.  
        } // std::lock_guard 对象在这里销毁,互斥锁 m 被解锁
  23.  
    }
  24.  
     
  25.  
    int main()
  26.  
    {
  27.  
        std::thread t1(worker, 1);
  28.  
        std::thread t2(worker, 2);
  29.  
     
  30.  
        t1.join();
  31.  
        t2.join();
  32.  
     
  33.  
        std::cout << "Final value of shared data is " << shared_data << std::endl;
  34.  
     
  35.  
        return 0;
  36.  
    }



在上面的示例代码中,有两个线程t1和t2,它们同时访问共享数据shared_data。为了避免数据竞争和其他并发问题,我们使用了std::mutex和std::lock_guard来确保只有一个线程可以访问共享数据。

在worker()函数中,我们使用了std::lock_guard对象guard来锁定互斥锁m,以确保每个线程在修改共享数据时都能够获得锁。当std::lock_guard对象在代码块末尾销毁时,互斥锁将自动解锁,从而允许其他线程访问共享数据。

在main()函数中,我们创建了两个线程t1和t2,它们分别执行worker()函数。我们使用t1.join()和t2.join()等待线程执行完毕,然后输出最终的共享数据值。

编译运行结果:

在这里插入图片描述
原文链接:https://blog.csdn.net/Dontla/article/details/129030629