技术标签: c# .Net mutex 异步编程 wpf 互斥锁
C#对异步的支持越来越成熟,async、await简化了代码也提高了可读性,但由于在一段上下文中有了异步操作,意味着这段操作可能会被同时重复调用,如果本身没有被设计可以重复调用的情况下,就很可能会出问题。
异步互斥锁的作用是用于确保存在异步操作的上下文同步互斥。可以参考flutter的插件mutex功能与本文基本一样。
有创建和销毁两个方法,两个方法中都有异步操作,两个方法可以单独调用,但不可以同时调用。
单线程中连续调用创建和销毁(不在同一个上下文无法用await),如果没有互斥限制有可能出现如下的操作:
创建开始->创建异步操作->消息队列->销毁开始->销毁异步操作->消息队列->销毁完成->消息队列->创建完成
加入异步互斥锁之后
加锁->创建开始->创建完成->解锁
加锁等待->销毁开始->销毁完成->解锁
由于操作都是在单线程我们直接用标识+队列就可以实现一个互斥锁。
bool _lock = false;
_lock=true;
_lock=false;
通过TaskCompletionSource可以实现异步通知
var tcs = new TaskCompletionSource();
return tcs.Task;
tcs.SetResult();
用一个队列来记录等待加锁的请求。
Queue<TaskCompletionSource> _queue = new Queue<TaskCompletionSource>();
_queue.Enqueue(tcs);
_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;
}
}
}
直接加锁
AsyncMutex _mtx = new AsyncMutex();
async void test()
{
await _mtx.Acquire();
//custom code
_mtx.Release();
}
加锁成功才执行操作
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();
}
}
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);
可能出现的组合,效果预览
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);
效果预览
以上就是今天要讲的内容,本文简单的实现了单线程的异步互斥锁,实现起来相对简单,但作用还是比较大的。虽然说有些情况的异步是可以在前期设计上避免同时调用,比如登录按钮点击后出现蒙板不允许再次点击,但是对于已存在的代码出现了同时调用问题,此时有互斥锁则可以避免大范围改动代码,有效解决问题。
文章浏览阅读202次。packagecode;//importjava.awt.*;//importjava.awt.Canvas;//importjava.awt.event.*;//importjavax.swing.*;importjava.util.Random;importjavax.microedition.lcdui.*;//写界面所需要的包/***//***俄罗斯方块*高雷*2007年1..._240×320java游戏
文章浏览阅读779次,点赞14次,收藏19次。然后,实现系统的数据管理和服务功能,包括用户的注册与登录、电影的分类与展示、电影信息的查询与推荐、座位的选择与预订、在线支付与电子票生成等。此外,随着在线视频平台的兴起,越来越多的人选择在线观看电影,这对传统电影院产生了巨大的冲击。研究意义: 开发在线电影院售票平台对于提升用户的观影体验、优化电影院的运营效率、促进电影产业的发展具有重要的意义。该系统旨在通过技术手段解决传统电影院售票中的问题,提供一个集成化的电影信息展示、座位选择、在线支付和用户评价平台,同时也为电影院和电影制作方提供有效的工具。
文章浏览阅读509次。保护我们剩下的人的通话信息安全,使用TOX可以让你在和家人,朋友,爱人交流时保护你的隐私不受政府无孔不入的的偷窥.关于TOX:其他牛逼的软件因为一些细化服务问你要钱的时候, TOX分文不取 . 你用了TOX, 想干嘛就干嘛.网友评论:项目源码展示:源码测试效果:最后,如果你学C/C++编程有什么不懂的,可以来问问我哦,或许我能够..._基于c++的即时聊天系统设计
文章浏览阅读584次。鱼弦:CSDN内容合伙人、CSDN新星导师、全栈领域创作新星创作者 、51CTO(Top红人+专家博主) 、github开源爱好者(go-zero源码二次开发、游戏后端架构 https://github.com/Peakchen)当Java服务在Linux系统中运行时,可能会出现swap分区被占用的内存泄露问题,导致系统性能下降或者崩溃。下面是该问题的故障及解决方法、底层结构、架构图、工作原理、使用场景详解和实际应用方式、原理详细描述、相关命令使用示例以及文献材料链接。_linux swap占用很高
文章浏览阅读662次。Alt+F11,然后插入-模块:复制下面代码到编辑窗口:Sub 半角标点符号转换为全角标点符号()'中英互译文档中将中文段落中的英文标点符号替换为中文标点符号 Dim i As Paragraph, ChineseInterpunction() As Variant, EnglishInterpunction() As Variant Dim MyRange..._替换半角宏
文章浏览阅读2.8k次。#.简介: WebView是Android提供的用来展示展示web页面的View,内部使用webkit浏览器引擎(一个轻量级的浏览器引擎),除了展示Web页面外,还可与Web页面内的JS脚本交互调用。WebView内部的WebSetting对象负责管理WebView的参数配置; WebViewClient负责处理WebView的各种请求和通知事件,在对应事件发生时会执行WebViewClient的对应回调; ChromeWebviewClient辅助Webview处理与JS一些交互......_android webview真正加载完成
文章浏览阅读1.6k次。_bitcoin 调试环境搭建
文章浏览阅读4.3k次,点赞93次,收藏94次。为了解决贝塞尔曲线无法局部修正、控制性减弱、曲线次数过高、不易拼接的缺陷,引入B样条曲线(B-Spline)。本文介绍B样条曲线的基本概念:节点向量、支撑性、次数阶数、加权性质、节点生成算法等,为后续曲线计算打下基础。_样条曲线生成
文章浏览阅读902次。配置本地repo库下载我的阿里云盘文件文件放置#创建目录mkdir -p /opt/cloudera/parcel-repo/mkdir -p /opt/cloudera/cm/yum install createrepoCDH 6.2.0 的三个文件放到/opt/cloudera/parcel-repo/中,并且注意把sha256后缀的文件名修改为sha#执行createrepo命令生成rpm元数据 最终/opt/cloudera/parcel-repo/会多一个repodata目录_/opt/cloudera/cm-agent/service/mgmt/mgmt.sh: line 76: /usr/java/jdk1.8.0_181
文章浏览阅读943次,点赞2次,收藏2次。uni.canvasToTempFilePath_uni.canvastotempfilepath
文章浏览阅读3.1k次。SRAM :静态RAM,不用刷新,速度可以非常快,像CPU内部的cache,都是静态RAM,缺点是一个内存单元需要的晶体管数量多,因而价格昂贵,容量不大。DRAM:动态RAM,需要刷新,容量大。SDRAM:同步动态RAM,需要刷新,速度较快,容量大。DDR SDRAM:双通道同步动态RAM,需要刷新,速度快,容量大。........................_sdram 干扰
文章浏览阅读7.3k次。假设表格有A、B、C、D四列数据,希望导入到你的数据库中表格table,对应的字段分别是col1、col2、col3、col4。_excel数据怎么生成sql语句