c# - 基于推和基于拉的结构(如 IEnumerable 和 IObservable)之间有什么区别

Question

在我读到的关于 IEnumerable 和 IObservable 的每篇技术讲座或每篇博客文章中，我都读到了，IEnumerable 是基于拉的结构，并且IObservable 是基于推送的结构。

我读到过关于 IObservable 我们有异步调用，其中没有任何阻塞并且一切都是基于推送的。

但是，但是，但是...

这到底是什么意思？基于推和拉

因为在我看来，在 IEnumerable 中，我们还可以将数据推送到结构中，也可以从中提取数据，我真的迷失了那些技术术语和想法。

请以正常和人性化的方式向我解释这两种结构之间的区别以及基于推和基于拉的结构之间的区别。

谢谢。

Answer 1

Please in a normal and human way explain to me the difference

好吧，让我们干杯吧。这是我做的最正常的人类行为。

基于拉取:

// I want some toast.  I will pull it out of the toaster when it is done.
// I will do nothing until the toast is available.
Toast t = toaster.MakeToast();
t.AddJam();
// Yum.

基于推送:

// I want some toast.  But it might take a while and I can do more work
// while I am waiting:
Task<Toast> task = toaster.MakeToastAsync();
Toast t = await task;
// await returns to the caller if the toast is not ready, and assigns
// a callback. When the toast is ready, the callback causes this method
// to start again from this point:
t.AddJam();
// Yum.

你想提取一个结果，调用一个函数，然后在函数返回之前什么都不做。

你想要一个结果推送给你，你调用一个异步函数并等待结果。当结果可用时，它会被推送到回调中，回调会在需要的地方恢复方法。

IEnumerable<T>只是一系列拉动；你打电话MoveNext每次你想提取结果时，你都会得到一个 T . IObservable<T>只是一系列的插入；你注册一个回调，每次新的T都会被调用可用。

换句话说:IEnumerable<T>逻辑上是 Func<T> 的序列调用。 IObservable<T>逻辑上是 Task<T> 的序列继续。不要让它们是 序列 的事实让您感到困惑；那是偶然的。基本思想是函数是同步的；你调用它们并同步得到一个结果；如果需要一段时间，请等待。任务是异步的；您启动它们并在可用时异步获得结果。

---

这个想法在IObservable之前存在于C#中和 await .另一种看待方式是:基于拉的就像函数调用，基于推的就像事件处理程序。一个普通的函数调用，当你想要什么的时候调用它。事件处理程序，它会在发生某些事情时调用您。 事件是 C# 语言本身表示观察者模式的方式。但是事件总是在逻辑上形成一个序列，因此能够像操作拉取项序列一样操作插入项序列是有意义的。因此，IObservable被发明了。