composewell/streamly
1
1
Fork 0
mirror of https://github.com/composewell/streamly.git synced 2024-11-10 12:47:22 +03:00
Code Issues Packages Projects Releases Wiki Activity

remove the append benchmark

Browse Source 
it is already covered by the generation benchmarks
This commit is contained in:
Harendra Kumar 2018-06-12 14:51:38 +05:30
parent 9790107a63
commit b9e5e424a7
2 changed files with 12 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
benchmark/Linear.hs
View File

@ -26,9 +26,6 @@ benchSrcIO
benchSrcIO t name f
= bench name $ nfIO $ randomRIO (1,1000) >>= Ops.toNull t . f
benchIOAppend :: (NFData b) => String -> (Int -> IO b) -> Benchmark
benchIOAppend name f = bench name $ nfIO $ randomRIO (1,1000) >>= f
{-
_benchId :: NFData b => String -> (Ops.Stream m Int -> Identity b) -> Benchmark
_benchId name f = bench name $ nf (runIdentity . f) (Ops.source 10)
@ -40,10 +37,10 @@ main = do
[ bgroup "serially"
[ bgroup "generation"
[ benchSrcIO serially "unfoldr" $ Ops.sourceUnfoldr
, benchSrcIO serially "fromFoldable" Ops.sourceFromFoldable
, benchSrcIO serially "foldMapWith" Ops.sourceFoldMapWith
, benchSrcIO serially "unfoldrM" Ops.sourceUnfoldrM
, benchSrcIO serially "fromFoldable" Ops.sourceFromFoldable
, benchSrcIO serially "fromFoldableM" Ops.sourceFromFoldableM
, benchSrcIO serially "foldMapWith" Ops.sourceFoldMapWith
, benchSrcIO serially "foldMapWithM" Ops.sourceFoldMapWithM
]
, bgroup "elimination"
@ -66,7 +63,6 @@ main = do
, benchIO "drop-all" Ops.dropAll
, benchIO "dropWhile-true" Ops.dropWhileTrue
]
, benchIOAppend "append" $ Ops.append serially
, benchIO "zip" $ Ops.zip
, bgroup "compose"
[ benchIO "mapM" Ops.composeMapM
@ -85,45 +81,41 @@ main = do
, bgroup "asyncly"
[ -- benchIO "unfoldr" $ Ops.toNull asyncly
-- , benchSrcIO asyncly "fromFoldable" Ops.sourceFromFoldable
benchSrcIO asyncly "foldMapWith" Ops.sourceFoldMapWith
, benchSrcIO asyncly "unfoldrM" Ops.sourceUnfoldrM
benchSrcIO asyncly "unfoldrM" Ops.sourceUnfoldrM
, benchSrcIO asyncly "fromFoldableM" Ops.sourceFromFoldableM
, benchSrcIO asyncly "foldMapWith" Ops.sourceFoldMapWith
, benchSrcIO asyncly "foldMapWithM" Ops.sourceFoldMapWithM
, benchIO "mapM" $ Ops.mapM asyncly
, benchIOAppend "append" $ Ops.append asyncly
]
, bgroup "wAsyncly"
[ -- benchIO "unfoldr" $ Ops.toNull wAsyncly
-- , benchSrcIO wAsyncly "fromFoldable" Ops.sourceFromFoldable
benchSrcIO wAsyncly "foldMapWith" Ops.sourceFoldMapWith
, benchSrcIO wAsyncly "unfoldrM" Ops.sourceUnfoldrM
benchSrcIO wAsyncly "unfoldrM" Ops.sourceUnfoldrM
, benchSrcIO wAsyncly "fromFoldableM" Ops.sourceFromFoldableM
, benchSrcIO wAsyncly "foldMapWith" Ops.sourceFoldMapWith
, benchSrcIO wAsyncly "foldMapWithM" Ops.sourceFoldMapWithM
, benchIO "mapM" $ Ops.mapM wAsyncly
, benchIOAppend "append" $ Ops.append wAsyncly
]
-- unfoldr and fromFoldable are always serial and thereofore the same for
-- all stream types.
, bgroup "aheadly"
[ -- benchIO "unfoldr" $ Ops.toNull aheadly
-- , benchSrcIO aheadly "fromFoldable" Ops.sourceFromFoldable
benchSrcIO aheadly "foldMapWith" Ops.sourceFoldMapWith
, benchSrcIO aheadly "unfoldrM" Ops.sourceUnfoldrM
benchSrcIO aheadly "unfoldrM" Ops.sourceUnfoldrM
, benchSrcIO aheadly "fromFoldableM" Ops.sourceFromFoldableM
, benchSrcIO aheadly "foldMapWith" Ops.sourceFoldMapWith
, benchSrcIO aheadly "foldMapWithM" Ops.sourceFoldMapWithM
, benchIO "mapM" $ Ops.mapM aheadly
, benchIOAppend "append" $ Ops.append aheadly
]
-- XXX need to use smaller streams to finish in reasonable time
, bgroup "parallely"
[ --benchIO "unfoldr" $ Ops.toNull parallely
--, benchSrcIO parallely "fromFoldable" Ops.sourceFromFoldable
benchSrcIO parallely "foldMapWith" Ops.sourceFoldMapWith
, benchSrcIO parallely "unfoldrM" Ops.sourceUnfoldrM
benchSrcIO parallely "unfoldrM" Ops.sourceUnfoldrM
, benchSrcIO parallely "fromFoldableM" Ops.sourceFromFoldableM
, benchSrcIO parallely "foldMapWith" Ops.sourceFoldMapWith
, benchSrcIO parallely "foldMapWithM" Ops.sourceFoldMapWithM
, benchIO "mapM" $ Ops.mapM parallely
, benchIOAppend "append" $ Ops.append parallely
-- Zip has only one parallel flavor
, benchIO "zip" $ Ops.zipAsync
]

15
benchmark/LinearOps.hs
View File

@ -11,14 +11,13 @@ module LinearOps where
import Prelude
(Monad, Int, (+), ($), (.), return, fmap, even, (>), (<=),
subtract, undefined, Maybe(..), Monoid, foldMap)
subtract, undefined, Maybe(..))
import qualified Streamly as S
import qualified Streamly.Prelude as S
value, appendValue, maxValue :: Int
value, maxValue :: Int
value = 100000
appendValue = 100000
maxValue = value + 1000
-------------------------------------------------------------------------------
@ -150,16 +149,6 @@ zip src = transform $ (S.zipWith (,) src src)
zipAsync src = transform $ (S.zipAsyncWith (,) src src)
concat _n = return ()
-------------------------------------------------------------------------------
-- Append
-------------------------------------------------------------------------------
{-# INLINE append #-}
append
:: (Monoid (t m Int), Monad m, Monad (t m))
=> (t m Int -> S.SerialT m Int) -> Int -> m ()
append t n = runStream $ t $ foldMap return [n..n+appendValue]
-------------------------------------------------------------------------------
-- Composition
-------------------------------------------------------------------------------