C#对线程同步的应用

news2025/1/5 19:21:19

什么是线程同步?线程同步的应用场景有哪些?在C#中有哪些线程同步方式?下面对这些问题做一个总结,让大家在面试的时候遇到这些问题能够游刃有余。
线程同步是指在多线程环境下,多个线程同时访问共享资源时,确保数据一致性和正确性的一种机制。以下是线程同步的主要应用场景和常用方式,以及每种方式的简单代码示例。


应用场景

  1. 共享资源的保护
  • 多个线程同时读写共享资源时,防止数据竞争和不一致。
  1. 线程间的通信
  • 一个线程等待另一个线程完成某些任务或传递数据。
  1. 避免死锁
  • 多线程并发访问资源时,通过合理设计同步机制,避免资源争用导致的死锁。
  1. 线程协调
  • 控制线程的执行顺序或实现生产者-消费者模式。

线程同步方式与示例

  1. 锁(lock / Monitor)
    用于同步对共享资源的访问,确保同时只有一个线程可以访问资源。
class Program
{
    private static readonly object _lock = new object();
    private static int _counter = 0;

    static void Main()
    {
        Thread t1 = new Thread(IncrementCounter);
        Thread t2 = new Thread(IncrementCounter);

        t1.Start();
        t2.Start();

        t1.Join();
        t2.Join();

        Console.WriteLine($"Final Counter: {_counter}");
    }

    static void IncrementCounter()
    {
        for (int i = 0; i < 1000; i++)
        {
            lock (_lock)
            {
                _counter++;
            }
        }
    }
}


  1. 信号量(Semaphore / SemaphoreSlim)
    用于限制对某些资源的访问线程数。
class Program
{
    private static SemaphoreSlim _semaphore = new SemaphoreSlim(2);

    static void Main()
    {
        for (int i = 1; i <= 5; i++)
        {
            int id = i;
            new Thread(() => AccessResource(id)).Start();
        }
    }

    static void AccessResource(int id)
    {
        Console.WriteLine($"Thread {id} is waiting to enter...");
        _semaphore.Wait();
        Console.WriteLine($"Thread {id} entered.");
        Thread.Sleep(2000); // Simulating work
        Console.WriteLine($"Thread {id} is leaving.");
        _semaphore.Release();
    }
}


  1. 互斥(Mutex)
    用于跨进程同步资源。
class Program
{
    private static Mutex _mutex = new Mutex();

    static void Main()
    {
        for (int i = 1; i <= 3; i++)
        {
            new Thread(AccessResource).Start(i);
        }
    }

    static void AccessResource(object id)
    {
        Console.WriteLine($"Thread {id} waiting for mutex...");
        _mutex.WaitOne();
        Console.WriteLine($"Thread {id} acquired mutex.");
        Thread.Sleep(2000);
        Console.WriteLine($"Thread {id} releasing mutex.");
        _mutex.ReleaseMutex();
    }
}

  1. 手动重置事件(ManualResetEvent)
    允许一个线程通知其他线程可以继续。
class Program
{
    private static ManualResetEvent _mre = new ManualResetEvent(false);

    static void Main()
    {
        new Thread(WaitForSignal).Start();
        Console.WriteLine("Main thread doing work...");
        Thread.Sleep(2000);
        Console.WriteLine("Signal other threads to proceed.");
        _mre.Set();
    }

    static void WaitForSignal()
    {
        Console.WriteLine("Thread waiting for signal...");
        _mre.WaitOne();
        Console.WriteLine("Thread received signal!");
    }
}


  1. 自动重置事件(AutoResetEvent)
    每次调用 Set 后,自动重置为非信号状态。
class Program
{
    private static AutoResetEvent _are = new AutoResetEvent(false);

    static void Main()
    {
        new Thread(WaitForSignal).Start();
        Console.WriteLine("Main thread doing work...");
        Thread.Sleep(2000);
        Console.WriteLine("Signal other thread to proceed.");
        _are.Set();
    }

    static void WaitForSignal()
    {
        Console.WriteLine("Thread waiting for signal...");
        _are.WaitOne();
        Console.WriteLine("Thread received signal!");
    }
}


  1. 信号量栅栏(Barrier)
    允许多个线程到达某个同步点后再继续执行。
class Program
{
    private static Barrier _barrier = new Barrier(3, b => Console.WriteLine("All threads reached barrier."));

    static void Main()
    {
        for (int i = 1; i <= 3; i++)
        {
            new Thread(Work).Start(i);
        }
    }

    static void Work(object id)
    {
        Console.WriteLine($"Thread {id} doing work...");
        Thread.Sleep(new Random().Next(1000, 3000));
        Console.WriteLine($"Thread {id} waiting at barrier.");
        _barrier.SignalAndWait();
        Console.WriteLine($"Thread {id} passed barrier.");
    }
}


  1. 读写锁(ReaderWriterLockSlim)
    提供多个线程的读操作,但写操作是互斥的。
class Program
{
    private static ReaderWriterLockSlim _lock = new ReaderWriterLockSlim();
    private static List<int> _data = new List<int>();

    static void Main()
    {
        new Thread(ReadData).Start();
        new Thread(WriteData).Start();
    }

    static void ReadData()
    {
        _lock.EnterReadLock();
        try
        {
            Console.WriteLine($"Read thread reading data: {string.Join(", ", _data)}");
        }
        finally
        {
            _lock.ExitReadLock();
        }
    }

    static void WriteData()
    {
        _lock.EnterWriteLock();
        try
        {
            _data.Add(new Random().Next(100));
            Console.WriteLine("Write thread updated data.");
        }
        finally
        {
            _lock.ExitWriteLock();
        }
    }
}


以上是常用的线程同步方式及其简单示例代码,您可以根据具体需求选择合适的方式来保证线程安全。希望对大家有所帮助。


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

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

相关文章

【Cocos TypeScript 零基础 4.1】

目录 背景滚动 背景滚动 创建一个 空节点 背景丟进去 ( 复制一个,再丢一次都行) 新建TS脚本 并绑定到 空节点 上 再对TS脚本进行编辑 export class TS2bg extends Component {property (Node) // 通过属性面板去赋值bg1:Node nullproperty (Node) bg2:Node nullprope…

利用 AI 高效生成思维导图的简单实用方法

#工作记录 适用于不支持直接生成思维导图的AI工具&#xff1b;适用于AI生成后不能再次编辑的思维导图。 在日常的学习、工作以及知识整理过程中&#xff0c;思维导图是一种非常实用的工具&#xff0c;能够帮助我们清晰地梳理思路、归纳要点。而借助 AI 的强大能力&#xff0c…

AfuseKt1.4.4 | 刮削视频播放器,支持阿里云盘和自动海报墙

AfuseKt是一款功能强大的安卓端在线视频播放器&#xff0c;广泛兼容多种平台如阿里云盘、Alist、WebDAV、Emby、Jellyfin等&#xff0c;同时也支持本地存储视频文件的播放。其特色功能包括自动抓取影片信息生成海报墙展示&#xff0c;充分利用设备硬件进行高清视频流畅播放&…

Linux下部署ElasticSearch集群

Elasticsearch7.17.8集群的搭建 节点host名称节点ip节点部署内容k8s-m192.168.40.142主节点 数据节点k8s-w1192.168.40.141主节点 数据节点k8s-w2192.168.40.140数据节点 一、准备安装环境 1.下载安装包 官网 www.elastic.co 下载所有版本地址 点击跳转 下载elasticsearch-7.…

covid-vaccine-availability-using-flask-server

使用烧瓶服务器获得 Covid 疫苗 原文:https://www . geesforgeks . org/co vid-疫苗-可用性-使用-烧瓶-服务器/ 在本文中&#xff0c;我们将使用 Flask Server 构建 Covid 疫苗可用性检查器。 我们都知道&#xff0c;整个世界都在遭受疫情病毒的折磨&#xff0c;唯一能帮助我们…

线性变换在机器学习中的应用实例

一、线性变换的基本概念 线性变换是指将一个向量空间中的向量映射到另一个向量空间中的函数&#xff0c;这种映射关系保持向量加法和标量乘法的运算性质。在机器学习中&#xff0c;线性变换通常通过矩阵乘法来实现&#xff0c;其中输入向量被视为列向量&#xff0c;矩阵被视为…

【Linux】传输层协议UDP

目录 再谈端口号 端口号范围划分 UDP协议 UDP协议端格式 UDP的特点 UDP的缓冲区 UDP注意事项 进一步深刻理解 再谈端口号 在上图中&#xff0c;有两个客户端A和B&#xff0c;客户端A打开了两个浏览器&#xff0c;这两个客户端都访问同一个服务器&#xff0c;都访问服务…

大功率PCB设计

1.电源和电机的走线用线径较大的铺铜&#xff0c;讲究的是走线顺畅&#xff1a; 2.同一个电源属性四层板都铺铜&#xff0c;并打很多过孔: 3.走线顺畅&#xff0c;可以看到从左到右供电。从右向左接地&#xff0c;加电流采样&#xff1a; 一个问题&#xff0c;这样会形成电源环…

ArkTs之NAPI学习

1.Node-api组成架构 为了应对日常开发经的网络通信、串口访问、多媒体解码、传感器数据收集等模块&#xff0c;这些模块大多数是使用c接口实现的&#xff0c;arkts侧如果想使用这些能力&#xff0c;就需要使用node-api这样一套接口去桥接c代码。Node-api整体的架构图如下&…

Vue el-data-picker选中开始时间,结束时间自动加半小时

效果 思路 查阅elemnet plus官网&#xff0c;日期时间选择器type"datetimerange"这个选中开始时间并没有对应事件会被触发&#xff0c;因此思路更换成type"datetime"的两个组成一起可以通过监听开始时间v-model的值变化更新结束时间的值。 代码 日期时间…

gitlab高级功能之 CICD Steps

CICD Steps 1. 介绍2. 定义 Steps2.1 Inputs2.2 Outputs 3. Using steps3.1 Set environment variables3.2 Running steps locally 4. Scripts5. Actions5.1 已知的问题 6. 表达式7. 实操7.1 单个step7.2 多个step7.3 复用steps7.4 添加output到step7.5 使用远程step 1. 介绍 …

TVS二极管选型【EMC】

TVS器件并联在电路中&#xff0c;当电路正常工作时&#xff0c;他处于截止状态&#xff08;高阻态&#xff09;&#xff0c;不影响线路正常工作&#xff0c;当线路处于异常过压并达到其击穿电压时&#xff0c;他迅速由高阻态变为低阻态&#xff0c;给瞬间电流提供一个低阻抗导通…

122.【C语言】数据结构之快速排序(Hoare排序的优化)

目录 1.解决方法(即优化方法) 方法1.随机选key 运行结果 方法2:三数取中 1.含义 2.做法 3.代码 1.若arr[left] < arr[mid_i],则arr[right]可能的位置也有三处 2.若arr[left] > arr[mid_i],则arr[right]可能的位置也有三处 2.证明当key_ileft时,right先走,使left…

Golang的容器编排实践

Golang的容器编排实践 一、Golang中的容器编排概述 作为一种高效的编程语言&#xff0c;其在容器编排领域也有着广泛的运用。容器编排是指利用自动化工具对容器化的应用进行部署、管理和扩展的过程&#xff0c;典型的容器编排工具包括Docker Swarm、Kubernetes等。在Golang中&a…

《Spring Framework实战》2:Spring快速入门

欢迎观看《Spring Framework实战》视频教程 Spring快速入门 目录 1. Java™开发套件&#xff08;JDK&#xff09; 2. 集成开发人员环境&#xff08;IDE&#xff09; 3. 安装Maven 4. Spring快速入门 4.1. 开始一个新的Spring Boot项目 4.2. 添加您的代码 4.3. 尝…

HTML——66.单选框

<!DOCTYPE html> <html><head><meta charset"UTF-8"><title>单选框</title></head><body><!--input元素的type属性&#xff1a;(必须要有)--> <!--单选框:&#xff08;如所住省会&#xff0c;性别选择&…

rouyi(前后端分离版本)配置

从gitee上下载&#xff0c;复制下载地址&#xff0c;到 点击Clone&#xff0c;下载完成&#xff0c; 先运行后端&#xff0c;在运行前端 运行后端&#xff1a; 1.配置数据库&#xff0c;在Navicat软件中&#xff0c;连接->mysql->名字自己起(rouyi-vue-blog),用户名roo…

基于云架构Web端的工业MES系统:赋能制造业数字化变革

基于云架构Web端的工业MES系统:赋能制造业数字化变革 在当今数字化浪潮席卷全球的背景下,制造业作为国家经济发展的重要支柱产业,正面临着前所未有的机遇与挑战。市场需求的快速变化、客户个性化定制要求的日益提高以及全球竞争的愈发激烈,都促使制造企业必须寻求更加高效、智…

如何解决电脑提示缺失kernel32.dll文件错误,kernel32.dll文件缺失、损坏或错误加载问题解决方案

电脑运行故障深度解析&#xff1a;从文件丢失到系统报错&#xff0c;全面应对kernel32.dll问题 在数字化时代&#xff0c;电脑已经成为我们日常生活和工作中不可或缺的工具。然而&#xff0c;电脑在长时间运行过程中&#xff0c;难免会遇到各种问题&#xff0c;如文件丢失、文…

leecode300.最长递增子序列

dp[i]表示以nums[i]这个数结尾的时的严格递增子序列的最长长度&#xff0c;那么只要每次增加一个数字nums[i]并且这个nums[i]比之前的nums[j]要大&#xff0c;dp[i]就要更新为dp[i]和dp[j]1二者的最大值&#xff0c;初始化默认最大递增子序列都是1 这里遍历顺序的感觉很像多重…