@@ -131,7 +131,6 @@ import Data.Kind (Type)
131131#endif
132132import Data.IORef
133133 (IORef, modifyIORef, newIORef, readIORef, writeIORef, atomicModifyIORef)
134−import Data.List ((\\))
135134import Data.Maybe (fromJust)
136135#if __GLASGOW_HASKELL__ < 808
137136import Data.Semigroup ((<>))
@@ -618,14 +617,14 @@ cleanupSVar :: SVar t m a -> IO ()
618617cleanupSVar sv = do
619618 workers <- readIORef (workerThreads sv)
620619 Prelude.mapM_ (`throwTo` ThreadAbort)
621− (S.toList workers)
620+ workers
622621
623622cleanupSVarFromWorker :: SVar t m a -> IO ()
624623cleanupSVarFromWorker sv = do
625624 workers <- readIORef (workerThreads sv)
626625 self <- myThreadId
627− mapM_ (`throwTo` ThreadAbort)
628− (S.toList workers \\ [self])
626+ Prelude.mapM_ (`throwTo` ThreadAbort)
627+ (Prelude.filter (/= self) $ S.toList workers)
629628
630629-------------------------------------------------------------------------------
631630-- Worker latency data collection