zoukankan      html  css  js  c++  java
  • 十、原子操作

    std::atomic原子操作:

    互斥量:多线程编程中 用于保护共享数据:先锁住, 操作共享数据, 解锁。

    有两个线程,对一个变量进行操作,一个线程读这个变量的值,一个线程往这个变量中写值。

    即使是一个简单变量的读取和写入操作,如果不加锁,也有可能会导致读写值混乱。

    • 一条C++语句  i++ 会被拆成3条汇编语句来执行,所以仍然有可能混乱
    • 汇编指令:read i;inc i;store i。

    • a线程读取 i (i=1)放入寄存器加1,变成2,同时b线程读取i (i=1)放入寄存器加1,变成2,然后a,b都把2放回内存,但其实此时结果已经为3了。
     1 using namespace std;
     2 int g_count = 0;
     3  
     4 void mythread1() {
     5     for (int i = 0; i < 1000000; i++) {
     6         g_count++;
     7     }
     8 }
     9  
    10 int main() {
    11     std::thread t1(mythread1);
    12     std::thread t2(mythread1);
    13     t1.join();
    14     t2.join();
    15     cout << "正常情况下结果应该是200 0000次,实际是" << g_count << endl;
    16 }

    使用mutex解决这个问题

     1 using namespace std;
     2 int g_count = 0;
     3 std::mutex mymutex;
     4  
     5 void mythread1() {
     6     for (int i = 0; i < 1000000; i++) {
     7         std::unique_lock<std::mutex> u1(mymutex);
     8         g_count++;
     9     }
    10 }
    11  
    12  
    13 int main() {
    14     std::thread t1(mythread1);
    15     std::thread t2(mythread1);
    16     t1.join();
    17     t2.join();
    18     cout << "正常情况下结果应该是200 0000次,实际是" << g_count << endl;
    19 }

    大家可以把原子操作理解成一种:不需要用到互斥量加锁(无锁)计数多线程并发变成方式,加锁后会很慢。

    原子操作:在多线程中不会被打断的程序执行片段,从效率上来说,原子操作要比互斥量的方式效率要高。

    互斥量的加锁一般是针对一个代码段,而原子操作针对的一般都是一个变量,而不是一个代码段。

    原子操作,一般都是指“不可分割的操作”;也就是说这种操作状态要么是完成的,要么是没完成的,不可能出现半完成状态。

    std::atomic来代表原子操作,是个类模板。其实std::atomic使用来封装某个类型的值

     1 using namespace std;
     2 std::atomic<int> g_count = 0; //封装了一个类型为int的 对象(值)
     3  
     4 void mythread1() {
     5     for (int i = 0; i < 1000000; i++) {
     6         g_count++;
     7     }
     8 }
     9  
    10  
    11 int main() {
    12     std::thread t1(mythread1);
    13     std::thread t2(mythread1);
    14     t1.join();
    15     t2.join();
    16     cout << "正常情况下结果应该是200 0000次,实际是" << g_count << endl;
    17 }

    修改代码试试:

     1 using namespace std;
     2 std::atomic<int> g_count = 0; //封装了一个类型为int的 对象(值)
     3  
     4 void mythread1() {
     5     for (int i = 0; i < 1000000; i++) {
     6         g_count = g_count + 1; //虽然g_count使用了原子操作模板,但是这种写法既读又写,
     7                                 //会导致计数错误
     8     }
     9 }
    10  
    11  
    12 int main() {
    13     std::thread t1(mythread1);
    14     std::thread t2(mythread1);
    15     t1.join();
    16     t2.join();
    17     cout << "正常情况下结果应该是200 0000次,实际是" << g_count << endl;
    18 }

     一般atomic原子操作,针对++,--,+=,&=,|=,^=是支持的,其他操作不一定支持。

    使用时要先测试,最好网上验证再使用。

    总结:

    1、原子操作一般用于计数或者统计(累计发送多少个数据包,累计接收到了多少个数据包),多个线程一起统计,这种情况如果不使用原子操作会导致统计发生混乱。用的并不多。

    2、写商业代码时,如果不确定结果的影响,最好自己先写一小段代码调试。或者不要使用。

     

    心之所愿,永不相忘
  • 相关阅读:
    使用 GPUOperator 与 KubeSphere 简化深度学习训练与 GPU 监控
    基于 WeDataSphere Prophecis 与 KubeSphere 构建云原生机器学习平台
    在 Kubernetes Pod 中如何获取客户端的真实 IP
    云原生的 WebAssembly 能取代 Docker 吗?
    KubeSphere 开源 KubeEye:Kubernetes 集群自动巡检工具
    对于 Serverless, DevOps, 多云及边缘可观察性的思考与实践
    终于可以像使用 Docker 一样丝滑地使用 Containerd 了
    你真的理解 Kubernetes 中的 requests 和 limits 吗?
    顶点(vertexs) 图元(primitives) 片元(fragments片断) 像素(pixels)
    GLUT回调函数
  • 原文地址:https://www.cnblogs.com/zgll/p/15305943.html
Copyright © 2011-2022 走看看