fdf7e1f · streamly · git.iko.soy

git.iko.soy/streamly

increase the stream size for linear-async benchmarks

This is to make it the same as other benchmarks. We had to change the size of the extreme concatMapWith benchmark to keep it in reasonable time limits.

commitfdf7e1fdf919c28784cc75feb2c8e10aa068caa5 authorHarendra Kumar <harendra.kumar@gmail.com> dateThu 16 Jan 2020, 17:19 (7 years ago) parent22bfa72

1 file changed+10−10

compare with master

unifiedsplit

benchmark/LinearAsync.hs+10−10

benchmark/LinearAsync.hs+10−10

@@ -45,7 +45,7 @@ _benchId name f = bench name $ nf (runIdentity . f) (Ops.source 10)

4545-}

4646

4747defaultStreamSize :: Int

48−defaultStreamSize = 10000

48+defaultStreamSize = 100000

4949

5050main :: IO ()

5151main = do

@@ -72,8 +72,8 @@ main = do

7272 (Ops.concatStreamsWith async 2 (value `div` 2))

7373 , benchMonadicSrcIO "concatMapWith (sqrt x,sqrt x)"

7474 (Ops.concatStreamsWith async value2 value2)

75− , benchMonadicSrcIO "concatMapWith (x/2,2)"

76− (Ops.concatStreamsWith async (value `div` 2) 2)

75+ , benchMonadicSrcIO "concatMapWith (sqrt x * 2,sqrt x / 2)"

76+ (Ops.concatStreamsWith async (value2 * 2) (value2 `div` 2))

7777 ]

7878 , bgroup "wAsyncly"

7979 [ benchSrcIO wAsyncly "unfoldr" (Ops.sourceUnfoldr value)

@@ -102,10 +102,10 @@ main = do

102102 (Ops.concatStreamsWith wAsync 2 (value `div` 2))

103103 , benchMonadicSrcIO "concatMapWith (sqrt x,sqrt x)"

104104 (Ops.concatStreamsWith wAsync value2 value2)

105− , benchMonadicSrcIO "concatMapWith (x/2,2)"

106− (Ops.concatStreamsWith wAsync (value `div` 2) 2)

105+ , benchMonadicSrcIO "concatMapWith (sqrt x * 2,sqrt x / 2)"

106+ (Ops.concatStreamsWith wAsync (value2 * 2) (value2 `div` 2))

107107 ]

108− -- unfoldr and fromFoldable are always serial and thereofore the same for

108+ -- unfoldr and fromFoldable are always serial and therefore the same for

109109 -- all stream types.

110110 , bgroup "aheadly"

111111 [ benchSrcIO aheadly "unfoldr" (Ops.sourceUnfoldr value)

@@ -126,8 +126,8 @@ main = do

126126 (Ops.concatStreamsWith ahead 2 (value `div` 2))

127127 , benchMonadicSrcIO "concatMapWith (sqrt x,sqrt x)"

128128 (Ops.concatStreamsWith ahead value2 value2)

129− , benchMonadicSrcIO "concatMapWith (x/2,2)"

130− (Ops.concatStreamsWith ahead (value `div` 2) 2)

129+ , benchMonadicSrcIO "concatMapWith (sqrt x * 2,sqrt x / 2)"

130+ (Ops.concatStreamsWith ahead (value2 * 2) (value2 `div` 2))

131131 ]

132132 -- XXX need to use smaller streams to finish in reasonable time

133133 , bgroup "parallely"

@@ -148,8 +148,8 @@ main = do

148148 (Ops.concatStreamsWith parallel 2 (value `div` 2))

149149 , benchMonadicSrcIO "concatMapWith (sqrt x,sqrt x)"

150150 (Ops.concatStreamsWith parallel value2 value2)

151− , benchMonadicSrcIO "concatMapWith (x/2,2)"

152− (Ops.concatStreamsWith parallel (value `div` 2) 2)

151+ , benchMonadicSrcIO "concatMapWith (sqrt x * 2,sqrt x / 2)"

152+ (Ops.concatStreamsWith parallel (value2 * 2) (value2 `div` 2))

153153 ]

154154 , bgroup "zip"

155155 [ benchIO value "zip" Ops.zipAsync