Giter Club home page Giter Club logo

netfabric.hyperlinq's Introduction

GitHub last commit (main) Build and test Coverage NuGet Version NuGet Downloads Gitter

NetFabric.Hyperlinq

NetFabric.Hyperlinq contains alternative implementations of many operations found in the System.Linq namespace:

  • Uses value-types to improve performance by making method calls non-virtual and reducing GC collections by not allocating on the heap.
  • Adds support for Span<>, ReadOnlySpan<>, Memory<> and ReadOnlyMemory<>.
  • Nullable reference type annotations.
  • One single NuGet package support for both sync and async enumerables.

This implementation favors performance in detriment of assembly binary size (lots of overloads).

Contents

Fast enumeration

NetFabric.Hyperlinq can enumerate faster the results of a query than System.Linq by performing all of the following:

  • Merges multiple enumerators into a single one for several more scenarios.
  • It does not box value-type enumerators so, calls to the Current property and the MoveNext() method are non-virtual.
  • All the enumerables returned by operations define a value-type enumerator.
  • Whenever possible, the enumerator returned by the public GetEnumerator() or GetAsyncEnumerator() does not implement IDisposable. This allows the foreach that enumerates the result to be inlinable.
  • Operations enumerate the source using the indexer when the source is an array, ArraySegment<>, Span<>, ReadOnlySpan<>, Memory<>, ReadOnlyMemory<>, or implements IReadOnlyList<>. The indexer performs a lot fewer operations than the enumerator.
  • The enumerables returned by operations like Range(), Repeat(), Return(), and Select(), implement IReadOnlyList<> and IList<>.
  • Use of object pools in operations like Distinct().
  • Elimination of conditional branchs in Count() with a predicate.
  • Allows the JIT compiler to perform optimizations on array enumeration whenever possible.
  • Takes advantage of EqualityComparer<>.Default devirtualization whenever possible.
  • ToList() uses ICollection<>.CopyTo() to add the items to the resulting List<>. This removes the many operations performed when adding items one-by-one or using an IEnumerable<>.

The performance is equivalent when the enumerator is a reference-type. This happens when the enumerable is generated using yield or when it's cast to one of the BCL enumerable interfaces (IEnumerable, IEnumerable<>, IReadOnlyCollection<>, ICollection<>, IReadOnlyList<>, IList<>, or IAsyncEnumerable<>). In the case of operation composition, this only affects the first operation. The subsequent operations will have value-type enumerators.

Reduced heap allocations

NetFabric.Hyperlinq allocates as much as possible on the stack. Enumerables and enumerators are defined as value-types. Generics constraints are used for the operation parameters so that the value-types are not boxed.

When the indexers are used, no allocation is performed.

It only allocates on the heap for the following cases:

  • ToArray() and ToList() allocate their results on the heap.
  • Operations that use ICollection<>.CopyTo(), ICollection<>.Contains(), or IList<>.IndexOf() will box enumerables that are value-types.
  • ToList(), when applied to collections that implement IReadOnlyCollection<> but not ICollection<>, allocates an instance of an helper class so that ICollection<>.CopyTo() can be used.

Usage

  1. Add the NetFabric.Hyperlinq NuGet package to your project.
  2. Optionally, also add the NetFabric.Hyperlinq.Analyzer NuGet package to your project. It's a Roslyn analyzer that suggests performance improvements on your enumeration source code. No dependencies are added to your assemblies.
  3. Add an using NetFabric.Hyperlinq directive to all source code files where you want to use NetFabric.Hyperlinq. It can coexist with System.Linq and System.Linq.Async directives:
using System;
using System.Linq;
using System.Linq.Async;
using NetFabric.Hyperlinq; // add this directive

BCL Collections

NetFabric.Hyperlinq includes bindings for collections available in the namespaces:

  • System - arrays, ArraySegment<>, Span<>, ReadOnlySpan<>, Memory<> and ReadOnlyMemory<>
  • System.Collections.Generic - List<>, Dictionary<>, Stack<>, ...
  • System.Collections.Immutable - ImmutableArray<>, ImmutableList<>, ImmutableStack<>, ...

For all these collections, once the directive is added, NetFabric.Hyperlinq will be used automatically:

public static void Example(ReadOnlySpan<int> span)
{
  var result = span
    .Where(item => item > 2)
    .Select(item => item * 2);

  foreach(var value in result)
    Console.WriteLine(value);
}

AsValueEnumerable and AsAsyncValueEnumerable

NetFabric.Hyperlinq implements operations (extension methods) for the interfaces:

  • IValueEnumerable<,>
  • IValueReadOnlyCollection<,>
  • IValueReadOnlyList<,>
  • IAsyncValueEnumerable<,>

These are extensions to the BCL enumerable interfaces and contain a second generic argument for the enumerator type so that it won't be boxed.

If the collection does not implement any of these, to use NetFabric.Hyperlinq operations, you have to use the conversion methods AsValueEnumerable() or AsAsyncValueEnumerable(). (Except for the BCL collections where specific bindings are provided.)

In the following example, AsValueEnumerable() converts IReadOnlyList<> to IValueReadOnlyList<>. The subsequent operations used are the ones implemented in NetFabric.Hyperlinq:

public static void Example(IReadOnlyList<int> list)
{
  var result = list
    .AsValueEnumerable()
    .Where(item => item > 2)
    .Select(item => item * 2);

  foreach(var value in result)
    Console.WriteLine(value);
}

All value enumeration interfaces derive from IEnumerable<> or IAsyncEnumerable so, if an operation is not available in NetFabric.Hyperlinq, it will automatically drop to the System.Linq implementation.

OrderByDescending() is not yet available in Netfabric.Hyperlinq but can still be used without requiring any conversion:

public static void Example(IReadOnlyList<int> list)
{
  var result = list
    .AsValueEnumerable()
    .Where(item => item > 2)
    .OrderByDescending(item => item) // is not yet available in Netfabric.Hyperlinq
    .AsValueEnumerable()
    .Select(item => item * 2);

  foreach(var value in result)
    Console.WriteLine(value);
}

To add Netfabric.Hyperlinq operations after a System.Linq operation, simply add one more AsValueEnumerable() or AsAsyncValueEnumerable().

Generation operations

In NetFabric.Hyperlinq, the generation operations like Empty(), Range(), Repeat() and Return() are static methods implemented in the static class ValueEnumerable. To use the equivalent operations from NetFabric.Hyperlinq, simply replace Enumerable for ValueEnumerable.

public static void Example(int count)
{
  var source = ValueEnumerable
    .Range(0, count)
    .Select(item => item * 2);

  foreach(var value in source)
    Console.WriteLine(value);
}

Method return types

Usually, when returning a query, it's used IEnumerable<> as the method return type:

public static IEnumerable<int> Example(int count)
  => ValueEnumerable
    .Range(0, count)
    .Select(value => value * 2);

This allows the caller to use System.Linq or a foreach loop to pull and process the result. NetFabric.Hyperlinq can also be used but the AsValueEnumerable() conversion method has to be used.

The operation in NetFabric.Hyperlinq are implemented so that they return the highest level enumeration interface possible. For example, the Range() operation returns IValueReadOnlyList<,> and the subsequent Select() does not change this. IValueReadOnlyList<,> derives from IReadOnlyList<> so, we can change the method to return this interface:

public static IReadOnlyList<int> Example(int count)
  => ValueEnumerable
    .Range(0, count)
    .Select(value => value * 2);

Now, the caller is free to use the enumerator or the indexer, which are provided by this interface. This means that, all previous methods of iteration can be used plus the for loops, which is much more efficient. The indexer performs fewer internal operations and doesn't need an enumerator instance. NetFabric.Hyperlinq can also be used and the AsValueEnumerable() conversion method still has to be used but, NetFabric.Hyperlinq will now use the indexer.

Otherwise, NetFabric.Hyperlinq will use enumerators. It implements all enumerators as value types. This allows the enumerators not to be allocated on the heap and calls to its methods to be non-virtual. The IEnumerable<> interface, and all other derived BCL interfaces, convert the enumerator to the IEnumerator<> interface. This results in the enumerator to be boxed, undoing the mentioned benefits.

NetFabric.Hyperlinq defines enumerable interfaces that contain the enumerator type as a generic parameter. This allows the caller to use it without boxing. Consider changing the method to return one of these interfaces:

public static IValueReadOnlyList<int, ReadOnlyList.SelectEnumerable<ValueEnumerable.RangeEnumerable, int, int>.DisposableEnumerator> Example(int count)
  => ValueEnumerable
    .Range(0, count)
    .Select(value => value * 2);

The caller is now able to use NetFabric.Hyperlinq without requiring the AsValueEnumerable() conversion method. In this case, it will use the indexer in all subsequent operations but the enumerator is still available. In other cases (IValueEnumerable<,>, IValueReadOnlyCollection<,> and IAsyncValueEnumerable<,>) it will use the enumerator.

NetFabric.Hyperlinq also implements the enumerables as value types. Returning an interface means that the enumerable will still be boxed. If you want to also avoid this, consider changing the return type to be the actual enumerable type. In this case:

public static ReadOnlyList.SelectEnumerable<ValueEnumerable.RangeEnumerable, int, int> Example(int count)
  => ValueEnumerable
    .Range(0, count)
    .Select(value => value * 2);

NOTE: Returning the enumerable type or a value enumeration interface, allows major performance improvements but creates a library design issue. Changes in the method implementation may result in changes to the retun type. This is a breaking change. This is an issue on the public API but not so much for the private and internal methods. Take this into consideration when deciding on the return type.

Composition

NetFabric.Hyperlinq operations can be composed just like with System.Linq. The difference is on how each one optimizes the internals to reduce the number of enumerators required to iterate the values.

Both System.Linq and NetFabric.Hyperlinq optimize the code in the following example so that only one enumerator is used to perform both the Where() and the Select():

var result = source
    .Where(item => item > 2)
    .Select(item => item * 2);

But, System.Linq does not do the same for this other example:

var result = source
    .Where(item => item > 2)
    .First();

System.Linq has a second overload for methods, like First() and Single(), that take the predicate as a parameter and allow the Where() to be removed. In NetFabric.Hyperlinq this is not required. With the intention of reducing the code to be maintained and tested, these other overloads actually are not available in NetFabric.Hyperlinq.

NetFabric.Hyperlinq includes many more composition optimizations. In the following code, only one enumerator is used, and only because of the Where() operation. Otherwise, the indexer would have been used instead. Also, the Select() is applied after First(), so that it's applied to only to the resulting item:

var result = array
    .Skip(1)
    .Take(10)
    .Where(item => item > 2)
    .Select(item => item * 2)
    .First();

Option

In System.Linq, the aggregation operations like First(), Single() and ElementAt(), throw an exception when the source has no items. Often, empty collections are a valid scenario and exception handling is very slow. System.Linq has alternative methods like FirstOrDefault(), SingleOrDefault() and ElementAtOrDefault(), that return the default value instead of throwing. This is still an issue when the items are value-typed, where there's no way to distinguish between an empty collection and a valid item.

In NetFabric.Hyperlinq, aggregation operations return an Option<> type. This is similar in behavior to the Nullable<> but it can contain reference types.

Here's a small example using First():

var result = source.First();
if (result.IsSome)
  Console.WriteLine(result.Value);

It also provides a deconstructor so, you can convert it to a tuple:

var (isSome, value) = source.First();
if (isSome)
  Console.WriteLine(value);

If you prefer a more functional approach, you can use Match() to specify the value returned when the collection has values and when it's empty. Here's how to use it to define the previous behavior of First() and FirstOrDefault():

var first = source.First().Match(
  item => item,
  () => throw new InvalidOperationException("Sequence contains no elements"));

var firstOrDefault = source.First().Match(
  item => item,
  () => default);

Console.WriteLine(first);
Console.WriteLine(firstOrDefault);

Match() can also be used to define actions:

source.First().Match(
  item => Console.WriteLine(item),
  () => { });

The NetFabric.Hyperlinq operations can be applied to Option<>, including Where(), Select() and SelectMany(). These return another Option<> with the predicate/selector applied to the value, if it exists.

source.First().Where(item => item > 2).Match(
  item => Console.WriteLine(item),
  () => { });

Documentation

Articles explaining implementation:

Supported operations

  • Aggregation
    • Count()
  • Conversion
    • AsEnumerable()
    • AsValueEnumerable()
    • ToArray()
    • ToList()
    • ToDictionary(Selector<TSource, TKey>)
    • ToDictionary(Selector<TSource, TKey>, IEqualityComparer<TKey>)
    • ToDictionary(Selector<TSource, TKey>, Selector<TSource, TElement>)
    • ToDictionary(Selector<TSource, TKey>, Selector<TSource, TElement>, IEqualityComparer<TKey>)
  • Element
    • ElementAt()
    • First()
    • Single()
  • Filtering
    • Where(Predicate<TSource>)
    • Where(PredicateAt<TSource>)
  • Generation
    • Create(Func<TEnumerator>)
    • Empty()
    • Range(int, int)
    • Repeat(TSource, int)
    • Return(TSource)
  • Projection
    • Select(Selector<TSource, TResult>)
    • Select(SelectorAt<TSource, TResult>)
    • SelectMany(IValueEnumerable<TSource>)
  • Partitioning
    • Take(int)
    • Skip(int)
  • Quantifier
    • All(Predicate<TSource>)
    • All(PredicateAt<TSource>)
    • Any()
    • Any(Predicate<TSource>)
    • Any(PredicateAt<TSource>)
    • Contains(TSource)
    • Contains(TSource, IEqualityComparer<TSource>)
  • Set
    • Distinct(TSource)
    • Distinct(TSource, IEqualityComparer<TSource>)

Benchmarks

The repository contains a benchmarks project based on BenchmarkDotNet that compares NetFabric.Hyperlinq to System.Linq for many of the supported operations and its combinations.

References

Credits

The following open-source projects are used to build and test this project:

License

This project is licensed under the MIT license. See the LICENSE file for more info.

netfabric.hyperlinq's People

Contributors

aalmada avatar dependabot-preview[bot] avatar mend-bolt-for-github[bot] avatar

Watchers

James Cloos avatar

Recommend Projects

  • React photo React

    A declarative, efficient, and flexible JavaScript library for building user interfaces.

  • Vue.js photo Vue.js

    🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.

  • Typescript photo Typescript

    TypeScript is a superset of JavaScript that compiles to clean JavaScript output.

  • TensorFlow photo TensorFlow

    An Open Source Machine Learning Framework for Everyone

  • Django photo Django

    The Web framework for perfectionists with deadlines.

  • D3 photo D3

    Bring data to life with SVG, Canvas and HTML. 📊📈🎉

Recommend Topics

  • javascript

    JavaScript (JS) is a lightweight interpreted programming language with first-class functions.

  • web

    Some thing interesting about web. New door for the world.

  • server

    A server is a program made to process requests and deliver data to clients.

  • Machine learning

    Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.

  • Game

    Some thing interesting about game, make everyone happy.

Recommend Org

  • Facebook photo Facebook

    We are working to build community through open source technology. NB: members must have two-factor auth.

  • Microsoft photo Microsoft

    Open source projects and samples from Microsoft.

  • Google photo Google

    Google ❤️ Open Source for everyone.

  • D3 photo D3

    Data-Driven Documents codes.