We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7ac0e51 commit 8a8789cCopy full SHA for 8a8789c
Control/Concurrent/Async/Internal.hs
@@ -55,7 +55,7 @@ import Data.IORef
55
56
import GHC.Exts
57
import GHC.IO hiding (finally, onException)
58
-import GHC.Conc (ThreadId(..))
+import GHC.Conc (ThreadId(..), labelThread)
59
60
-- -----------------------------------------------------------------------------
61
-- STM Async API
@@ -504,6 +504,7 @@ linkOnly
504
linkOnly shouldThrow a = do
505
me <- myThreadId
506
void $ forkRepeat $ do
507
+ myThreadId >>= flip labelThread ("linkOnly " ++ show (asyncThreadId a) ++ " -> " ++ show me)
508
r <- waitCatch a
509
case r of
510
Left e | shouldThrow e -> throwTo me (ExceptionInLinkedThread a e)
0 commit comments