我有两个（或更多）监听器订阅到了多通道上。我想使用它们中的全部，然后随意让其中一个（或多个）离开，同时不会阻塞其他消费者或发布者。最初它们工作正常，直到其中一个想要停止监听。我本以为退出监听的监听器需要（成为一位好市民，并将其）通道从多通道中取消订阅（否则死锁是系统性的）。但是，如果在离开的监听器有机会取消订阅其通道之前将消息放入多通道，那么它就会在主线程（正在同时放置更多消息）上创建死锁。我没有找到一种可以确保我能够及时取消订阅通道以避免这种竞争条件的方法。
一旦我重现了死锁，repl就会冻结，直到我按下ctrl-c中断。
我还尝试在取消订阅之前关闭订阅的通道，但结果是相同的。
在下面的代码片段中，最后的（println "I'm done. You will never see this"）永远不会被执行。发布者和剩下的消费者（消费者1）即使消费者2正在良好的意愿下尝试离开，也会发生死锁。
(require '[clojure.core.async :refer (chan go <! >!! mult tap untap)])
(let [to-mult (chan 1)
m (mult to-mult)]
;;消费者1
(let [c (chan 1)]
(tap m c)
(go (loop []
(when-let [v (<! c)]
(println "1 Got! " v)
(recur))
(println "1 Exiting!"))))
;;消费者2
(let [c (chan 1)]
(tap m c)
(go (loop []
(when-let [v (<! c)]
(when (= v 42) ;; 当值为42时退出
(println "2 Got! " v)
(recur)))
(println "2 about to leave!")
(Thread/sleep 5000) ;; 稍等片刻以加剧竞争条件
(untap m c) ;; 在取消订阅此读取器之前
(println "2 Exiting."))))
(println "about to put a few messages that work")
(doseq [a (range 10)]
(>!! to-mult 42))
(println "about to put a message that will force the exit of 2")
(>!! to-mult 43)
(println "about to put a few more messages before reader 2 is unsubscribed to show the deadlock")
(doseq [a (range 10)]
(println "putting msg" a)
(>!! to-mult 42))
(println "I'm done. You will never see this"))
即将放置一些可以正常工作的消息
2 已获得！ 42
1 已获得！ 42
2 已获得！ 42
1 已获得！ 42
1 已获得！ 42
2 已获得！ 42
1 已获得！ 42
1 已获得！ 42
2 已获得！ 42
2 已获得！ 42
2 已获得！ 42
2 已获得！ 1 已获得！ 42
422 已获得！ 42
1 已获得！ 42
1 已获得！ 42
2 已获得！ 42
1 已获得！ 42
即将放置将强制退出 2 的消息
1 已获得！ 42
2 已获得！ 在 2 被取消订阅之前，将要放置一些更多的消息以显示死锁
42
放置 msg 1 已获得！ 0
2 即将离开！
43
1 已获得！ 42
放置 msg 1
放置 msg 2
放置 msg 3
1 已获得！ 42
2 正在退出。
