composewell/streamly
1
1
Fork 0
mirror of https://github.com/composewell/streamly.git synced 2024-09-20 07:58:27 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fix draining of threads (serial instead of parallel)

Browse Source
This commit is contained in:
Harendra Kumar 2017-08-22 17:01:07 +05:30
parent 04fef4fe4f
commit 6ec80a0f92
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Asyncly/AsyncT.hs
View File

@ -263,7 +263,7 @@ pullSideDispatch :: MonadAsync m
pullSideDispatch ctx m1 m2 = AsyncT $ \_ stp yld -> do
let chan = childChannel ctx
_ <- doFork (push (ctx {pullSide = False}) m1) (handlePushException chan)
liftIO $ threadDelay 0
-- liftIO $ threadDelay 0
liftIO $ writeIORef (pendingWork ctx) m2
(runAsyncT (pullDispatch ctx False)) Nothing stp yld
@ -307,7 +307,7 @@ pullFork m1 m2 = AsyncT $ \_ stp yld -> do
newContext m = do
channel <- atomically newTChan
work <- liftIO $ newIORef (m <|> pullDrain channel)
work <- liftIO $ newIORef (m <> pullDrain channel)
return $ Context { childChannel = channel
, pullSide = True
, pendingWork = work