summaryrefslogtreecommitdiff
path: root/src/Control/Concurrent
diff options
context:
space:
mode:
Diffstat (limited to 'src/Control/Concurrent')
-rw-r--r--src/Control/Concurrent/Lifted/Instrument.hs2
-rw-r--r--src/Control/Concurrent/Tasks.hs2
2 files changed, 2 insertions, 2 deletions
diff --git a/src/Control/Concurrent/Lifted/Instrument.hs b/src/Control/Concurrent/Lifted/Instrument.hs
index 4aa9268f..91d4c0a4 100644
--- a/src/Control/Concurrent/Lifted/Instrument.hs
+++ b/src/Control/Concurrent/Lifted/Instrument.hs
@@ -43,7 +43,7 @@ globals = unsafePerformIO $ newMVar $ GlobalState
43 43
44 44
45forkIO :: IO () -> IO ThreadId 45forkIO :: IO () -> IO ThreadId
46forkIO = fork 46forkIO = GHC.forkIO
47{-# INLINE forkIO #-} 47{-# INLINE forkIO #-}
48 48
49forkOS :: MonadBaseControl IO m => m () -> m ThreadId 49forkOS :: MonadBaseControl IO m => m () -> m ThreadId
diff --git a/src/Control/Concurrent/Tasks.hs b/src/Control/Concurrent/Tasks.hs
index 287542ee..da2e589e 100644
--- a/src/Control/Concurrent/Tasks.hs
+++ b/src/Control/Concurrent/Tasks.hs
@@ -20,7 +20,7 @@ withTaskGroup :: String -> Int -> (TaskGroup -> IO ()) -> IO ()
20withTaskGroup glabel numslots action = do 20withTaskGroup glabel numslots action = do
21 tg <- atomically $ newTChan 21 tg <- atomically $ newTChan
22 cnt <- atomically $ newTVar 0 22 cnt <- atomically $ newTVar 0
23 thread <- fork $ do 23 thread <- forkIO $ do
24 myThreadId >>= flip labelThread glabel 24 myThreadId >>= flip labelThread glabel
25 fix $ \again -> do 25 fix $ \again -> do
26 (slot, (lbl,task)) <- atomically $ do 26 (slot, (lbl,task)) <- atomically $ do