@@ -586,69 +586,6 @@ benchmark linear
586586 build-depends: template-haskell >= 2.14 && < 2.16
587587 , inspection-testing >= 0.4 && < 0.5
588588
589−benchmark linear-async
590− import: bench-options-threaded
591− cpp-options: -DLINEAR_ASYNC
592− type: exitcode-stdio-1.0
593− hs-source-dirs: benchmark
594− main-is: LinearAsync.hs
595− other-modules: Streamly.Benchmark.Prelude
596− build-depends:
597− streamly
598− , base >= 4.8 && < 5
599− , deepseq >= 1.4.1 && < 1.5
600− , random >= 1.0 && < 2.0
601− , gauge >= 0.2.4 && < 0.3
602− if impl(ghc < 8.0)
603− build-depends:
604− transformers >= 0.4 && < 0.6
605− if flag(inspection)
606− build-depends: template-haskell >= 2.14 && < 2.16
607− , inspection-testing >= 0.4 && < 0.5
608−
609−benchmark linear-async-long
610− import: bench-options-threaded
611− cpp-options: -DLONG_BENCHMARKS
612− type: exitcode-stdio-1.0
613− hs-source-dirs: benchmark
614− main-is: LinearAsync.hs
615− other-modules: Streamly.Benchmark.Prelude
616− if flag(dev)
617− buildable: True
618− build-depends:
619− streamly
620− , base >= 4.8 && < 5
621− , deepseq >= 1.4.1 && < 1.5
622− , random >= 1.0 && < 2.0
623− , gauge >= 0.2.4 && < 0.3
624− if impl(ghc < 8.0)
625− build-depends:
626− transformers >= 0.4 && < 0.6
627− if flag(inspection)
628− build-depends: template-haskell >= 2.14 && < 2.16
629− , inspection-testing >= 0.4 && < 0.5
630− else
631− buildable: False
632−
633−benchmark linear-rate
634− import: bench-options-threaded
635− type: exitcode-stdio-1.0
636− hs-source-dirs: benchmark
637− main-is: LinearRate.hs
638− other-modules: Streamly.Benchmark.Prelude
639− build-depends:
640− streamly
641− , base >= 4.8 && < 5
642− , deepseq >= 1.4.1 && < 1.5
643− , random >= 1.0 && < 2.0
644− , gauge >= 0.2.4 && < 0.3
645− if impl(ghc < 8.0)
646− build-depends:
647− transformers >= 0.4 && < 0.6
648− if flag(inspection)
649− build-depends: template-haskell >= 2.14 && < 2.16
650− , inspection-testing >= 0.4 && < 0.5
651−
652589benchmark nested
653590 import: bench-options
654591 type: exitcode-stdio-1.0
@@ -749,6 +686,89 @@ benchmark fileio
749686 build-depends: template-haskell >= 2.14 && < 2.16
750687 , inspection-testing >= 0.4 && < 0.5
751688
689+-------------------------------------------------------------------------------
690+-- Threaded Benchmarks
691+-------------------------------------------------------------------------------
692+
693+benchmark linear-async
694+ import: bench-options-threaded
695+ cpp-options: -DLINEAR_ASYNC
696+ type: exitcode-stdio-1.0
697+ hs-source-dirs: benchmark
698+ main-is: LinearAsync.hs
699+ other-modules: Streamly.Benchmark.Prelude
700+ build-depends:
701+ streamly
702+ , base >= 4.8 && < 5
703+ , deepseq >= 1.4.1 && < 1.5
704+ , random >= 1.0 && < 2.0
705+ , gauge >= 0.2.4 && < 0.3
706+ if impl(ghc < 8.0)
707+ build-depends:
708+ transformers >= 0.4 && < 0.6
709+ if flag(inspection)
710+ build-depends: template-haskell >= 2.14 && < 2.16
711+ , inspection-testing >= 0.4 && < 0.5
712+
713+benchmark linear-async-long
714+ import: bench-options-threaded
715+ cpp-options: -DLONG_BENCHMARKS
716+ type: exitcode-stdio-1.0
717+ hs-source-dirs: benchmark
718+ main-is: LinearAsync.hs
719+ other-modules: Streamly.Benchmark.Prelude
720+ if flag(dev)
721+ buildable: True
722+ build-depends:
723+ streamly
724+ , base >= 4.8 && < 5
725+ , deepseq >= 1.4.1 && < 1.5
726+ , random >= 1.0 && < 2.0
727+ , gauge >= 0.2.4 && < 0.3
728+ if impl(ghc < 8.0)
729+ build-depends:
730+ transformers >= 0.4 && < 0.6
731+ if flag(inspection)
732+ build-depends: template-haskell >= 2.14 && < 2.16
733+ , inspection-testing >= 0.4 && < 0.5
734+ else
735+ buildable: False
736+
737+benchmark nested-concurrent
738+ import: bench-options-threaded
739+ type: exitcode-stdio-1.0
740+ hs-source-dirs: benchmark
741+ main-is: NestedConcurrent.hs
742+ other-modules: NestedOps
743+ build-depends:
744+ streamly
745+ , base >= 4.8 && < 5
746+ , deepseq >= 1.4.1 && < 1.5
747+ , random >= 1.0 && < 2.0
748+ , gauge >= 0.2.4 && < 0.3
749+ if impl(ghc < 8.0)
750+ build-depends:
751+ transformers >= 0.4 && < 0.6
752+
753+benchmark linear-rate
754+ import: bench-options-threaded
755+ type: exitcode-stdio-1.0
756+ hs-source-dirs: benchmark
757+ main-is: LinearRate.hs
758+ other-modules: Streamly.Benchmark.Prelude
759+ build-depends:
760+ streamly
761+ , base >= 4.8 && < 5
762+ , deepseq >= 1.4.1 && < 1.5
763+ , random >= 1.0 && < 2.0
764+ , gauge >= 0.2.4 && < 0.3
765+ if impl(ghc < 8.0)
766+ build-depends:
767+ transformers >= 0.4 && < 0.6
768+ if flag(inspection)
769+ build-depends: template-haskell >= 2.14 && < 2.16
770+ , inspection-testing >= 0.4 && < 0.5
771+
752772benchmark concurrent
753773 import: bench-options-threaded
754774 type: exitcode-stdio-1.0