2. 用std::lock_guard加互斥锁

2. 用std::lock_guard加互斥锁

目录

1. lock_guard和unique_lock区别

2. 用std::lock_guard加互斥锁

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

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

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 的简单使用示例,可以看出二者在使用方法上的区别

#include

#include

#include

std::mutex m;

void worker()

{

std::lock_guard lg(m); // lock_guard 方式上锁

std::cout << "worker thread is running..." << std::endl;

// 这里可以写一些需要互斥保护的代码

std::this_thread::sleep_for(std::chrono::seconds(1));

std::cout << "worker thread is done." << std::endl;

} // lock_guard 不支持手动解锁,会在此自动释放锁

void another_worker()

{

std::unique_lock ul(m); // unique_lock 方式上锁

std::cout << "another worker thread is running..." << std::endl;

// 这里可以写一些需要互斥保护的代码

std::this_thread::sleep_for(std::chrono::seconds(1));

std::cout << "another worker thread is done." << std::endl;

ul.unlock(); // 手动释放锁

//do something...

} // 如果锁未释放,unique_lock 会在此自动释放锁

int main()

{

std::thread t1(worker);

std::thread t2(another_worker);

t1.join();

t2.join();

return 0;

}

编译运行结果:

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

1

2. 用std::lock_guard加互斥锁

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

#include

#include

#include

#include

#include

std::mutex mtx;

std::vector data;

void func1()

{

std::lock_guard lock(mtx); // 创建 lock_guard 对象

for (int i = 0; i < 10; ++i)

{

data.push_back(i);

std::cout << "func1: " << i << std::endl;

std::this_thread::sleep_for(std::chrono::seconds(1));

}

}

void func2()

{

std::lock_guard lock(mtx); // 创建 lock_guard 对象

for (int i = 100; i < 110; ++i)

{

data.push_back(i);

std::cout << "func2: " << i << std::endl;

std::this_thread::sleep_for(std::chrono::seconds(1));

}

}

int main()

{

std::thread thrd1(func1);

std::thread thrd2(func2);

thrd1.join();

thrd2.join();

for (auto &i : data)

{

std::cout << i << " ";

}

std::cout << std::endl;

return 0;

}

编译运行:

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

1

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

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

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

#include

#include

#include

#include

std::mutex g_mutex;

int count = 0;

void func()

{

std::unique_lock lock(g_mutex);

std::cout << "Thread " << std::this_thread::get_id() << " acquired the lock." << std::endl;

count++;

std::cout << "Thread " << std::this_thread::get_id() << " count = " << count << std::endl;

lock.unlock(); // 手动释放互斥锁 //如果不手动释放,锁会在函数结束时自动释放

std::cout << "Thread " << std::this_thread::get_id() << " released the lock." << std::endl;

//do somethine...

std::this_thread::sleep_for(std::chrono::seconds(1));

}

int main()

{

const int numThreads = 1000;

std::thread threads[numThreads];

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

threads[i] = std::thread(func);

}

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

threads[i].join();

}

std::cout << "final count = " << count << std::endl;

return 0;

}

编译运行结果:

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

1

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

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

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

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

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

#include

std::mutex m; // 互斥锁

void foo()

{

{

std::lock_guard guard(m); // 创建 std::lock_guard 对象

// 在这个代码块中,互斥锁 m 被锁定

// 执行一些需要互斥访问的代码

} // std::lock_guard 对象在这里销毁,互斥锁 m 被解锁

// 在这个代码块外,无法访问锁 m

}

完整测试代码:

#include

#include

#include

#include

std::mutex m; // 互斥锁

int shared_data = 0; // 共享数据

void worker(int id)

{

// 在循环中修改共享数据

for (int i = 0; i < 5; ++i)

{

{

std::lock_guard guard(m); // 创建 std::lock_guard 对象

shared_data++; // 修改共享数据

std::cout << "Worker " << id << " modified shared data to " << shared_data << std::endl;

} //销毁lock_guard,释放锁

printf("Worker %d relead lock.......................................\n", id);

std::this_thread::sleep_for(std::chrono::seconds(1));

printf("Worker %d has sleep 1 second.......................................\n", id);

} // std::lock_guard 对象在这里销毁,互斥锁 m 被解锁

}

int main()

{

std::thread t1(worker, 1);

std::thread t2(worker, 2);

t1.join();

t2.join();

std::cout << "Final value of shared data is " << shared_data << std::endl;

return 0;

}

在上面的示例代码中,有两个线程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

相关推荐

​港视往事:口碑最好的九部僵尸电视剧
365bet手机版中文

​港视往事:口碑最好的九部僵尸电视剧

📅 07-19 👁️ 6952
本地主叫和省内主叫的含义是什么
365bet手机版中文

本地主叫和省内主叫的含义是什么

📅 07-24 👁️ 4051
PS无法保存,这里有5种解决方法!
平板安卓office365破解版

PS无法保存,这里有5种解决方法!

📅 08-25 👁️ 3818
冒险游戏游戏有哪些好玩 十大必玩冒险游戏游戏精选
365防伪码查询系统

冒险游戏游戏有哪些好玩 十大必玩冒险游戏游戏精选

📅 07-27 👁️ 5338
Clash of Clans 中文
365bet手机版中文

Clash of Clans 中文

📅 07-10 👁️ 9555
光脚穿皮鞋出汗怎么办
平板安卓office365破解版

光脚穿皮鞋出汗怎么办

📅 07-29 👁️ 9179