C#使用CallContext缓存线程数据
作者:springsnow 发布时间:2022-03-27 17:45:55
一、CallContext 概述
命名空间:System.Runtime.Remoting.Messaging
CallContext 用于提供与执行代码路径一起传送的属性集,直白讲就是:提供线程(多线程/单线程)代码执行路径中数据传递的能力。
当对另一个 AppDomain 中的对象进行远程方法调用时,CallContext 类将生成一个与该远程调用一起传播的 LogicalCallContext 实例。只有公开 ILogicalThreadAffinative 接口并存储在 CallContext 中的对象被在 LogicalCallContext 中传播到 AppDomain 外部。
CallContext成员
SetData: 存储给定的对象并将其与指定名称关联。
GetData: 从CallContext中检索具有指定名称的对象
LogicalSetData: 将给定的对象存储在逻辑调用上下文,并将其与指定名称关联。可用于多线程环境
LogicalGetData: 从逻辑调用上下文中检索具有指定名称的对象。可用于多线程环境
FreeNamedDataSlot: 清空具有指定名称的数据槽。可用于多线程环境
HostContext属性: 获取或设置与当前线程相关联的主机上下文。在Web环境下等于System.Web.HttpContext.Current
GetData、SetData
只能用于单线程环境,如果发生了线程切换,存储的数据也会随之丢失
可以用于同一线程中的不同地方,传递数据
LogicalSetData、LogicalGetData
LogicalSetData、LogicalGetData可用于在多线程环境下传递数据;
LogicalSetData只是存储当前线程以及子线程的数据槽
LogicalGetData获取的是当前线程或父线程的数据槽对象,拿到的是对象的引用
FreeNamedDataSlot清除当前线程,之前已经运行子任务,不受影响,不能清除子线程的数据槽;
二、 CallContext不跨线程传播的方法:GetData、SetData
可以利用CallContext 实现单例,默认情况下,CallContext 的数据不跨线程传播。
1、在处理多组件共用Context时非常有用,比如常见的EF 可以将实例的DBEntity存储在其中,可以一次访问只实例化一次,便于管理且不用多次实例访问对象
public static class DbContextHelper
{
private static DbContext context = null;
private const string SessionKey_DbContext = "Entities";
public static DbContext GetDbContext()
{
if (CallContext.GetData(SessionKey_DbContext) == null)
{
CallContext.SetData(SessionKey_DbContext, new Entities());
}
return CallContext.GetData(SessionKey_DbContext) as Entities;
}
}
2、类单例
void Main()
{
MyAppContext.Current.FirstName = "a";
Console.Write(MyAppContext.Current.FirstName);
}
public class MyAppContext
{
const string contextKey = "MyAppContext:ContextKey";
public string FirstName { get; set; }
public static MyAppContext Current
{
get
{
if (CallContext.GetData(contextKey) == null)
{
CallContext.SetData(contextKey, new MyAppContext());
}
return CallContext.GetData(SessionKey_DbContext) as MyAppContext;
}
}
}
三、 CallContext跨线程传播的方法:ILogicalSetData、LogicalGetData
要让CallContext实现跨线程传播,可以调用CallContext的静态方法ILogicalSetData,或让上下文类实现ILogicalThreadAffinative 接口。
线程本地存储
线程池可能不会释放使用过的线程,导致多次执行之间可能共享数据(可以每次执行前重置线程本地存储的数据)。
for (var i = 0; i < 10; i++)
{
Thread.Sleep(10);
Task.Run(() =>
{
var slot = Thread.GetNamedDataSlot("test");
if (slot == null)
{
Thread.AllocateNamedDataSlot("test");
}
if (Thread.GetData(slot) == null)
{
Thread.SetData(slot, DateTime.Now.Millisecond);
}
Console.WriteLine(Thread.CurrentThread.ManagedThreadId + ":" + Thread.GetData(slot));
});
}
结果
调用上下文
每次执行的数据是完全隔离的,非常符合我们的期望。但是,如果我们期望调用期间又开启了一个子线程,如何让子线程访问父线程的数据呢?这就需要使用到:“逻辑调用上下文”。
Console.WriteLine("测试:CallContext.SetData");
for (var i = 0; i < 10; i++)
{
Thread.Sleep(10);
Task.Run(() =>
{
if (CallContext.GetData("test") == null)
{
CallContext.SetData("test", DateTime.Now.Millisecond);
}
Console.WriteLine(Thread.CurrentThread.ManagedThreadId + ":" + CallContext.GetData("test"));
});
}
结果
每次执行的数据是完全隔离的,非常符合我们的期望。
逻辑调用上下文
如果我们期望调用期间又开启了一个子线程,如何让子线程访问父线程的数据呢?这就需要使用到:“逻辑调用上下文”。
注意 ExecutionContext.SuppressFlow(); 和ExecutionContext.RestoreFlow();它们分别能阻止传播和重置传播,默认是允许传播的。
Console.WriteLine("测试:CallContext.SetData");
Task.Run(() =>
{
CallContext.SetData("test", "段光伟");
Console.WriteLine(Thread.CurrentThread.ManagedThreadId + ":" + CallContext.GetData("test"));
Task.Run(() =>
{
Console.WriteLine(Thread.CurrentThread.ManagedThreadId + ":" + CallContext.GetData("test"));
});
});
Thread.Sleep(100);
Console.WriteLine("测试:CallContext.LogicalSetData");
Task.Run(() =>
{
CallContext.LogicalSetData("test", "段光伟");
Console.WriteLine(Thread.CurrentThread.ManagedThreadId + ":" + CallContext.LogicalGetData("test"));
Task.Run(() =>
{
Console.WriteLine(Thread.CurrentThread.ManagedThreadId + ":" + CallContext.LogicalGetData("test"));
});
ExecutionContext.SuppressFlow();
Task.Run(() =>
{
Console.WriteLine("SuppressFlow 之后:" + CallContext.LogicalGetData("test"));
});
ExecutionContext.RestoreFlow();
Task.Run(() =>
{
Console.WriteLine("RestoreFlow 之后:" + CallContext.LogicalGetData("test"));
});
});
输出
四、Web中的CallContext
HttpContext.Current(包括Session)的存储是基于当前线程的CallContext,在非请求处理线程(即其他线程)是无法获取当前HttpContext的(不跨线程传播)。
来源:https://www.cnblogs.com/springsnow/p/9434008.html
![](https://www.aspxhome.com/images/zang.png)
![](https://www.aspxhome.com/images/jiucuo.png)
猜你喜欢
- 近期用到了一位师兄写的C++程序,总体功能良好。使用不同的数据测试,发现了一个明显的缺点:大数据量下,预处理过程耗时很长。中科院的某计算集群
- Mybatis Log Plugin使用今天发现大部分猿友关于查看执行sql语句的方法,只知道将其输出到控制台。然而还有更简便的方法,就是使
- 1、修改maven的pom文件只需要将如下依赖添加到pom.xml文件中即可。(注意此处是以plugin的方式,放在<plugins&
- 本文实例为大家分享了Java实现通讯录管理系统的具体代码,供大家参考,具体内容如下一、前言我们学了这么久的知识了,光学知识不会用是一件很悲伤
- 本文实例讲述了C#线程同步的三类情景,分享给大家供大家参考。具体分析如下:C# 已经提供了我们几种非常好用的类库如 BackgroundWo
- 【前言】面向资源的 Restful 风格的 api 接口本着简洁,资源,便于扩展,便于理解等等各项优势,在如今的系统服务中越来越受欢迎。.n
- 一、滑动验证码生成思路1、随机选择一张图片2、生成滑块起点位置(x, y)3、生成滑块轮廓4、抠出滑块5、将滑块部位去除颜色二、主要方法这里
- 目录1、this代表了()的对象引用,super表示的是当前对象的()对象?2、输出内容是:3、下面程序的输出是:()4、执行下列代码的输出
- Spring Cloud Gateway(以下简称 SCG)做为网关服务,是其他各服务对外中转站,通过 SCG 进行请求转发。在请求到达真正
- 昨天在与对端系统调接口的时候,对端系统对我们传过去的json串老是处理不了,后来查原因是应为我们传过去的json串里有json对象数组,因为
- java实现在线预览- -之poi实现word、excel、ppt转html,具体内容如下所示:###简介java实现在线预览功能是一个大家
- Java中有两类线程:User Thread(用户线程)、Daemon Thread(守护线程)用户线程即运行在前台的线程,而守护线程是运行
- 记录使用Scroller实现平滑滚动,效果图如下:一、自定义View中实现View的平滑滚动public class ScrollerVie
- like模糊查询特殊字符报错转义处理方案1 <if test="projectName!
- 在实施接口中,我们利用interface语法,将interface从类定义中独立出来,构成一个主体。interface为类提供了接口规范。在
- 1. 前言随着数据量和调用量的增长,用户对应用的性能要求越来越高。另外,在实际的服务中,还存在着这样的场景:系统在组装数据的时候,对于数据的
- 本文实例讲述了C#中累加器函数Aggregate用法。分享给大家供大家参考。具体如下:var shouldExclude = false;v
- 正则: “.”和"\""."点儿,在正则表达式中表示任意一个字符。"\"在正则表
- Android内存优化是我们性能优化工作中比较重要的一环,这里其实主要包括两方面的工作:1、优化RAM,即降低运行时内存。这里的目的是防止程
- 本文实例为大家分享了Javaweb统计在线人数示的具体代码,供大家参考,具体内容如下1. 实现功能统计在线人数显示每个人的sessionId