C#vb.net中Interlocked类实现原子操作加减计算,涵盖状态切换、计数控制等常见场景

以下是 C# 中使用 int 类型结合 Interlocked 类实现原子操作的完整示例,涵盖状态切换、计数控制等常见场景:

完整代码示例csharp

using System;
using System.Threading;/// <summary>
/// 基于整数类型的原子操作工具类(线程安全)
/// 适用于开关状态控制、计数器等场景
/// </summary>
public static class AtomicStateManager
{// 核心状态变量:用整数表示不同状态// 示例场景:0=关闭(False),1=开启(True);也可扩展为多状态(如0=未初始化,1=运行中,2=已停止)private static int _state = 0; #region 基础状态控制(开关场景)/// <summary>/// 原子设置状态为“开启”(对应值1)/// </summary>public static void Enable(){// 直接将状态设为1,无视当前值(原子操作)Interlocked.Exchange(ref _state, 1);}/// <summary>/// 原子设置状态为“关闭”(对应值0)/// </summary>public static void Disable(){// 直接将状态设为0,无视当前值(原子操作)Interlocked.Exchange(ref _state, 0);}/// <summary>/// 原子切换状态(0→1 或 1→0)/// </summary>public static void Toggle(){// 循环尝试切换,直到成功(处理并发冲突)do{int currentState = _state; // 读取当前状态int newState = currentState == 1 ? 0 : 1; // 计算目标状态// 比较并交换:如果当前值仍为currentState,则更新为newState// 若交换失败(返回值≠currentState),则重试} while (Interlocked.CompareExchange(ref _state, newState, _state) != _state);}/// <summary>/// 原子读取当前状态是否为“开启”/// </summary>/// <returns>True=开启(1),False=关闭(0)</returns>public static bool IsEnabled(){// 用CompareExchange确保读取到最新值(避免CPU缓存导致的脏读)return Interlocked.CompareExchange(ref _state, 0, 0) == 1;}#endregion#region 计数器场景(原子增减)/// <summary>/// 原子递增状态值(+1)/// </summary>/// <returns>递增后的新值</returns>public static int Increment(){return Interlocked.Increment(ref _state);}/// <summary>/// 原子递减状态值(-1)/// </summary>/// <returns>递减后的新值</returns>public static int Decrement(){return Interlocked.Decrement(ref _state);}/// <summary>/// 原子读取当前计数值/// </summary>/// <returns>当前状态值</returns>public static int GetCount(){return Interlocked.CompareExchange(ref _state, 0, 0);}#endregion#region 高级场景:条件更新(仅当满足条件时修改)/// <summary>/// 仅当当前状态为“关闭”时,原子设置为“开启”/// </summary>/// <returns>True=更新成功,False=当前状态不满足条件</returns>public static bool EnableIfDisabled(){// 比较并交换:若当前值为0(关闭),则更新为1(开启)int originalValue = Interlocked.CompareExchange(ref _state, 1, 0);return originalValue == 0; // 若原始值为0,说明更新成功}/// <summary>/// 仅当当前状态为目标值时,原子更新为新值/// </summary>/// <param name="expectedValue">预期当前值</param>/// <param name="newValue">目标新值</param>/// <returns>True=更新成功,False=当前值不符预期</returns>public static bool UpdateIfMatch(int expectedValue, int newValue){int originalValue = Interlocked.CompareExchange(ref _state, newValue, expectedValue);return originalValue == expectedValue;}#endregion
}

使用示例csharp

class Program
{static void Main(){// 1. 开关状态场景AtomicStateManager.Enable();Console.WriteLine($"是否开启:{AtomicStateManager.IsEnabled()}"); // 输出:TrueAtomicStateManager.Toggle();Console.WriteLine($"切换后是否开启:{AtomicStateManager.IsEnabled()}"); // 输出:Falsebool updateSuccess = AtomicStateManager.EnableIfDisabled();Console.WriteLine($"是否成功开启:{updateSuccess}"); // 输出:TrueConsole.WriteLine($"当前状态:{AtomicStateManager.IsEnabled()}"); // 输出:True// 2. 计数器场景AtomicStateManager.Increment(); // 状态从1→2AtomicStateManager.Increment(); // 状态从2→3Console.WriteLine($"当前计数:{AtomicStateManager.GetCount()}"); // 输出:3AtomicStateManager.Decrement(); // 状态从3→2Console.WriteLine($"递减后计数:{AtomicStateManager.GetCount()}"); // 输出:2// 3. 条件更新场景bool conditionUpdate = AtomicStateManager.UpdateIfMatch(2, 100);Console.WriteLine($"条件更新是否成功:{conditionUpdate}"); // 输出:TrueConsole.WriteLine($"更新后的值:{AtomicStateManager.GetCount()}"); // 输出:100}
}

核心原理与优势

  1. 原子性保证
    Interlocked 类的方法通过底层硬件指令实现原子操作,确保操作过程不会被其他线程打断,避免竞态条件。

  2. 性能优化
    相比 lock 等锁机制,Interlocked 操作无需上下文切换,开销更小,适合高频访问场景。

  3. 可见性保证
    所有 Interlocked 操作会强制刷新 CPU 缓存,确保所有线程看到的是最新值,避免因缓存导致的数据不一致。

  4. 灵活性扩展
    示例中用 0 和 1 表示开关状态,实际可扩展为多状态(如 0=未初始化1=运行中2=已停止),通过 UpdateIfMatch 方法实现复杂状态转换。

这种方式特别适合 IIS 等多线程环境下的全局变量控制,可有效避免并发修改导致的异常。


VB.NET的用法例子:

将布尔值转换为整数类型(如 Integer)后使用 Interlocked 类的原子操作(如递增、递减、比较交换),在多线程场景中会更直观且高效。这种方式特别适合需要 "开关状态切换" 或 "计数控制" 的场景。

以下是 VB.NET 中基于整数类型的原子操作实现,以 GetServerInfo 的状态控制为例:

实现示例:VB.NET 用整数类型模拟状态,结合原子操作

vb

Imports System.Threading' 用整数表示状态:0=关闭(False),1=开启(True)
Private Shared _serverInfoState As Integer = 0 ' 初始状态:关闭' 原子开启(设置为1)
Public Sub EnableServerInfo()Interlocked.Exchange(_serverInfoState, 1)
End Sub' 原子关闭(设置为0)
Public Sub DisableServerInfo()Interlocked.Exchange(_serverInfoState, 0)
End Sub' 原子切换状态(0→1 或 1→0)
Public Sub ToggleServerInfo()' 循环尝试切换,直到成功(处理并发冲突)DoDim currentState = _serverInfoStateDim newState = If(currentState = 1, 0, 1)' 比较并交换:如果当前值仍为 currentState,则更新为 newStateLoop While Interlocked.CompareExchange(_serverInfoState, newState, currentState) <> currentState
End Sub' 原子读取当前状态
Public Function IsServerInfoEnabled() As Boolean' 读取操作本身是原子的,但用 CompareExchange 确保可见性Return Interlocked.CompareExchange(_serverInfoState, 0, 0) = 1
End Function' 原子递增(适合计数场景)
Public Sub IncrementCounter()Interlocked.Increment(_serverInfoState)
End Sub' 原子递减(适合计数场景)
Public Sub DecrementCounter()Interlocked.Decrement(_serverInfoState)
End Sub

优势说明

  1. 操作直观
    用 0 和 1 对应 False 和 True,通过 Interlocked.Increment/Decrement 可直接实现计数,无需额外转换逻辑。

  2. 性能优异
    Interlocked 类的方法是底层硬件支持的原子操作,比 SyncLock 等锁机制开销更小,尤其适合高频访问的场景。

  3. 避免竞态条件

    • Exchange 确保 "设置新值" 操作的原子性,不会被其他线程打断。
    • CompareExchange 结合循环可实现 "检查 - 更新" 的原子性(如 ToggleServerInfo 方法),避免并发下的状态不一致。
  4. 可见性保证
    Interlocked 操作会强制刷新 CPU 缓存,确保所有线程看到的是最新值(避免因缓存导致的 "脏读")。

适用场景

  • 简单的开关状态(如 GetServerInfo 的启用 / 禁用)。
  • 计数器(如统计并发请求数、操作次数)。
  • 需要原子 "检查并修改" 的逻辑(如仅当状态为关闭时才开启)。

如果你的场景涉及更复杂的状态转换(如多值状态),这种整数映射方式同样适用,只需扩展数值对应的含义即可(如 0=未初始化1=运行中2=已停止)。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.pswp.cn/web/93088.shtml
繁体地址,请注明出处:http://hk.pswp.cn/web/93088.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

RCL 2025 | LLM采样机制的新视角:来自处方性偏移的解释

1. 导读 大型语言模型&#xff08;Large Language Models, LLMs&#xff09;在自主决策场景中的应用日益广泛&#xff0c;它们需要在庞大的行动空间中进行响应采样&#xff08;response sampling&#xff09;。然而&#xff0c;驱动这一采样过程的启发式机制仍缺乏深入研究。本…

08 ABP Framework Blazor UI

ABP Framework Blazor UI 架构 overview ABP Blazor UI 系统构建在 Blazorise 组件库之上&#xff0c;为构建数据驱动应用提供结构化方法&#xff0c;包含 CRUD 操作、主题和本地化的一致模式。 #mermaid-svg-QAvWlELsLhZgYXHu {font-family:"trebuchet ms",verdana,…

JUC学习笔记-----LinkedBlockingQueueConcurrentLinkedQueueCopyOnWriteArrayList

LinkedBlockingQueue基本的入队出队初始化public class LinkedBlockingQueue<E> extends AbstractQueue<E>implements BlockingQueue<E>, java.io.Serializable {// 静态内部类 Node&#xff0c;用于存储队列元素及维护节点间关系static class Node<E>…

小杰python高级(six day)——pandas库

1.数据可视化用于绘制 DataFrame 数据图形&#xff0c;它允许用户直接从 DataFrame 创建各种类型的图表&#xff0c;而不需要使用其他绘图库&#xff08;底层实际上使用了 Matplotlib&#xff09;。&#xff08;1&#xff09;plotDataFrame.plot(*args, **kwargs)功能&#xff…

第十六届蓝桥杯青少组C++省赛[2025.8.9]第二部分编程题(1 、庆典队列)

参考程序&#xff1a;#include <iostream> using namespace std;int main() {int n, A;cin >> n >> A; // 输入&#xff1a;n 和 A&#xff0c;用空格隔开cout << n / A; // 整数相除&#xff0c;自动向下取整return 0; }

C++进阶:智能指针

目录1. RAII与智能指针2. C库中的智能指针2.1 智能指针auto_ptr2.2 智能指针unique_ptr2.3 智能指针shared_ptr3. shared_ptr的循环引用4. 智能指针的定值删除器1. RAII与智能指针 上一篇文章学习了异常相关的知识&#xff0c;其中遗留了一个异常安全相关的问题。那就是异常的抛…

Tkinter 实现按钮鼠标悬浮提示:两种方案(继承Frame与不继承)

在 Tkinter 桌面应用开发中&#xff0c;为按钮添加“鼠标悬浮提示”是提升用户体验的常用功能——无需点击&#xff0c;只需将鼠标挪到按钮上方&#xff0c;就能自动显示按钮功能说明。本文将详细介绍两种实现方案&#xff1a;不继承 Frame 类&#xff08;快速简洁版&#xff0…

20250814 最小生成树总结

引子 啊啊额&#xff0c;从一张图里抽出几条边&#xff0c;组成一棵树&#xff0c;无环n−1n-1n−1条边&#xff0c;就是生成树。那么边权和最小的生成树就叫最小生成树&#xff0c;最大生成树同理。 kruskal最小生成树 要求kruskal最小生成树&#xff0c;我们首先用结构体数组…

数据大集网:实体店获客引流的数字化引擎,解锁精准拓客新密码​

​在实体店面临流量焦虑、获客成本攀升的当下&#xff0c;实体店获客引流工具的重要性愈发凸显。如何在激烈的市场竞争中精准触达目标客户、构建可持续的客流增长模式&#xff1f;数据大集网凭借其创新的智能获客体系与全链路服务能力&#xff0c;正成为万千实体店突破增长瓶颈…

nginx --ssl证书生成mkcert

github https://github.com/FiloSottile/mkcert/releases网盘下载地址 https://pan.baidu.com/s/1XI0879pqu7HXZMnmQ9ztaw 提取码: 1111windows使用示例

守拙以致远:个人IP的长青之道|创客匠人

2025年被认为是AI应用全面爆发的一年。各种人工智能工具在写作、制图、剪辑等领域广泛使用&#xff0c;大大提升了个人和团队的工作效率。对于个人IP而言&#xff0c;这类工具的出现确实带来了新的机会&#xff0c;但也伴随着一种现象——一些人开始过度依赖甚至神化AI&#xf…

USB 3.0 LTSSM 状态机

USB2.0在电源供应后&#xff0c;通过Pull Up D-来决定枚举LS&#xff0c;Pull Up D有一个USB高速握手过程&#xff0c;来决定HS FS。USB3.0则会通过链路训练&#xff08;Link Training&#xff09;&#xff0c;来准备USB3.0通信。每当我们插上USB线的时候&#xff0c;对于3.0的…

MySQL窗口函数与PyMySQL以及SQL注入

MySQL窗口函数与PyMySQL实战指南&#xff1a;从基础到安全编程 引言 在数据处理和分析领域&#xff0c;MySQL作为最流行的关系型数据库之一&#xff0c;其窗口函数功能为数据分析提供了强大的支持。同时&#xff0c;Python作为数据分析的主要语言&#xff0c;通过PyMySQL库与My…

高级项目——基于FPGA的串行FIR滤波器

给大家安利一个 AI 学习神站&#xff01;在这个 AI 卷成红海的时代&#xff0c;甭管你是硬核开发者还是代码小白&#xff0c;啃透 AI 技能树都是刚需。这站牛逼之处在于&#xff1a;全程用 "变量名式" 幽默 生活化类比拆解 AI&#xff0c;从入门到入土&#xff08;啊…

JPrint免费的Web静默打印控件:PDF打印中文乱码异常解决方案

文章目录JPrint是什么&#xff1f;中文乱码&#xff08;Using fallback font xxx for xxxx&#xff09;1.字体嵌入2.客户机字体安装开源地址相关目录导航使用文档端口号修改代理使用场景打印服务切换中文乱码解决方案 JPrint是什么&#xff1f; JPrint是一个免费开源的可视化静…

MFT 在零售行业的实践案例与场景:加速文件集成与业务协作的高效方案

零售行业竞争激烈、数字化转型迭代迅速&#xff0c;业务对数据与档案的传输、处理和整合要求极高。无论是新品上市市场数据&#xff0c;还是供应链物流单据&#xff0c;集成方式不论是通过API或是档案传输, 对于传输的稳定性,安全性与性能, 都会直接影响决策效率与顾客体验。MF…

OSG+Qt —— 笔记1 - Qt窗口加载模型(附源码)

🔔 OSG/OsgEarth 相关技术、疑难杂症文章合集(掌握后可自封大侠 ⓿_⓿)(记得收藏,持续更新中…) OSG+Qt所用版本皆为: Vs2017+Qt5.12.4+Osg3.6.5+OsgQt(master) 效果 代码(需将cow.osg、reflect.rgb拷贝至工程目录下) OsgForQt.ui main.cpp

开源安全云盘存储:Hoodik 实现端到端数据加密,Docker快速搭建

以下是对 Hoodik 的简单介绍&#xff1a; Hoodik 是一个使用 Rust 和 Vue 开发的轻量级自托管安全云存储解决方案采用了非对称RSA密钥对和AES混合加密策略&#xff0c;从文件存储加密到数据链路加密&#xff0c;全程保证数据安全支持Docker一键私有部署&#xff0c;数据和服务…

[C++] Git 使用教程(从入门到常用操作)

1. Git 简介 Git 是一款分布式版本控制系统&#xff0c;用来跟踪文件变化、协作开发、管理项目版本。 它是开源的&#xff0c;由 Linus Torvalds 在 2005 年开发&#xff0c;广泛用于开源与企业项目中。 2. 安装 Git Windows 前往 Git 官网 下载并安装。 安装时建议勾选 Git…

实盘回测一体的期货策略开发:tqsdk获取历史数据并回测,附python代码

原创内容第969篇&#xff0c;专注AGI&#xff0c;AI量化投资、个人成长与财富自由。 星球好多同学希望说说实盘&#xff0c;我们就从实盘开始吧。 我们选择tqsdk给大家讲解&#xff0c;tqsdk支持免费注册&#xff0c;使用模拟账户&#xff0c;历史和实时数据&#xff0c;方便…