jjzjj

c# - 在 IObservable<T> 接口(interface)中返回 IDisposable 的目的是什么？

coder 2024-05-21 原文

我正在阅读 Head First Design Patterns 一书，并尽力将代码从他们的 Java 转换为 C#。在这本书讨论了观察者模式之后，它提到 Java 具有内置的类/接口(interface)，.NET4 也是如此。所以我开始研究如何正确使用它，除了 Subscribe() 方法外，我已经弄明白了大部分内容。

如果您查看 MSDN Article当您尝试订阅 IObserver 时，该方法返回一个 IDisposable。为什么那是必要的？为什么不只实现一个基于方法参数取消订阅 IObserver 的方法呢？ I researched the reason to use an IDisposable interface .我也读过这篇文章，但不太明白其中的区别/它想告诉我什么:

It returns a reference to an IDisposable interface. This enables observers to unsubscribe (that is, to stop receiving notifications) before the provider has finished sending them and called the subscriber's OnCompleted method.

最佳答案

取消订阅所需的信息因事件发布者管理订阅的方式而异。用于事件的方法——将委托(delegate)先前传递给 Add 方法的委托(delegate)传递给 Remove 方法——有点可行，但有一些明显的缺陷。其中:

  1. 通常需要事件发布者执行线性搜索来定位包含与订阅相关的信息的记录。如果一个事件有可能有很多订阅者，这可能会不必要地创建 O(N^2) 行为。如果订阅者保存在某种链表(链接对象或索引链接数组槽)中，并且取消订阅请求包含有关要取消的订阅的信息，则订阅和取消订阅都可以在恒定时间内处理。此外，取消订阅可以以无锁非阻塞方式安全且轻松地处理(在最有可能是无竞争数组槽的位置上使用一个 CompareExchange)，这可以在 Finalize 上下文中安全地完成。
  2. 如果一个代表多次订阅处理顺序很重要的事件，并且代码试图取消第一个订阅，最后一个订阅将被取消，第一个订阅将保持有效。
  3. 如果订阅了委托(delegate)`D`，则订阅包含`A`、`B`、`C`和`D`的组播委托(delegate)`ABCD`，然后取消订阅`D`，那么委托(delegate) `DABC` 将按顺序保持订阅状态，即使代码试图取消订阅 `ABCD`。请注意，如果使用 `List` 而不是 `delegateType.Combine` 可以避免此问题，但其他问题仍然存在。

让事件订阅方法返回一个可用于取消订阅的对象可以避免这些问题。那么最大的问题就变成了应该使用什么类型的对象。我想到了三个选择:

  1. 委托(delegate)(可能无参数，返回 `void`)
  2. 一些 `ICancelSubscription` 接口(interface)，使用单一方法(可能无参数，返回 `void`)取消订阅
  3. `IDisposable`，一个存在的接口(interface)，有一个单一的无参数方法，广泛用于清理相关的目的

使用委托(delegate)是一个合理的选择。它可以很容易地封装取消订阅所需的任何信息，而用户不必担心该信息可能采用什么形式。使用委托(delegate)将需要分配至少一个额外的堆对象(对于委托(delegate)本身)，可能还有两个(第二个是保存取消订阅信息的对象)。使用 IDisposable 本质上与使用委托(delegate)相同，不同之处在于委托(delegate)调用 Dispose 而不是 Invoke；但是，在许多情况下，IDisposable 在效率方面会稍有优势。使用其他一些接口(interface)也是可行的，但与使用现有的 IDisposable 相比并没有真正的优势。

关于c# - 在 IObservable<T> 接口(interface)中返回 IDisposable 的目的是什么？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/10625815/

c#IObservabledelegatecodeIDisposabledesign-patternssystem.reactiveobserver-pattern

有关c# - 在 IObservable<T> 接口(interface)中返回 IDisposable 的目的是什么？的更多相关文章

  1. ruby - 为什么我可以在 Ruby 中使用 Object#send 访问私有(private)/ protected 方法？ - 2

    类classAprivatedeffooputs:fooendpublicdefbarputs:barendprivatedefzimputs:zimendprotecteddefdibputs:dibendendA的实例a=A.new测试a.foorescueputs:faila.barrescueputs:faila.zimrescueputs:faila.dibrescueputs:faila.gazrescueputs:fail测试输出failbarfailfailfail.发送测试[:foo,:bar,:zim,:dib,:gaz].each{|m|a.send(m)resc

  2. ruby-on-rails - Rails - 子类化模型的设计模式是什么？ - 2

    我有一个模型:classItem项目有一个属性“商店”基于存储的值，我希望Item对象对特定方法具有不同的行为。Rails中是否有针对此的通用设计模式？如果方法中没有大的if-else语句，这是如何干净利落地完成的？ 最佳答案 通常通过Single-TableInheritance. 关于ruby-on-rails-Rails-子类化模型的设计模式是什么？，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.co

  3. ruby - 什么是填充的 Base64 编码字符串以及如何在 ruby​​ 中生成它们？ - 2

    我正在使用的第三方API的文档状态:"[O]urAPIonlyacceptspaddedBase64encodedstrings."什么是“填充的Base64编码字符串”以及如何在Ruby中生成它们。下面的代码是我第一次尝试创建转换为Base64的JSON格式数据。xa=Base64.encode64(a.to_json) 最佳答案 他们说的padding其实就是Base64本身的一部分。它是末尾的“=”和“==”。Base64将3个字节的数据包编码为4个编码字符。所以如果你的输入数据有长度n和n%3=1=>"=="末尾用于填充n%

  4. ruby - 解析 RDFa、微数据等的最佳方式是什么，使用统一的模式/词汇(例如 schema.org)存储和显示信息 - 2

    我主要使用Ruby来执行此操作，但到目前为止我的攻击计划如下:使用gemsrdf、rdf-rdfa和rdf-microdata或mida来解析给定任何URI的数据。我认为最好映射到像schema.org这样的统一模式，例如使用这个yaml文件，它试图描述数据词汇表和opengraph到schema.org之间的转换:#SchemaXtoschema.orgconversion#data-vocabularyDV:name:namestreet-address:streetAddressregion:addressRegionlocality:addressLocalityphoto:i

  5. ruby - 为什么 4.1%2 使用 Ruby 返回 0.0999999999999996？但是 4.2%2==0.2 - 2

    为什么4.1%2返回0.0999999999999996？但是4.2%2==0.2。 最佳答案 参见此处:WhatEveryProgrammerShouldKnowAboutFloating-PointArithmetic实数是无限的。计算机使用的位数有限(今天是32位、64位)。因此计算机进行的浮点运算不能代表所有的实数。0.1是这些数字之一。请注意，这不是与Ruby相关的问题，而是与所有编程语言相关的问题，因为它来自计算机表示实数的方式。 关于ruby-为什么4.1%2使用Ruby返

  6. ruby-on-rails - 如何从 format.xml 中删除 <hash></hash> - 2

    我有一个对象has_many应呈现为xml的子对象。这不是问题。我的问题是我创建了一个Hash包含此数据，就像解析器需要它一样。但是rails自动将整个文件包含在.........我需要摆脱type="array"和我该如何处理？我没有在文档中找到任何内容。 最佳答案 我遇到了同样的问题；这是我的XML:我在用这个:entries.to_xml将散列数据转换为XML，但这会将条目的数据包装到中所以我修改了:entries.to_xml(root:"Contacts")但这仍然将转换后的XML包装在“联系人”中，将我的XML代码修改为

  7. ruby - ruby 中的 TOPLEVEL_BINDING 是什么？ - 2

    它不等于主线程的binding，这个toplevel作用域是什么？此作用域与主线程中的binding有何不同？>ruby-e'putsTOPLEVEL_BINDING===binding'false 最佳答案 事实是，TOPLEVEL_BINDING始终引用Binding的预定义全局实例，而Kernel#binding创建的新实例>Binding每次封装当前执行上下文。在顶层，它们都包含相同的绑定(bind)，但它们不是同一个对象，您无法使用==或===测试它们的绑定(bind)相等性。putsTOPLEVEL_BINDINGput

  8. ruby - Infinity 和 NaN 的类型是什么？ - 2

    我可以得到Infinity和NaNn=9.0/0#=>Infinityn.class#=>Floatm=0/0.0#=>NaNm.class#=>Float但是当我想直接访问Infinity或NaN时:Infinity#=>uninitializedconstantInfinity(NameError)NaN#=>uninitializedconstantNaN(NameError)什么是Infinity和NaN？它们是对象、关键字还是其他东西？ 最佳答案 您看到打印为Infinity和NaN的只是Float类的两个特殊实例的字符串

  9. ruby-on-rails - 如果 Object::try 被发送到一个 nil 对象，为什么它会起作用？ - 2

    如果您尝试在Ruby中的nil对象上调用方法，则会出现NoMethodError异常并显示消息:"undefinedmethod‘...’fornil:NilClass"然而，有一个tryRails中的方法，如果它被发送到一个nil对象，它只返回nil:require'rubygems'require'active_support/all'nil.try(:nonexisting_method)#noNoMethodErrorexceptionanymore那么try如何在内部工作以防止该异常？ 最佳答案 像Ruby中的所有其他对象

  10. ruby - 为什么 SecureRandom.uuid 创建一个唯一的字符串？ - 2

    关闭。这个问题需要detailsorclarity.它目前不接受答案。想改进这个问题吗？通过editingthispost添加细节并澄清问题.关闭8年前。Improvethisquestion为什么SecureRandom.uuid创建一个唯一的字符串？SecureRandom.uuid#=>"35cb4e30-54e1-49f9-b5ce-4134799eb2c0"SecureRandom.uuid方法创建的字符串从不重复？

随机推荐