Очистка дочерних потока, когда основной поток завершается

Question

Я очутившись пытаюсь написать что-то вроде этого:

main = do t1 <- forkIO (forever io) 
      t2 <- forkIO (forever io) 
      forever io 
      `finally` traverse_ killThread [t1,t2] 

Но t1 и t2 не могут быть доступны в finally, потому что это вне монады.

Поскольку здесь действия IO запускаются вечно, моя главная задача - дать возможность потоку выйти из строя в случае прерывания пользователя или IOException в последнем действии ввода-вывода.

Я знаю, что такие пакеты, как async и threads, отлично подходят для этого, но можно ли это сделать с помощью простых примитивов параллелизма?

Кстати, было бы неплохо, чтобы среда выполнения автоматически отправляла killThread всем дочерним потокам. Когда ты этого не хочешь?

Answer 1

Только что понял, что нет никаких проблем, включая finally в блоке монадического кода.

main = do t1 <- forkIO (forever io) 
      t2 <- forkIO (forever io) 
      forever io `finally` traverse_ killThread [t1,t2] 

Я не отмечаю этот вопрос как ответ, если кто-то видит что-то не так с этим.

Answer 2

Вам не нужно убивать дочерние потоки, потому что время выполнения Haskell убивает их, когда основной поток завершается в любом случае. Обычно вы пишете код в главном, чтобы дождаться завершения дочерних потоков, прежде чем завершать себя.