当前位置：首页 > 编程日记 > 正文

C# 实现单线程异步互斥锁

编程日记 2024-01-19 21:12:09

前言

C#对异步的支持越来越成熟，async、await简化了代码也提高了可读性，但由于在一段上下文中有了异步操作，意味着这段操作可能会被同时重复调用，如果本身没有被设计可以重复调用的情况下，就很可能会出问题。

一、异步互斥锁的作用是什么？

异步互斥锁的作用是用于确保存在异步操作的上下文同步互斥。可以参考flutter的插件mutex功能与本文基本一样。

示例一、创建和销毁

有创建和销毁两个方法，两个方法中都有异步操作，两个方法可以单独调用，但不可以同时调用。
单线程中连续调用创建和销毁（不在同一个上下文无法用await），如果没有互斥限制有可能出现如下的操作：

创建开始->创建异步操作->消息队列->销毁开始->销毁异步操作->消息队列->销毁完成->消息队列->创建完成

加入异步互斥锁之后

加锁->创建开始->创建完成->解锁

加锁等待->销毁开始->销毁完成->解锁

二、如何实现？

由于操作都是在单线程我们直接用标识+队列就可以实现一个互斥锁。

1、标识

（1）标识是否锁住

bool _lock = false;

（2）加锁

_lock=true;

（3）解锁

_lock=false;

2、异步通知

通过TaskCompletionSource可以实现异步通知

（1）创建对象

var tcs = new TaskCompletionSource();

（2）返回Task

return tcs.Task;

（3）通知完成

tcs.SetResult();

3、等待队列

用一个队列来记录等待加锁的请求。

（1）创建队列

Queue<TaskCompletionSource> _queue = new Queue<TaskCompletionSource>();

（2）等待加锁

_queue.Enqueue(tcs);

（3）加锁成功

_queue.Dequeue().SetResult();

三、完整代码

/// <summary>
/// 异步锁，非线程锁，只能用于单线程异步环境中。
/// </summary>
class AsyncMutex
{
    Queue<TaskCompletionSource> _queue = new Queue<TaskCompletionSource>();
    bool _lock = false;
    /// <summary>
    /// 获取锁
    /// </summary>
    /// <returns>返回Task，await后即进入了锁</returns>
    public Task Acquire()
    {
        if (_lock)
        {
            var tcs = new TaskCompletionSource();
            _queue.Enqueue(tcs);
            return tcs.Task;
        }
        _lock = true;
        return Task.CompletedTask;
    }
    /// <summary>
    /// 尝试获取锁
    /// 因为是单线程环境，重复调用需要切换上下文，否则是无法成功的。
    /// 比如可以await Task.Delay(30);
    /// </summary>
    /// <returns>是否成功</returns>
    public bool TryAcquire()
    {
        if (_lock) return false;
        return _lock = true;
    }
    /// <summary>
    /// 释放锁
    /// </summary>
    public void Release()
    {
        if (_queue.Count > 0)
        {
            _queue.Dequeue().SetResult();
        }
        else
        {
            _lock = false;
        }
    }
}

四、使用示例

1、基本用法

直接加锁

AsyncMutex _mtx = new AsyncMutex();
async void test()
{
    await _mtx.Acquire();
    //custom code
    _mtx.Release();
}

2、尝试加锁

加锁成功才执行操作

AsyncMutex _mtx = new AsyncMutex();
void test()
{
    if (_mtx.TryAcquire())
    {
        //custom code
        _mtx.Release();
    }
}

超时等待

AsyncMutex _mtx = new AsyncMutex();
async void test()
{
    //超时等待300ms
    bool isLock = false;
    for (int i = 0; i < 10; i++)
    {
        if (isLock = _mtx.TryAcquire()) break;
        await Task.Delay(30);
    }
    if (isLock)
    {
        //custom code
        _mtx.Release();
    }
}

3、加锁对比

（1）未加锁

async void test(int num)
{
    Console.WriteLine("enter " + num);
    //模拟异步操作
    await Task.Delay(10);
    Console.WriteLine("exit " + num);
}
//.net 6.0
test(1);
test(2);
test(3);

可能出现的组合，效果预览
在这里插入图片描述

（2）加锁

AsyncMutex _mtx = new AsyncMutex();
async void test(int num)
{
    await _mtx.Acquire();
    Console.WriteLine("enter " + num);
    //模拟异步操作
    await Task.Delay(10);
    Console.WriteLine("exit " + num);
    _mtx.Release();
}
//.net 6.0
test(1);
test(2);
test(3);

效果预览
在这里插入图片描述

总结

以上就是今天要讲的内容，本文简单的实现了单线程的异步互斥锁，实现起来相对简单，但作用还是比较大的。虽然说有些情况的异步是可以在前期设计上避免同时调用，比如登录按钮点击后出现蒙板不允许再次点击，但是对于已存在的代码出现了同时调用问题，此时有互斥锁则可以避免大范围改动代码，有效解决问题。

.Netc#wpf异步编程mutex互斥锁

https://www.dkcj.cn/info/764.html

Kubernetes对象的定义和操作

Kubernetes对象指的是Kubernetes系统的持久化实体，所有这些对象合起来，代表了你集群的实际情况。常规的应用里，我们把应用程序的数据存储在数据库中，Kubernetes将其数据以Kubernetes对象的形式通过 api server存储在 etcd 中。集群中运行了哪些容器化应用程序集群中对应用程序可用的资源应用程序相关的策略定义，例如，重启策略、升级策略、容错策略其他Kubernetes管理应用程序时所需要的信息。

编程日记2024/09/26 16:30:22

使用名称空间共享集群

可以限定使用某个名称空间的用户不能看到另外一个名称空间中的内容。默认情况下，安装Kubernetes集群时，会初始化一个 default 名称空间，用来将承载那些未指定名称空间的 Pod、Service、Deployment等对象。接下来，为 kubectl 定义一个上下文，以便在不同的名称空间中工作。此时，开发人员可以做任何他想要做的操作，所有操作都限定在名称空间 development 里，而无需担心影响到 production 名称空间中的内容。使用 kubectl 有两种方式可以创建名称空间。

编程日记2024/09/26 16:30:22

k8s 标签和选择器

标签（Label）是附加在Kubernetes对象上的一组名值对，其意图是按照对用户有意义的方式来标识Kubernetes对象，同时，又不对Kubernetes的核心逻辑产生影响。管理这些对象时，很多时候要针对某一个维度的条件做整体操作，例如，将某个版本的程序整体删除，这种情况下，如果用户能够事先规划好标签的使用，再通过标签进行选择，就会非常地便捷。Kubernetes api server支持两种形式的标签选择器，equality-based 基于等式的和 set-based 基于集合的。

编程日记2024/09/26 16:30:22

Deployment概述

Pod 容器组是 Kubernetes 中最小的调度单元，更多信息请参考容器组 - 概述Deployment 是最常用的用于部署无状态服务的方式。Deployment 控制器使得您能够以声明的方式更新 Pod（容器组）和 ReplicaSet（副本集）。以“声明”的方式管理 Pod 和 ReplicaSet，其本质是将一些特定场景的一系列运维步骤固化下来，以便快速准确无误的执行。

编程日记2024/09/26 16:30:22

k8s搭建部署（超详细）

Kubernetes是Google 2014年创建管理的，是Google 10多年大规模容器管理技术Borg的开源版本。它是容器集群管理系统，是一个开源的平台，可以实现容器集群的自动化部署、自动扩缩容、维护等功能。快速部署应用快速扩展应用无缝对接新的应用功能节省资源，优化硬件资源的使用可移植: 支持公有云，私有云，混合云，多重云（multi-cloud）可扩展: 模块化, 插件化, 可挂载, 可组合自动化: 自动部署，自动重启，自动复制，自动伸缩/扩展。

编程日记2024/02/03 23:30:01

【OpenCV】在Linux上使用OpenCvSharp

OpenCvSharp是一个OpenCV的 .Net wrapper，应用最新的OpenCV库开发，使用习惯比EmguCV更接近原始的OpenCV，该库采用LGPL发行，对商业应用友好。

精选2024/01/31 20:42:49

k8s图形化管理工具之rancher

在前面的k8s基础学习中，我们学习了各种资源的搭配运用，以及命令行，声明式文件创建。这些都是为了k8s管理员体会k8s的框架，内容基础。在真正的生产环境中，大部分的公司还是会选用图形化管理工具来管理k8s集群，大大提高工作效率。在二进制搭建k8集群时，我们就知道了k8s本身就具有一款原生的k8s集群管理工具，但是原生图形化管理工具dashborad只拥有管理一个集群的能力。而对于现代化生产力公司来讲，一个集群能够做的事情还是太少，所以我们需要引入更强大的集群管理工具。

编程日记2024/01/24 22:12:12

给服务器开通telnet的流程

但一些特殊场景下，比如要升级ssh，ssh不能用时，需要使用telnet，用过要关闭此服务。需要首先安装，如果telnet-server服务在xinetd之前安装了，要先删除telnet-server，再安装xinetd。安装顺序：xinetd--》telnet--》telnet-server。安装顺序：xinetd--》telnet--》telnet-server。2、卸载rpm包（如果已经安装了，又不清楚顺序，可以都卸载后统一安装）注意：telnet-server服务启动依赖xinetd服务，

编程日记2024/01/24 20:02:23

k8s 使用tomcat官方镜像部署集群并解决访问页面404

官方镜像这里有个坑，使用kubectl启动之后，页面报错404，仔细检查发现，是因为tomcat的webapp目录下没有对应的文件，所以连初始界面都无法显示。要想显示，必须要根据官方镜像自己构建一个Dockerfile。根据上面的信息可以看出，该POD部署在k8s-node1上，映射POD的8080端口到master的30088端口上。这里需要将镜像上传到自己搭建的registry，并配置nodes节点都可以正常访问5000端口。三、根据官方镜像自己构建一个一次性就能启动的Tomcat镜像。

编程日记2024/01/22 22:22:24

在C#中调用C++函数并返回const char*类型的值

在C#中，使用DllImport特性将C++函数声明为外部函数。在Main方法中，调用generateProjectCode函数并将返回的指针转换为const char*类型的字符串。在C#中调用C++函数并返回const char*类型的值，可以使用Interop服务来实现。C++代码需要编译为动态链接库（DLL）。

编程日记2024/01/22 15:18:55

C#winform上位机开发学习笔记3-串口助手的信息保存功能添加

上位机开发的系列学习笔记，避免遗忘多记录多补充多优化

编程日记2024/01/20 22:24:35

.Net 8.0 Web API Controllers 添加到 windows 服务

但是，如果您希望能够让它托管 API 控制器（也许是为了查看它正在运行的进程的状态），您将需要添加并进行一些更改。要卸载在终端 sc.exe 中运行的服务，请删除“My Worker Service”浏览到http://localhost:5000/my以确保它正在运行。在 Windows 中打开“服务”应用程序，您应该会在那里看到它。（如果更改了 appsettings.json 中的端口，则浏览到。在弹出窗口中，选择“文件夹”，然后按“下一步”、 “完成并关闭”在Program.cs中，您将添加。_.net8.0 服务程序

编程日记2024/01/19 23:02:34

文章目录

前言

一、异步互斥锁的作用是什么？

示例一、创建和销毁

二、如何实现？

1、标识

（1）标识是否锁住

（2）加锁

（3）解锁

2、异步通知

（1）创建对象

（2）返回Task

（3）通知完成

3、等待队列

（1）创建队列

（2） 等待加锁

（3）加锁成功

三、完整代码

四、使用示例

1、基本用法

2、尝试加锁

3、加锁对比

（1）未加锁

（2）加锁

总结

相关文章：

（2）等待加锁