C# 中的多线程同步:原子变量、原子操作、内存顺序和可见性
C# 中的多线程同步:原子变量、原子操作、内存顺序和可见性
引言
随着现代计算机系统的发展,多核处理器已经变得非常普遍。在这种环境下,多线程编程成为提高应用程序性能的关键技术之一。然而,多线程编程带来了新的挑战,其中之一就是确保数据在并发访问时的一致性和安全性。本文将探讨 C# 中的多线程同步机制,特别是原子变量、原子操作、内存顺序和可见性,并通过代码示例来演示如何使用这些工具来构建健壮的并发程序。
原子操作与原子变量
在多线程环境中,原子操作是指那些不可中断的操作。这意味着一旦开始执行,该操作就会一直执行到完成,期间不会被其他线程中断。C# 中提供了多种工具来实现原子操作,包括 Interlocked
类和 System.Threading.Atomic
类。
Interlocked
类
Interlocked
类提供了多个静态方法来执行原子操作,这些方法可以确保在多线程环境中对整型变量的操作是原子的。例如,Interlocked.Increment
和 Interlocked.Decrement
可以用于安全地增加或减少共享变量的值。
示例代码
using System;
using System.Threading;class Program
{private static int counter = 0;private static CountDownEvent allDone = new CountDownEvent(5); // 五个线程static void Increment(){for (int i = 0; i < 100000; i++){Interlocked.Increment(ref counter);}allDone.Signal(); // 通知检查线程,本线程已完成递增}static void Check(){allDone.Wait(); // 等待所有线程完成int finalValue = counter;Console.WriteLine($"Final counter value: {finalValue}");// 验证最终值是否等于预期int expectedValue = 5 * 100000; // 五个线程,每个线程递增100000次if (finalValue == expectedValue){Console.WriteLine("Counter incremented correctly.");}else{Console.WriteLine("Counter did not increment correctly.");}}static void Main(string[] args){var threads = new Thread[5];for (int i = 0; i < 5; i++){threads[i] = new Thread(new ThreadStart(Increment));threads[i].Start();}var checkThread = new Thread(new ThreadStart(Check));checkThread.Start();foreach (var thread in threads){thread.Join();}checkThread.Join();}
}
System.Threading.Atomic
类
从 C# 8.0 开始,引入了 System.Threading.Atomic
类,该类提供了原子类型的实现,类似于 C++ 中的 std::atomic
。使用 System.Threading.Atomic
类可以更加方便地处理原子操作。
示例代码
using System;
using System.Threading;class Program
{private static int counter = 0;private static CountDownEvent allDone = new CountDownEvent(5); // 五个线程static void Increment(){for (int i = 0; i < 100000; i++){Interlocked.Increment(ref counter);}allDone.Signal(); // 通知检查线程,本线程已完成递增}static void Check(){allDone.Wait(); // 等待所有线程完成int finalValue = counter;Console.WriteLine($"Final counter value: {finalValue}");// 验证最终值是否等于预期int expectedValue = 5 * 100000; // 五个线程,每个线程递增100000次if (finalValue == expectedValue){Console.WriteLine("Counter incremented correctly.");}else{Console.WriteLine("Counter did not increment correctly.");}}static void Main(string[] args){var threads = new Thread[5];for (int i = 0; i < 5; i++){threads[i] = new Thread(new ThreadStart(Increment));threads[i].Start();}var checkThread = new Thread(new ThreadStart(Check));checkThread.Start();foreach (var thread in threads){thread.Join();}checkThread.Join();}
}
内存顺序和可见性
在多线程环境中,内存顺序和可见性是非常重要的概念。内存顺序指的是内存操作的顺序,而可见性则确保一个线程对共享数据的修改对其他线程可见。
内存顺序
内存顺序决定了内存操作的执行顺序,这对于确保数据的一致性至关重要。在 C# 中,Interlocked
类提供了不同的内存顺序选项,如 MemoryOrderRelease
、MemoryOrderAcquire
、MemoryOrderSeqCst
等。
示例代码
using System;
using System.Threading;class Program
{private static int flag = 0;private static int counter = 0;static void Writer(){Interlocked.Exchange(ref flag, 1, MemoryOrder.Release); // 设置 flagInterlocked.Exchange(ref counter, 42, MemoryOrder.Release); // 设置 counter}static void Reader(){while (Interlocked.CompareExchange(ref flag, 0, 1, MemoryOrder.Acquire) != 1){Thread.Yield(); // 使当前线程放弃执行权}Console.WriteLine("Counter value: " + Interlocked.Exchange(ref counter, 0, MemoryOrder.Acquire));}static void Main(string[] args){var writerThread = new Thread(Writer);var readerThread = new Thread(Reader);writerThread.Start();readerThread.Start();writerThread.Join();readerThread.Join();Console.WriteLine("Final counter value: " + counter);}
}
内存可见性
内存可见性确保一个线程对共享数据的修改对其他线程可见。在 C# 中,使用 volatile
关键字可以标记一个变量,确保编译器不会对该变量进行优化,从而保证在多线程环境中的内存可见性。但是,volatile
本身并不提供原子性,仅保证内存可见性。
示例代码
using System;
using System.Threading;class Program
{private static volatile bool flag = false;private static int counter = 0;static void Writer(){flag = true;counter = 42;}static void Reader(){while (!flag){Thread.Yield(); // 使当前线程放弃执行权}Console.WriteLine("Counter value: " + counter);}static void Main(string[] args){var writerThread = new Thread(Writer);var readerThread = new Thread(Reader);writerThread.Start();readerThread.Start();writerThread.Join();readerThread.Join();Console.WriteLine("Final counter value: " + counter);}
}
结论
多线程编程需要仔细考虑数据的一致性和同步问题。C# 提供了多种工具来帮助开发者构建健壮的并发程序,包括 Interlocked
类、System.Threading.Atomic
类以及 volatile
关键字。通过合理使用这些工具,可以有效地避免数据竞争和其他并发问题,确保程序的正确性和高效性。
通过上述示例和解释,我们看到了如何在 C# 中使用原子变量、原子操作、内存顺序和可见性来构建可靠的多线程应用程序。希望这篇文章能帮助你在开发并发程序时更好地理解和运用这些概念。
相关文章:
C# 中的多线程同步:原子变量、原子操作、内存顺序和可见性
C# 中的多线程同步:原子变量、原子操作、内存顺序和可见性 引言 随着现代计算机系统的发展,多核处理器已经变得非常普遍。在这种环境下,多线程编程成为提高应用程序性能的关键技术之一。然而,多线程编程带来了新的挑战ÿ…...

视图(mysql)
一、什么是视图 视图是⼀个虚拟的表,它是基于⼀个或多个基本表或其他视图的查询结果集。视图本⾝不存储数 据,⽽是通过执⾏查询来动态⽣成数据。⽤⼾可以像操作普通表⼀样使⽤视图进⾏查询、更新和管 理。视图本⾝并不占⽤物理存储空间,它仅…...

elementui组件el-upload实现批量文件上传
el-upload组件上传文件时,每传一个文件会调一次接口,所以当上传多个文件的时候,有 n 个文件就要调 n 次接口。 刚好之前工作中遇到使用el-upload组件批量上传文件的需求,来看看怎么实现。 思路: 1.取消组件的自动上…...

【JAVA入门】Day45 - 压缩流 / 解压缩流
【JAVA入门】Day45 - 压缩流 / 解压缩流 文章目录 【JAVA入门】Day45 - 压缩流 / 解压缩流一、解压缩流二、压缩流 在文件传输过程中,文件体积比较大,传输较慢,因此我们发明了一种方法,把文件里的数据压缩到一种压缩文件中&#x…...

Qt_自定义信号
目录 1、自定义信号的规定 2、创建自定义信号 3、带参数的信号与槽 4、一个信号连接多个槽 5、信号与槽的断开 结语 前言: 虽然Qt已经内置了大量的信号,并且这些信号能够满足大部分的开发场景,但是Qt仍然允许开发者自定义信号&#…...

【运维方案】某系统运维需求方案参考(doc全原件2024)
系统运维需求方案 1服务目标 2服务人力需求、服务资源需求 3信息资产统计服务需求 4业务应用软件服务需求 5网络、安全系统运维服务需求 6主机、存储系统运维服务需求 7数据库系统运维服务需求 8终端运维服务需求 9综合布线系统服务需求 10大屏幕显示系统的维护需求 11视频会议…...

Linux环境使用Git同步教程
📖 前言:由于CentOS 7已于2024年06月30日停止维护,为了避免操作系统停止维护带来的影响,我们将把系统更换为Ubuntu并迁移数据,在此之前简要的学习Git的上传下载操作。 目录 🕒 1. 连接🕘 1.1 配…...
c++临时对象导致的生命周期问题
对象的生命周期是c中非常重要的概念,它直接决定了你的程序是否正确以及是否存在安全问题。 今天要说的临时变量导致的生命周期问题是非常常见的,很多时候没有一定经验甚至没法识别出来。光是我自己写、review、回答别人的问题就犯了或者看到了许许多多这…...
CSP-J 算法基础 深度优先搜索
文章目录 前言深度优先搜索通俗解释例子深度优先搜索的步骤DFS 的特点生活中的类比 为什么递归问题会变成深度优先搜索?递归与深度优先搜索的关系:递归与系统栈递归调用的过程:栈的作用: 递归与系统栈的简单示例递归实现 DFS 的简…...
LeetCode题练习与总结:基本计算器 Ⅱ--227
一、题目描述 给你一个字符串表达式 s ,请你实现一个基本计算器来计算并返回它的值。 整数除法仅保留整数部分。 你可以假设给定的表达式总是有效的。所有中间结果将在 [-2^31, 2^31 - 1] 的范围内。 注意:不允许使用任何将字符串作为数学表达式计算…...

Elasticsearch基础(七):Logstash如何开启死信队列
文章目录 Logstash如何开启死信队列 一、确保 Elasticsearch 输出插件启用 DLQ 支持 二、配置 Logstash DLQ 设置 三、查看死信队列 四、排查 CSV 到 Elasticsearch 数据量不一致的问题 Logstash如何开启死信队列 在 Logstash 中,死信队列(Dead Le…...
c语言--力扣简单题目(链表的中间节点)讲解
题目如下: 给你单链表的头结点 head ,请你找出并返回链表的中间结点。 如果有两个中间结点,则返回第二个中间结点。 示例 1: 输入:head [1,2,3,4,5] 输出:[3,4,5] 解释:链表只有一个中间结点…...
【STM32 Blue Pill编程】-定时器计数模式
定时器计数模式 文章目录 定时器计数模式1、定时器计数模式介绍2、硬件准备及接线3、模块配置3.1 定时器计数模式配置3.2 定时器中断配置3.3 串口配置4、代码实现在本文中,我们将讨论如何在计数器模式下配置 STM32 Blue Pill 定时器模块。 要将定时器用作计数器,我们将其配置…...
【例题】lanqiao1331 二进制中 1 的个数
二进制中 1 的个数 题目描述 给定一个整数 x,输出该数二进制表示中 1 的个数。 例:9 的二进制表示为 1001,有 2 位是 1 ,所以函数返回 2。 输入描述 输入 x (内存空间为 32 位的整数)。 输出描述 第一…...

【论文解读】图像序列识别:CRNN技术在场景文本识别中的应用与突破(附论文地址)
论文地址:https://arxiv.org/pdf/1507.05717 这篇文章的标题是《An End-to-End Trainable Neural Network for Image-based Sequence Recognition and Its Application to Scene Text Recognition》,作者是Baoguang Shi, Xiang Bai和Cong Yao,…...

Vue3+CesiumJS相机定位camera
new Cesium.Camera (scene) 摄像机由位置,方向和视锥台定义。 方向与视图形成正交基准,上和右视图x上单位矢量。 视锥由6个平面定义。每个平面都由 Cartesian4 对象表示,其中x,y和z分量定义垂直于平面的单位矢量,w分量…...
turbo译码算法MAX, MAX_SCALE and MAX_STAR的比较
在Turbo码的译码算法中,MAX、MAX_SCALE和MAX_STAR是涉及对数似然比(LLR)计算时,对MAP(最大后验概率)算法或其变种Log-MAP算法中分支度量计算的几种不同处理方式。下面是对这三种方法的比较: 1.…...
关于HarmonyOS的学习
day31 购物车案例 一、加入购物车 1、点击按钮后,把当前这个列表的数据拿到,应该存储到一个数组里面 --- 数据结构,把数据存储进行数组2、假如已经把所有的数据添加数组完毕,最终应该存储进购物车里面,所谓的购物车说…...

【雅特力AT32】搭建模板工程及GPIO点灯操作
目录 AT32模板工程建立及点灯操作 建立AT32模板工程 AT32点灯操作 LED原理图GPIO寄存器LED源码分析 建立AT32模板工程 从0到编译运行详细搭建保姆教程: 【雅特力AT32】Keil 环境:搭建标准库模板工程、使用 AT-Link、Debug 里选择 CMSIS-DAP调试器 下面做…...

实战千问2大模型第三天——Qwen2-VL-7B(多模态)视频检测和批处理代码测试
画面描述:这个视频中,一位穿着蓝色西装的女性站在室内,背景中可以看到一些装饰品和植物。她双手交叉放在身前,面带微笑,似乎在进行一场演讲或主持活动。她的服装整洁,显得非常专业和自信。 一、简介 阿里通义千问开源新一代视觉语言模型Qwen2-VL。其中,Qwen2-VL-72B在大…...

网络编程(Modbus进阶)
思维导图 Modbus RTU(先学一点理论) 概念 Modbus RTU 是工业自动化领域 最广泛应用的串行通信协议,由 Modicon 公司(现施耐德电气)于 1979 年推出。它以 高效率、强健性、易实现的特点成为工业控制系统的通信标准。 包…...

深入浅出Asp.Net Core MVC应用开发系列-AspNetCore中的日志记录
ASP.NET Core 是一个跨平台的开源框架,用于在 Windows、macOS 或 Linux 上生成基于云的新式 Web 应用。 ASP.NET Core 中的日志记录 .NET 通过 ILogger API 支持高性能结构化日志记录,以帮助监视应用程序行为和诊断问题。 可以通过配置不同的记录提供程…...
应用升级/灾备测试时使用guarantee 闪回点迅速回退
1.场景 应用要升级,当升级失败时,数据库回退到升级前. 要测试系统,测试完成后,数据库要回退到测试前。 相对于RMAN恢复需要很长时间, 数据库闪回只需要几分钟。 2.技术实现 数据库设置 2个db_recovery参数 创建guarantee闪回点,不需要开启数据库闪回。…...

8k长序列建模,蛋白质语言模型Prot42仅利用目标蛋白序列即可生成高亲和力结合剂
蛋白质结合剂(如抗体、抑制肽)在疾病诊断、成像分析及靶向药物递送等关键场景中发挥着不可替代的作用。传统上,高特异性蛋白质结合剂的开发高度依赖噬菌体展示、定向进化等实验技术,但这类方法普遍面临资源消耗巨大、研发周期冗长…...

UE5 学习系列(三)创建和移动物体
这篇博客是该系列的第三篇,是在之前两篇博客的基础上展开,主要介绍如何在操作界面中创建和拖动物体,这篇博客跟随的视频链接如下: B 站视频:s03-创建和移动物体 如果你不打算开之前的博客并且对UE5 比较熟的话按照以…...

STM32F4基本定时器使用和原理详解
STM32F4基本定时器使用和原理详解 前言如何确定定时器挂载在哪条时钟线上配置及使用方法参数配置PrescalerCounter ModeCounter Periodauto-reload preloadTrigger Event Selection 中断配置生成的代码及使用方法初始化代码基本定时器触发DCA或者ADC的代码讲解中断代码定时启动…...

抖音增长新引擎:品融电商,一站式全案代运营领跑者
抖音增长新引擎:品融电商,一站式全案代运营领跑者 在抖音这个日活超7亿的流量汪洋中,品牌如何破浪前行?自建团队成本高、效果难控;碎片化运营又难成合力——这正是许多企业面临的增长困局。品融电商以「抖音全案代运营…...

如何在看板中有效管理突发紧急任务
在看板中有效管理突发紧急任务需要:设立专门的紧急任务通道、重新调整任务优先级、保持适度的WIP(Work-in-Progress)弹性、优化任务处理流程、提高团队应对突发情况的敏捷性。其中,设立专门的紧急任务通道尤为重要,这能…...

Nuxt.js 中的路由配置详解
Nuxt.js 通过其内置的路由系统简化了应用的路由配置,使得开发者可以轻松地管理页面导航和 URL 结构。路由配置主要涉及页面组件的组织、动态路由的设置以及路由元信息的配置。 自动路由生成 Nuxt.js 会根据 pages 目录下的文件结构自动生成路由配置。每个文件都会对…...
Neo4j 集群管理:原理、技术与最佳实践深度解析
Neo4j 的集群技术是其企业级高可用性、可扩展性和容错能力的核心。通过深入分析官方文档,本文将系统阐述其集群管理的核心原理、关键技术、实用技巧和行业最佳实践。 Neo4j 的 Causal Clustering 架构提供了一个强大而灵活的基石,用于构建高可用、可扩展且一致的图数据库服务…...