git.iko.soy/streamly
on master help sign in
Add serial_ benchmark
e052c82Harendra Kumar
benchmark/Streamly/Benchmark/Data/Fold.hs+10−12
compare with master
unifiedsplit
@@ -98,6 +98,15 @@ splitAllAny value =
98 (FL.any (> value))
98 (FL.any (> value))
99 )
99 )
100
100
101+{-# INLINE serial_ #-}
102+serial_ :: Monad m => Int -> SerialT m Int -> m Bool
103+serial_ value =
104+ IP.fold
105+ (FL.serial_
106+ (FL.all (<= (value `div` 2)))
107+ (FL.any (> value))
108+ )
109+
101{-# INLINE shortest #-}
110{-# INLINE shortest #-}
102shortest :: Monad m => SerialT m Int -> m (Either Int Int)
111shortest :: Monad m => SerialT m Int -> m (Either Int Int)
103shortest = IP.fold (FL.shortest FL.sum FL.length)
112shortest = IP.fold (FL.shortest FL.sum FL.length)
@@ -106,18 +115,6 @@ shortest = IP.fold (FL.shortest FL.sum FL.length)
106longest :: Monad m => SerialT m Int -> m (Either Int Int)
115longest :: Monad m => SerialT m Int -> m (Either Int Int)
107longest = IP.fold (FL.longest FL.sum FL.length)
116longest = IP.fold (FL.longest FL.sum FL.length)
108
117
109−{-
110−{-# INLINE split_ #-}
111−split_ :: Monad m
112− => Int -> SerialT m Int -> m ()
113−split_ value =
114− IP.fold
115− (FL.split_
116− (FL.all (<= (value `div` 2)))
117− (FL.any (> value))
118− )
119−-}
120−
121-------------------------------------------------------------------------------
118-------------------------------------------------------------------------------
122-- Distributing by parallel application
119-- Distributing by parallel application
123-------------------------------------------------------------------------------
120-------------------------------------------------------------------------------
@@ -316,6 +313,7 @@ o_1_space_serial_composition value =
316 [ bgroup
313 [ bgroup
317 "composition"
314 "composition"
318 [ benchIOSink value "serialWith (all, any)" $ splitAllAny value
315 [ benchIOSink value "serialWith (all, any)" $ splitAllAny value
316+ , benchIOSink value "serial_ (all, any)" $ serial_ value
319 , benchIOSink value "tee (all, any)" $ teeAllAny value
317 , benchIOSink value "tee (all, any)" $ teeAllAny value
320 , benchIOSink value "many drain (take 1)" many
318 , benchIOSink value "many drain (take 1)" many
321 , benchIOSink value "shortest (sum, length)" shortest
319 , benchIOSink value "shortest (sum, length)" shortest
src/Streamly/Internal/Data/Fold.hs+1
@@ -157,6 +157,7 @@ module Streamly.Internal.Data.Fold
157
157
158 -- ** Serial Append
158 -- ** Serial Append
159 , serialWith
159 , serialWith
160+ , serial_
160 -- , tail
161 -- , tail
161 -- , init
162 -- , init
162 , splitAt -- spanN
163 , splitAt -- spanN