C# 多线程二:Interlocked 互锁的理解和简单示例

news/2024/7/6 1:45:55

一.多线程的线程安全

多线程安全问题原因是在cpu执行多线程时,在执行的过程中可能随时切换到其他的线程上执行,当多个线程同时操作同一个变量时,如果不施加其他措施,可能导致错误数据的出现

二.Interlocked的特点

Interlocked是为多个线程共享的变量提供原子操作,这个类是一个静态类 它提供了以线程安全的方式递增、递减、交换和读取值的方法。

它的特点是:
(1)、相对于其他线程同步技术,速度会快很多。(它的原子操作是基于CPU本身的,非阻塞的,所以要比lock的效率高。)


(2)、只能用于简单的同步问题。(数学运算操作仅限于Increment、Decrement以及Add)

三.什么是原子操作

 如果一条语句在底层处理器上被当作一个独立不可分割的指令,那么它本质上是原子的(atomic)。严格的原子性可以阻止任何抢占的可能对于 32 位(或更低)的字段的简单读写总是原子的
      而操作 64 位字段仅在 64 位运行时环境下是原子的,并且结合了多个读写操作的语句必然不是原子的.

 32位和64位代表cpu一次处理数据的能力是32位还是64位,由前一章我们所理解的多线程的运行原理 可以轻易的得出当32位机器操作64位字段,如果此时发生了时间片轮询,则此时对64位的操作就不是原子操作

四.Interlocked的方法和作用

Interlocked的方法和作用
方法作用
CompareExchange()安全比较两个值是不是相等。如果相等,将第三个值于其中一个值交换
Decrement()安全递减1,相当于 i--
Exchange()安全交换:把值2赋给值1;返回新值
Increment()安全递加1,相当于 i++
Add()安全相加一个数值,相当于 a = a + 3
Read()安全读取数值,相等于int a=b

五.Interlocked的简单使用

1.不使用Interlocked

代码:

public class LudwigInterlocked {

    string persion;

    public LudwigInterlocked() {
        persion = "没人啊?";
    }
    public void AddPersion(string name) {
        persion = name;
    }

    public string SubPersion() {
        return persion;
    }
}

class Program {
    static string[] names = new string[] { "小明", "小话", "小雅", "小斌", "小头"};
    static void Main(string[] args) {
        LudwigInterlocked ludwigInterlocked = new LudwigInterlocked();
        ThreadStart threadStart = new ThreadStart(() => {
            for(int i = 0; i < names.Length; i++) {
                ludwigInterlocked.AddPersion(names[i]);
                Thread.Sleep(10);
            }
        });
        Thread thread = new Thread(threadStart);
        thread.Start();
        Thread.Sleep(10);
        Thread thread1 = new Thread(() => {
            for(int i = 0; i < names.Length; i++) {
                string name = ludwigInterlocked.SubPersion();
                if(!string.IsNullOrEmpty(name)) {
                    Console.WriteLine(name);
                    Thread.Sleep(10);
                }
            }
        });
        thread1.Start();

        Console.Read();
    }
}

 打印:

我们发现当两个线程同时操作同一个变量时,出现了我们不想要的结果。

2.使用Interlocked

 代码:

public class LudwigInterlocked {

    string persion;
    long index;
    public LudwigInterlocked() {
        persion = "没人啊?";
    }
    public void AddPersion(string name) {
        while(Interlocked.Read(ref index) == 1) {
            Thread.Sleep(10);
        }
        Interlocked.Increment(ref index);
        persion = name;
    }

    public string SubPersion() {
        while(Interlocked.Read(ref index) == 0) {
            Thread.Sleep(10);
        }
        Interlocked.Decrement(ref index);
        return persion;
    }
}
class Program {
    static string[] names = new string[] { "小明", "小话", "小雅", "小斌", "小头"};
    static void Main(string[] args) {
        LudwigInterlocked ludwigInterlocked = new LudwigInterlocked();
        ThreadStart threadStart = new ThreadStart(() => {
            for(int i = 0; i < names.Length; i++) {
                ludwigInterlocked.AddPersion(names[i]);
                Thread.Sleep(10);
            }
        });
        Thread thread = new Thread(threadStart);
        thread.Start();
        Thread.Sleep(10);
        Thread thread1 = new Thread(() => {
            for(int i = 0; i < names.Length; i++) {
                string name = ludwigInterlocked.SubPersion();
                if(!string.IsNullOrEmpty(name)) {
                    Console.WriteLine(name);
                    Thread.Sleep(10);
                }
            }
        });
        thread1.Start();

        Console.Read();
    }
}

打印:

利用Interlocked达到了我们想要的效果,这个例子中的index使用了Interlocked 进行操作,虽然被多个线程操作,仍然不会出现线程安全的问题。


http://lihuaxi.xjx100.cn/news/49763.html

相关文章

JavaWeb - 15 异步请求 Ajax axios

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录1.同步请求与异步请求1.1 同步请求1.2 异步请求2. Ajax发送异步请求2.1 Ajax概述2.2 原生JS实现AJAX详解2.3 代码码演示3. axios框架3.1 axios概述3.2 安装方式3.3 快…

【Linux从0到1】第十七篇:高级IO

文章目录一、五种IO模型二、高级IO重要概念2.1 同步通信 vs 异步通信(synchronous communication/ asynchronouscommunication)2.2 阻塞 vs 非阻塞2.3 其他高级IO2.4 非阻塞IO2.5 I/O多路转接之select2.6 I/O多路转接之poll [选学]2.7 I/O多路转接之epoll一、五种IO模型 阻塞IO…

SpringMVC处理Ajax请求及处理和响应json格式的数据

在SpringMVC中处理Ajax的请求可以用到RequestBody与ResponseBody注解实现 1.RequestBody:将请求体中的内容和控制器方法的形参进行绑定 2.使用RequestBody注解将json格式的请求参数转换程Java对象&#xff08;三个步骤&#xff09; a>导入Jackson的依赖 b>在SpringMVC的…

Redis从入门到精通(一)

Redis 一、Redis安装和概述 1.1、概述 Redis是什么&#xff1f; Redis&#xff08;Remote Dictionary Server )&#xff0c;即远程字典服务&#xff0c; Redis是一个开源的key-value存储系统&#xff0c;当下最热门的NoSQL 技术之一。 1.2、安装 1.把redis-6.2.6.tar.gz上…

HTML+CSS+JS520告白表白模板在线制作(七夕情人节表白网页代码)

❤ 精彩专栏推荐&#x1f447;&#x1f3fb;&#x1f447;&#x1f3fb;&#x1f447;&#x1f3fb; &#x1f482; 作者主页: 【进入主页—&#x1f680;获取更多源码】 &#x1f393; web前端期末大作业&#xff1a; 【&#x1f4da;HTML5网页期末作业 (1000套) 】 &#x1…

TiDB Dashboard 常见问题

本文汇总了使用 TiDB Dashboard 过程中的常见问题与解决办法。若无法找到对应问题&#xff0c;或者根据指引操作后问题仍然存在&#xff0c;请联系 PingCAP 技术支持获取帮助。 访问 已配置防火墙或反向代理&#xff0c;但访问后被跳转到一个内部地址无法访问 TiDB Dashboard…

Spring Boot 集成 Redis 配置 MyBatis 二级缓存

目录写在前面源码获取一、MyBatis缓存机制1.1、一级缓存1.2、二级缓存二、集成Redis2.1、安装Redis2.2、项目引入Redis2.2.1、Maven依赖2.2.2、配置application.yml2.2.3、配置序列化规则三、配置二级缓存2.1、开启二级缓存2.2、自定义缓存类2.3、增加注解2.4、测试验证写在前面…

http协议初探

目的 了解http协议 简介 http协议规定了浏览器和服务器在进行传输数据的时候的数据的格式。 对比tcp http基于tcp tcp&#xff1a;传输层&#xff0c;可靠传输&#xff0c;二进制位 http&#xff1a;应用层&#xff0c;信息使用&#xff0c;文本格式 Web调试工具fillder …