1

我在 Kotlin 中使用 Quasar 并开始使用主题和频道。我正在关注一些 Java 示例并编写了一个小片段。不幸的是，我似乎无法让它工作。它只是阻塞主线程并等待。我不太确定 join 正在做什么，想知道这是否是问题所在？

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()
    }

}
4

1 回答 1

2

该join方法告诉当前线程（即线程或光纤）阻塞，直到调用它的线程终止。在这种情况下，您等待光纤终止，但它几乎无法启动，因为您还没有发送任何东西。

要解决此问题，请将纤程分配给某个本地 ( val f = fiber { ... })，并仅在程序结束时加入它。或者，不要将其分配给任何东西，也不要加入。

于 2015-10-14T09:56:51.770 回答