conduit-1.3.0: benchmarks/unfused.hs

{-# LANGUAGE RankNTypes, BangPatterns #-}
-- Compare low-level, fused, unfused, and partially fused
import Data.Conduit
import qualified Data.Conduit.List as CL
import Gauge.Main

-- | unfused
enumFromToC :: (Eq a, Monad m, Enum a) => a -> a -> ConduitT i a m ()
enumFromToC x0 y =
    loop x0
  where
    loop x
        | x == y = yield x
        | otherwise = yield x >> loop (succ x)
{-# INLINE enumFromToC #-}

-- | unfused
mapC :: Monad m => (a -> b) -> ConduitT a b m ()
mapC f = awaitForever $ yield . f
{-# INLINE mapC #-}

-- | unfused
foldC :: Monad m => (b -> a -> b) -> b -> ConduitT a o m b
foldC f =
    loop
  where
    loop !b = await >>= maybe (return b) (loop . f b)
{-# INLINE foldC #-}

main :: IO ()
main = defaultMain
    [ bench "low level" $ flip whnf upper0 $ \upper ->
        let loop x t
                | x > upper = t
                | otherwise = loop (x + 1) (t + ((x * 2) + 1))
         in loop 1 0
    , bench "completely fused" $ flip whnf upper0 $ \upper ->
              runConduitPure
            $ CL.enumFromTo 1 upper
           .| CL.map (* 2)
           .| CL.map (+ 1)
           .| CL.fold (+) 0
    , bench "runConduit, completely fused" $ flip whnf upper0 $ \upper ->
             runConduitPure
           $ CL.enumFromTo 1 upper
          .| CL.map (* 2)
          .| CL.map (+ 1)
          .| CL.fold (+) 0
    , bench "completely unfused" $ flip whnf upper0 $ \upper ->
              runConduitPure
            $ enumFromToC 1 upper
           .| mapC (* 2)
           .| mapC (+ 1)
           .| foldC (+) 0
    , bench "beginning fusion" $ flip whnf upper0 $ \upper ->
              runConduitPure
            $ (CL.enumFromTo 1 upper .| CL.map (* 2))
           .| mapC (+ 1)
           .| foldC (+) 0
    , bench "middle fusion" $ flip whnf upper0 $ \upper ->
              runConduitPure
            $ enumFromToC 1 upper
           .| (CL.map (* 2) .| CL.map (+ 1))
           .| foldC (+) 0
    , bench "ending fusion" $ flip whnf upper0 $ \upper ->
              runConduitPure
            $ enumFromToC 1 upper
           .| mapC (* 2)
           .| (CL.map (+ 1) .| CL.fold (+) 0)
    , bench "performance of CL.enumFromTo without fusion" $ flip whnf upper0 $ \upper ->
              runConduitPure
            $ CL.enumFromTo 1 upper
           .| mapC (* 2)
           .| (CL.map (+ 1) .| CL.fold (+) 0)
    ]
  where
    upper0 = 100000 :: Int