Kotlin Quasar话题和频道阻塞问题

我在Kotlin玩Quasar，并且开始讨论话题和频道。 我正在关注一些Java示例，并写了一小段代码。 不幸的是，我似乎无法得到它的工作。 它只是阻止主线程并等待。 我不太确定连接是在做什么，并想知道这是否会成为问题？

public fun channelsDemo() { val x: Val<Int> = Val() val t: Topic<Int> = Topic() fiber { val c: Channel<Int> = t.subscribe(Channels.newChannel(0)) do { val m = c.receive() System.out.println("Channel => " + (m + x.get())) } while (m != null) }.join() x.set(13) t.send(5) t.close() } 

编辑：

 public fun channelsDemo() { val x: Val<Int> = Val() val t: Topic<Int> = Topic() fiber { val c: Channel<Int> = t.subscribe(Channels.newChannel(0)) do { val m = c.receive() System.out.println("Channel => " + (m + x.get())) } while (m != 40) } fiber { Strand.sleep(20000) x.set(13) t.send(5) t.send(21) t.send(40) t.close() } } 

Answer 1

join方法告诉当前的线 （即线或光纤）被阻塞，直到它被呼叫的线终止。 在这种情况下，您要等待光纤终止，但由于您尚未发送任何内容，因此很难启动。

为了解决这个问题，将光纤分配给一些本地的（ val f = fiber { ... } ），并且只在程序结束时加入。 另外，不要把它分配给任何东西，也不要加入。