Hoogle Search
Within LTS Haskell 24.52 (ghc-9.10.3)
Note that Stackage only displays results for the latest LTS and Nightly snapshot. Learn more.
-
streamly Streamly.Internal.Data.Channel No documentation available.
addThread :: MonadIO m => IORef (Set ThreadId) -> ThreadId -> m ()streamly Streamly.Internal.Data.Channel No documentation available.
allThreadsDone :: MonadIO m => IORef (Set ThreadId) -> m Boolstreamly Streamly.Internal.Data.Channel This is safe even if we are adding more threads concurrently because if a child thread is adding another thread then anyway workerThreads will not be empty.
boundThreads :: Bool -> Config -> Configstreamly Streamly.Internal.Data.Channel Spawn bound threads (i.e., spawn threads using forkOS instead of forkIO). The default value is False. Currently, this only takes effect only for concurrent folds.
delThread :: MonadIO m => IORef (Set ThreadId) -> ThreadId -> m ()streamly Streamly.Internal.Data.Channel No documentation available.
dumpRunningThreads :: Show a => IORef a -> IO Stringstreamly Streamly.Internal.Data.Channel No documentation available.
getMaxThreads :: Config -> Limitstreamly Streamly.Internal.Data.Channel No documentation available.
maxThreads :: Int -> Config -> Configstreamly Streamly.Internal.Data.Channel Specify the maximum number of threads that can be spawned by the channel. A value of 0 resets the thread limit to default, a negative value means there is no limit. The default value is 1500. When the actions in a stream are IO bound, having blocking IO calls, this option can be used to control the maximum number of in-flight IO requests. When the actions are CPU bound this option can be used to control the amount of CPU used by the stream.
minThreadDelay :: NanoSecond64streamly Streamly.Internal.Data.Channel This is a magic number and it is overloaded, and used at several places to achieve batching:
- If we have to sleep to slowdown this is the minimum period that we accumulate before we sleep. Also, workers do not stop until this much sleep time is accumulated.
- Collected latencies are computed and transferred to measured latency after a minimum of this period.
modifyThread :: MonadIO m => IORef (Set ThreadId) -> MVar () -> ThreadId -> m ()streamly Streamly.Internal.Data.Channel No documentation available.