是否有与 C# 中的 F# Seq.windowed 等效的功能？

Question

我正在编写一些 C# 代码来处理诸如移动平均线之类的问题，我经常需要使用 List / IEnumerable 并处理连续数据块。 F# Seq 模块有一个很棒的函数，windowed，它接受一个序列，返回一个连续元素块的序列。

C# 是否具有与 LINQ 相同的开箱即用功能？

Answer 1

John Palmer 的回答很好，下面是一个基于他回答的例子。

var numbers = new[] {1, 2, 3, 4, 5}; 
var windowed = SeqModule.Windowed(2, numbers);

您可能（或不）想将 ToArray() 添加到末尾，没有 ToArray，返回类型仍然在 F# 世界中（Sequence）。有了 ToArray，就回到了 C# 世界（数组）。

Answer 2

你总是可以从 C# 中调用SeqModule.Windowed，你只需要引用FSharp.Core.Dll。函数名称也有轻微损坏，因此您调用 Windowed 而不是 windowed，以便它符合 C# 大写约定

Answer 3

Reactive Extensions 有一些运算符可以帮助解决此问题，例如 Buffer 和 Window。可以在实验分支中找到的 Interactive Extensions 将这些以及大量额外的运算符添加到 LINQ。

Answer 4

您总是可以自己滚动（或从 F# 核心翻译）：

let windowed windowSize (source: seq<_>) =    
    checkNonNull "source" source
    if windowSize <= 0 then invalidArg "windowSize" (SR.GetString(SR.inputMustBeNonNegative))
    seq { let arr = Microsoft.FSharp.Primitives.Basics.Array.zeroCreateUnchecked windowSize 
            let r = ref (windowSize-1)
            let i = ref 0 
            use e = source.GetEnumerator() 
            while e.MoveNext() do 
                arr.[!i] <- e.Current
                i := (!i + 1) % windowSize
                if !r = 0 then 
                    yield Array.init windowSize (fun j -> arr.[(!i+j) % windowSize])
                else 
                r := (!r - 1) }

我的尝试看起来像这样，它比直接调用 F# 慢得多（正如 John Palmer 所建议的那样）。我猜这是因为 F# 使用了 Unchecked 数组。：

public static IEnumerable<T[]> Windowed<T>(this IEnumerable<T> list, int windowSize)
{
    //Checks elided
    var arr = new T[windowSize];
    int r = windowSize - 1, i = 0;
    using(var e = list.GetEnumerator())
    {
        while(e.MoveNext())
        {
            arr[i] = e.Current;
            i = (i + 1) % windowSize;
            if(r == 0) 
                yield return ArrayInit<T>(windowSize, j => arr[(i + j) % windowSize]);
            else
                r = r - 1;
        }
    }
}
public static T[] ArrayInit<T>(int size, Func<int, T> func)
{
    var output = new T[size];
    for(var i = 0; i < size; i++) output[i] = func(i);
    return output;
}