如何用Kotlin coroutines实现定时器

Edit 请注意，原答案中建议的API现在被标记为 @ObsoleteCoroutineApi 。

Ticker通道目前没有与结构化并发集成，其api将在未来改变。

你现在可以使用 Flow 的API来创建你自己的代码流。

import kotlin.time.Duration
import kotlin.time.Duration.Companion.seconds
import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*
fun tickerFlow(period: Duration, initialDelay: Duration = Duration.ZERO) = flow {
    delay(initialDelay)
    while (true) {
        emit(Unit)
        delay(period)
而且你可以用一种与你目前的代码非常相似的方式来使用它。
tickerFlow(5.seconds)
    .map { LocalDateTime.now() }
    .distinctUntilChanged { old, new ->
        old.minute == new.minute
    .onEach {
        setDateTime(it)
    .launchIn(viewModelScope) // or lifecycleScope or other
注意：在这里写的代码中，处理元素的时间没有被tickerFlow考虑在内，所以延迟可能不是正常的（这是一个延迟between元素处理）。如果你希望滴答器独立于每个元素的处理，你可能希望使用一个buffer或一个专门的线程（例如通过flowOn）。
Original answer
我相信这仍然是实验性的，但你可以用一个票据频道每隔X毫秒产生一次值。
val tickerChannel = ticker(delayMillis = 60_000, initialDelayMillis = 0)
repeat(10) {
    tickerChannel.receive()
    val currentTime = LocalDateTime.now()
    println(currentTime)
如果你需要在你的 "subscribe "为每个 "tick "做一些事情时继续做你的工作，你可以launch一个后台的coroutine，它将从这个通道读取并做你想要的事情。
val tickerChannel = ticker(delayMillis = 60_000, initialDelayMillis = 0)
launch {
    for (event in tickerChannel) {
        // the 'event' variable is of type Unit, so we don't really care about it
        val currentTime = LocalDateTime.now()
        println(currentTime)
delay(1000)
// when you're done with the ticker and don't want more events
tickerChannel.cancel()
如果你想从循环内停止，你可以简单地脱离它，然后取消这个通道。
val ticker = ticker(500, 0)
var count = 0
for (event in ticker) {
    count++
    if (count == 4) {
        break
    } else {
        println(count)
ticker.cancel()