corpus.blog
41,554 blogs · 4,654,352 posts Claim your blog
Record · corpus.blog/posts/01a087e6-0500-723d-8da3-9aa1ac4d68c2

Parallel stream processing with zero-copy fan-out and sharding

stevana.github.io · published 23 January 2024

A record is what was published and who pointed at it. The text of the post is not held here: read it at the source, or at its Wayback capture.

Read the post at stevana.github.io Wayback capture
0blogs citing
First cited
—
Most recent
—
Rank this month
not ranked
External links
64
Words captured
12,031

Cited by

No blog we hold has cited this post yet.

Links from this post

Link
Host
https://en.wikipedia.org/wiki/Disruptor_(software
en.wikipedia.org
https://www.youtube.com/watch?v=U3eo49nVxcA&t=1949s
youtube.com
https://youtu.be/qAKrMdUycb8?t=3058
youtu.be
https://www.youtube.com/watch?v=_KvFapRkR9I
youtube.com
https://www.reactivemanifesto.org/
reactivemanifesto.org
https://youtu.be/OqsAGFExFgQ?t=2532
youtu.be
https://youtu.be/bo5WL5IQAd0?t=2494
youtu.be
https://www.youtube.com/watch?v=8M0wTX6EOVI
youtube.com
https://dl.acm.org/doi/10.1145/366663.366704
dl.acm.org
https://dl.acm.org/doi/10.1145/363744.363749
dl.acm.org
https://en.wikipedia.org/wiki/Dataflow_programming
en.wikipedia.org
https://jpaulm.github.io/fbp/index.html
jpaulm.github.io
http://doc.cat-v.org/unix/pipes/
doc.cat-v.org
https://en.wikipedia.org/wiki/GNU_parallel
en.wikipedia.org
https://hackage.haskell.org/package/conduit
hackage.haskell.org
https://hackage.haskell.org/package/pipes
hackage.haskell.org
https://clojure.org/reference/transducers
clojure.org
https://doc.akka.io/docs/akka/current/stream/index.html
doc.akka.io
https://youtu.be/XPlXNUXmcgE?t=2783
youtu.be
https://doc.akka.io/docs/akka/current/stream/stream-refs.html
doc.akka.io
https://github.com/apache/incubator-pekko-management
github.com
https://aeron.io/
aeron.io
https://github.com/LMAX-Exchange/disruptor/wiki/Disruptor-Wizard
github.com
https://doc.akka.io/docs/akka/current/stream/stream-graphs.html
doc.akka.io
https://github.com/turion/essence-of-live-coding
github.com
https://github.com/stevana/pipelining-with-disruptor/blob/main/src/QueueDeployment.hs
github.com
https://github.com/stevana/pipelining-with-disruptor/blob/main/src/ModelIO.hs
github.com
https://hackage.haskell.org/package/vector
hackage.haskell.org
http://simonmar.github.io/bib/papers/assoc.pdf
simonmar.github.io
https://github.com/stevana/pipelining-with-disruptor/blob/main/src/RingBufferClass.hs
github.com
https://github.com/stevana/pipelining-with-disruptor/blob/main/src/LibMain/Sleep.hs
github.com
https://github.com/stevana/pipelining-with-disruptor/blob/main/src/Pipeline.hs
github.com
https://github.com/stevana/pipelining-with-disruptor/blob/main/src/LibMain/WordCount.hs
github.com
https://github.com/stevana/pipelining-with-disruptor/
github.com
https://www.haskell.org/ghcup/
haskell.org
https://github.com/stevana/pipelining-with-disruptor/tree/main/src/LibMain
github.com
https://github.com/stevana/pipelining-with-disruptor/blob/main/src/LibMain/Copying.hs
github.com
https://old.reddit.com/r/haskell/comments/19ef2b6/parallel_stream_processing_with_zerocopy_fanout/kjhfyfk/
old.reddit.com
https://ghc.gitlab.haskell.org/ghc/doc/users_guide/exts/arrows.html
ghc.gitlab.haskell.org
https://inria.hal.science/inria-00306565
inria.hal.science
https://www.infoq.com/presentations/Thinking-Parallel-Programming/
infoq.com
https://youtube.com/watch?v=DCdGlxBbKU4
youtube.com
https://github.com/mikeb01/folklore/tree/master/src/main/java/performance
github.com
https://www.oreilly.com/radar/the-world-beyond-batch-streaming-101/
oreilly.com
https://www.oreilly.com/radar/the-world-beyond-batch-streaming-102/
oreilly.com
https://people.eecs.berkeley.edu/~brewer/papers/SEDA-sosp.pdf
people.eecs.berkeley.edu
https://www.microsoft.com/en-us/research/publication/naiad-a-timely-dataflow-system-2/
microsoft.com
https://www.youtube.com/watch?v=2XrYd1W5GLo
youtube.com
https://mazzo.li/posts/fast-pipes.html
mazzo.li
https://man.freebsd.org/cgi/man.cgi?query=netmap&sektion=4
man.freebsd.org
The output of Linux pipes can be indeterministic Read at the source ↗
gibney.org
https://www.youtube.com/watch?v=Mc3tTRkjCvE
youtube.com
https://www.youtube.com/watch?v=ipceTuJlw-M
youtube.com
https://discourse.haskell.org/t/parallel-stream-processing-with-zero-copy-fan-out-and-sharding/8632
discourse.haskell.org
https://old.reddit.com/r/haskell/comments/19ef2b6/parallel_stream_processing_with_zerocopy_fanout/
old.reddit.com
https://lobste.rs/s/mvgdev/parallel_stream_processing_with_zero
lobste.rs
https://archive.org/details/bstj40-3-669
archive.org
http://flint.cs.yale.edu/trifonov/papers/pfrp.pdf
flint.cs.yale.edu
http://conal.net/papers/push-pull-frp/push-pull-frp.pdf
conal.net
http://conal.net/papers/compiling-to-categories/
conal.net
https://github.com/phadej/overloaded/blob/master/src/Overloaded/Categories.hs
github.com
https://github.com/stevana/pipelined-state-machines/tree/main/src/Disruptor/MP
github.com
https://github.com/LMAX-Exchange/disruptor
github.com
https://en.wikipedia.org/wiki/AoS_and_SoA
en.wikipedia.org
Elsewhere on stevana.github.io (5)