diff options
-rw-r--r-- | tasks/src/Control/Concurrent/Tasks.hs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/tasks/src/Control/Concurrent/Tasks.hs b/tasks/src/Control/Concurrent/Tasks.hs index da2e589e..73c8152e 100644 --- a/tasks/src/Control/Concurrent/Tasks.hs +++ b/tasks/src/Control/Concurrent/Tasks.hs | |||
@@ -29,10 +29,10 @@ withTaskGroup glabel numslots action = do | |||
29 | writeTVar cnt (succ slot) | 29 | writeTVar cnt (succ slot) |
30 | t <- readTChan tg | 30 | t <- readTChan tg |
31 | return (slot,t) | 31 | return (slot,t) |
32 | _ <- fork $ do | 32 | t <- fork $ do |
33 | myThreadId >>= flip labelThread (intercalate "." [glabel,show slot,lbl]) | ||
34 | task `catch` (\(SomeException e) -> return ()) | 33 | task `catch` (\(SomeException e) -> return ()) |
35 | atomically $ modifyTVar' cnt pred | 34 | atomically $ modifyTVar' cnt pred |
35 | labelThread t (intercalate "." [glabel,show slot,lbl]) | ||
36 | again | 36 | again |
37 | action (TaskGroup tg) `onException` killThread thread | 37 | action (TaskGroup tg) `onException` killThread thread |
38 | atomically $ do | 38 | atomically $ do |