Rx.NET庫(kù)中IDisposable對(duì)象的用法
IDisposable是.net中的主動(dòng)資源釋放接口,它是在編程過(guò)程中經(jīng)常使用到的一個(gè)接口,本文介紹一下微軟在Rx.NET中提供的一系列常用的Disposable類,通過(guò)它們可以簡(jiǎn)化我們的程序代碼,提高代碼質(zhì)量。
IDisposable:
一個(gè)簡(jiǎn)單的IDisposable接口實(shí)現(xiàn)如下
class DisposableObject : IDisposable
{
private readonly string name = null;
public DisposableObject(string name)
{
this.name = name;
}
public void Dispose()
{
Console.WriteLine("{0} - Disposed", this.name);
}
}注: 這個(gè)例子并不是合適的實(shí)現(xiàn),主要是為了后面的代碼演示使用。
ICancelable
RX框架在Disposable接口上擴(kuò)展了一下,增加了一個(gè)查看是否被釋放的狀態(tài),定義了一個(gè)ICancelable接口
public interface ICancelable : IDisposable
{
bool IsDisposed { get; }
}除了Disposable.Empty外,RX框架提供的都是ICancelable接口對(duì)象。
Disposable.Empty
Disposable.Empty返回的是一個(gè)沒(méi)有任何功能的IDisposable對(duì)象,是一個(gè)IDisposable的NullObject模式的實(shí)現(xiàn)。
它的Dispose函數(shù)可以使用,但沒(méi)有任何行為。
Disposable.Create
Disposable.Create可以快速構(gòu)建一個(gè)IDisposable對(duì)象,它接受一個(gè)委托,當(dāng)Dispose函數(shù)調(diào)用時(shí),執(zhí)行該委托。
var d = Disposable.Create(() =>
{
Console.WriteLine("Disposed");
});
d.Dispose();BooleanDisposable
BooleanDisposable是一個(gè)簡(jiǎn)單的ICancelable的實(shí)現(xiàn),它的Dispose操作也沒(méi)有任何行為,但可以查看該函數(shù)是否執(zhí)行過(guò)。
var d = new BooleanDisposable(); Console.WriteLine(d.IsDisposed); d.Dispose(); Console.WriteLine(d.IsDisposed);
由于不能控制該對(duì)象的Dispose行為,這個(gè)對(duì)象用得到不是很多,往往用來(lái)作為一個(gè)開(kāi)關(guān)變量使用。
CancellationDisposable
CancellationDisposable可將一個(gè)CancellationTokenSource對(duì)象封裝為Disposable對(duì)象
- 當(dāng)Dispose函數(shù)調(diào)用時(shí),調(diào)用Cancel函數(shù)。
- 查看IsPosed狀態(tài)時(shí),返回IsCancellationRequested狀態(tài)
簡(jiǎn)單的示例如下:
var source = new CancellationTokenSource();
source.Token.Register(() => Console.WriteLine("Cancelled"));
var d = new CancellationDisposable(source);
Console.WriteLine(d.IsDisposed);
Console.WriteLine(source.IsCancellationRequested);RefCountDisposable
RefCountDisposable也是一個(gè)封裝型的Disposable對(duì)象,不過(guò)它是一個(gè)引用計(jì)數(shù)型的封裝。
- 新建RefCountDisposable對(duì)象后,引用計(jì)數(shù)為1
- 調(diào)用GetDisposable可以生成一個(gè)新的引用Disposable封裝,引用技術(shù)加1
- 調(diào)用RefCountDisposable對(duì)象和GetDisposable生成的Disposable對(duì)象時(shí),引用計(jì)數(shù)都減1
- 引用計(jì)數(shù)為0時(shí),釋放封裝的Disposable對(duì)象
這里需要注意的時(shí),當(dāng)調(diào)用RefCountDisposable. Dispose函數(shù)時(shí),可能引用計(jì)數(shù)還不為0,此時(shí)還是可以繼續(xù)調(diào)用GetDisposable函數(shù)增加引用計(jì)數(shù)的。
簡(jiǎn)單的示例如下:
var d = new RefCountDisposable(new DisposableObject("#1"));
var ref1 = d.GetDisposable();
var ref2 = d.GetDisposable();
Console.WriteLine("ref2 - Dispose");
ref2.Dispose();
Console.WriteLine("ref1 - Dispose");
ref1.Dispose();
Console.WriteLine("Dispose");
d.Dispose();這個(gè)類在釋放共享資源的時(shí)候非常有用,例如我們做視頻點(diǎn)播的時(shí)候,當(dāng)有多個(gè)客戶端點(diǎn)播視頻時(shí),每個(gè)客戶端都需要維護(hù)引用計(jì)數(shù),當(dāng)所有客戶端都退出的時(shí)候,會(huì)自動(dòng)Dispose,注銷視頻源。
CompositeDisposable
CompositeDisposable用于聚合多個(gè)disposable對(duì)象,形成一個(gè)新的disposable對(duì)象,它主要有Add,Clear,Dispose三個(gè)函數(shù)。
- Add函數(shù)將子Disposable對(duì)象添加到集合
- Clear函數(shù)刪除集合類所有的Disposable對(duì)象,同時(shí)調(diào)用子Disposable對(duì)象的Dispose函數(shù)
- Dispose函數(shù)釋放CompositeDisposable對(duì)象:釋放所有子Disposable對(duì)象。
- 如果CompositeDisposable對(duì)象已經(jīng)釋放,再次調(diào)用Add函數(shù)時(shí),不會(huì)添加到集合,而是直接調(diào)用其子對(duì)象的Dispose函數(shù)。
簡(jiǎn)單的示例如下:
var d = new CompositeDisposable();
d.Add(new DisposableObject("#1"));
d.Add(new DisposableObject("#2"));
d.Add(new DisposableObject("#3"));
d.Clear();
Console.WriteLine("----------");
d.Add(new DisposableObject("#4"));
d.Add(new DisposableObject("#5"));
d.Add(new DisposableObject("#6"));
d.Dispose();
Console.WriteLine("----------");
d.Add(new DisposableObject("#7"));ContextDisposable
ContextDisposable對(duì)象也是一個(gè)復(fù)合Disposable對(duì)象
- 它主要用于封裝一個(gè)Disposable對(duì)象,將其與一個(gè)SynchronizationContext上下文關(guān)聯(lián),
- 封裝后生成的ContextDisposable對(duì)象的Disposable函數(shù)會(huì)Post到上下文線程中執(zhí)行。
簡(jiǎn)單的示例如下:
var context = SynchronizationContext.Current;
var obj = new DisposableObject("#1");
var d = new ContextDisposable(context, obj);
d.Dispose();這個(gè)對(duì)象用于釋放UI對(duì)象非常方便,另外,也可以實(shí)現(xiàn)用于將一些Dispose函數(shù)推送到指定的隊(duì)列中串行執(zhí)行,從而避免一些并發(fā)問(wèn)題。
ScheduledDisposable
ScheduledDisposable和ContextDisposable類似,也是用于封裝一個(gè)Disposable對(duì)象,不過(guò)它是將其Dispose函數(shù)推送到指定的IScheduler中執(zhí)行。
var scheduler = ThreadPoolScheduler.Instance;
var obj = new DisposableObject("#1");
var d = new ScheduledDisposable(scheduler, obj);
d.Dispose();SingleAssignmentDisposable
SingleAssignmentDisposable是一個(gè)關(guān)聯(lián)型的Disposable對(duì)象
- 可以通過(guò)它的Disposable屬性關(guān)聯(lián)到子Dispose對(duì)象。
- 當(dāng)執(zhí)行Dispose函數(shù)時(shí),執(zhí)行的是子Dispose對(duì)象的Dispose函數(shù),如果沒(méi)有關(guān)聯(lián)子Dispose對(duì)象,則不執(zhí)行任何操作。
- 已經(jīng)執(zhí)行Dispose函數(shù)后,再次使用Disposable屬性關(guān)聯(lián)后無(wú)法關(guān)聯(lián),直接會(huì)調(diào)用子對(duì)象的Dispose函數(shù)。
SingleAssignmentDisposable的關(guān)聯(lián)有一個(gè)Single特點(diǎn),它主要體現(xiàn)為:
- 如果已經(jīng)通過(guò)Disposable屬性關(guān)聯(lián)后,再次調(diào)用Disposable屬性關(guān)聯(lián)時(shí)會(huì)拋異常
簡(jiǎn)單的示例如下:
var d = new SingleAssignmentDisposable();
d.Disposable = new DisposableObject("#1");
try
{
d.Disposable = new DisposableObject("#2"); //--- 例外発生
}
catch (InvalidOperationException ex)
{
Console.WriteLine(ex.Message);
}
d.Dispose();
d.Disposable = new DisposableObject("#3");輸出結(jié)果為:
Disposable has already been assigned.
#1 – Disposed
#3 - Disposed
MultipleAssignmentDisposable
MultipleAssignmentDisposable和SingleAssignmentDisposable類似,區(qū)別是其關(guān)聯(lián)的multi特性,它的特點(diǎn)是:
- 如果已經(jīng)通過(guò)Disposable屬性關(guān)聯(lián)后,再次調(diào)用Disposable屬性是會(huì)覆蓋關(guān)聯(lián)
簡(jiǎn)單的示例如下:
var d = new MultipleAssignmentDisposable();
d.Disposable = new DisposableObject("#1");
d.Disposable = new DisposableObject("#2");
d.Dispose();
d.Disposable = new DisposableObject("#3");輸出結(jié)果為:
#2 – Disposed
#3 - Disposed
SerialDisposable
SerialDisposable和SingleAssignmentDisposable也類似,不過(guò)它的Disposable屬性再次關(guān)聯(lián)的策略是:
- 覆蓋關(guān)聯(lián),同時(shí)先釋放上一個(gè)Disposable對(duì)象。
簡(jiǎn)單的示例如下:
var d = new SerialDisposable();
Console.WriteLine("#1 - Set");
d.Disposable = new DisposableObject("#1");
Console.WriteLine("#2 - Set");
d.Disposable = new DisposableObject("#2");
Console.WriteLine("Dispose");
d.Dispose();輸出結(jié)果為:
#1 – Set
#2 – Set
#1 – Disposed
Dispose
#2 – Disposed
#3 – Set
#3 - Disposed
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
.net重啟iis線程池和iis站點(diǎn)程序代碼分享
服務(wù)器監(jiān)控,一定時(shí)間內(nèi)或者iis異常就需要重啟線程池和站點(diǎn),下面我們用代碼來(lái)做這個(gè)功能2013-12-12
ASP.NET?MVC使用typeahead.js實(shí)現(xiàn)輸入智能提示功能
這篇文章介紹了ASP.NET?MVC使用typeahead.js實(shí)現(xiàn)輸入智能提示功能的方法,文中通過(guò)示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2022-09-09
.NET Core基于Generic Host實(shí)現(xiàn)后臺(tái)任務(wù)方法教程
這篇文章主要給大家介紹了關(guān)于.NET Core基于Generic Host實(shí)現(xiàn)后臺(tái)任務(wù)的相關(guān)資料,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2018-11-11
使用Visual Studio 2017作為L(zhǎng)inux C++開(kāi)發(fā)工具
這篇文章主要為大家詳細(xì)介紹了使用Visual Studio 2017作為L(zhǎng)inux C++開(kāi)發(fā)工具的相關(guān)資料,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2017-03-03
C#中實(shí)現(xiàn)偽靜態(tài)頁(yè)面兩種方式介紹
偽靜態(tài)技術(shù)的誕生,帶動(dòng)了于搜索引擎友好C#中實(shí)現(xiàn)偽靜態(tài)頁(yè)面有兩種方式,本文將一一詳解,感興趣的朋友可以參考下,希望本文對(duì)你學(xué)習(xí)偽靜態(tài)有所幫助2013-01-01
關(guān)于.NET動(dòng)態(tài)代理的介紹和應(yīng)用簡(jiǎn)介
關(guān)于.NET動(dòng)態(tài)代理的介紹和應(yīng)用簡(jiǎn)介...2006-09-09

