parallel_stream alternatives and similar packages
Based on the "Algorithms and Data structures" category.
Alternatively, view parallel_stream alternatives based on common mentions on social networks and blogs.
-
-
-
matrex
A blazing fast matrix library for Elixir/Erlang with C implementation using CBLAS. -
simple_bayes
A Naive Bayes machine learning implementation in Elixir. -
exconstructor
An Elixir library for generating struct constructors that handle external data with ease. -
erlang-algorithms
Implementations of popular data structures and algorithms -
remodel
:necktie: An Elixir presenter package used to transform map structures. "ActiveModel::Serializer for Elixir" -
MapDiff
Calculates the difference between two (nested) maps, and returns a map representing the patch of changes. -
merkle_tree
:evergreen_tree: Merkle Tree implementation in pure Elixir -
sfmt
sfmt-erlang: SIMD-oriented Fast Mersenne Twister (SFMT) for Erlang -
bloomex
:hibiscus: A pure Elixir implementation of Scalable Bloom Filters -
graphmath
An Elixir library for performing 2D and 3D mathematics. -
exmatrix
Elixir library implementing a parallel matrix multiplication algorithm and other utilities for working with matrices. Used for benchmarking computationally intensive concurrent code. -
the_fuzz
String metrics and phonetic algorithms for Elixir (e.g. Dice/Sorensen, Hamming, Jaccard, Jaro, Jaro-Winkler, Levenshtein, Metaphone, N-Gram, NYSIIS, Overlap, Ratcliff/Obershelp, Refined NYSIIS, Refined Soundex, Soundex, Weighted Levenshtein) -
DeepMerge
Deep (recursive) merge for maps, keywords and others in Elixir -
dataframe
Package providing functionality similar to Python's Pandas or R's data.frame() -
ecto_materialized_path
Tree structure & hierarchy for ecto models -
parex
An elixir module for parallel execution of functions/processes -
Conrex
An Elixir implementation of the CONREC algorithm for topographic or isochrone maps. -
-
murmur
:speech_balloon: An implementation of the non-cryptographic hash Murmur3 -
bitmap
Bitmap implementation in Elixir using binaries and integers. Fast space efficient data structure for lookups -
paratize
Elixir library providing some handy parallel processing facilities that supports configuring number of workers and timeout. -
combination
A simple combinatorics library providing combination and permutation. -
Mappable
Simple module that provides unified, simple interface for converting between different dictionary-like data types in Elixir. -
exor_filter
Erlang nif for xor_filter. 'Faster and Smaller Than Bloom and Cuckoo Filters'.
Bot detection and prevention for Elixir/Phoenix applications
* Code Quality Rankings and insights are calculated and provided by Lumnify.
They vary from L1 to L5 with "L5" being the highest.
Do you think we are missing an alternative of parallel_stream or a related project?
|
Less time debugging, more time building
sponsored
scoutapm.com
|
Popular Comparisons
-
parallel_streamvsqex
-
parallel_streamvsbloomex
-
parallel_streamvseastar
-
parallel_streamvscuid
-
parallel_streamvsaruspex
|
Deliver Cleaner and Safer Code - Right in Your IDE of Choice!
sponsored
www.sonarlint.org
|
README
ParallelStream 
Parallelized stream implementation for elixir
What does it do?
Parallelize some stream operations in Elixir whilst keeping your stream in order. Operates with a worker pool.
How do I get it?
Add
{:parallel_stream, "~> 1.0.5"}
to your deps in mix.exs like so:
defp deps do
[
{:parallel_stream, "~> 1.0.5"}
]
end
Note: Elixir 1.1.0 is required
How to use
Do this to parallelize a map:
stream = 1..10 |> ParallelStream.map(fn i -> i * 2 end)
stream |> Enum.into([])
[2,4,6,8,10,12,14,16,18,20]
The generated stream is sorted the same as the input stream.
More supported functions are each (to produce side-effects):
1..100 |> ParallelStream.each(&IO.inspect/1)
filter:
stream = 1..20 |> ParallelStream.filter(fn i -> i |> rem(2) == 0 end)
stream |> Enum.into([])
[2,4,6,8,10,12,14,16,18,20]
and filter's counterpart, reject:
stream = 1..20 |> ParallelStream.reject(fn i -> i |> rem(2) == 0 end)
stream |> Enum.into([])
[1,3,5,7,9,11,13,15,17,19]
License
MIT
Contributions & Bugfixes are most welcome!
*Note that all licence references and agreements mentioned in the parallel_stream README section above
are relevant to that project's source code only.