Разница между Kotlin TickerModes - PullRequest
Новая
       11

Разница между Kotlin TickerModes

0 голосов
/ 19 декабря 2018

У меня проблемы с пониманием разницы между тикерным каналом Kotlin TickerMode.FIXED_DELAY и TickerMode.FIXED_PERIOD.Я играл с обоими, но я не могу сделать выводы из их поведения.Я также прочитал пример в документах .Буду признателен за более четкое объяснение с иллюстрацией каждого из них.

1 Ответ

0 голосов
/ 25 декабря 2018

Как вы можете найти в источниках сопрограмм , разница в том, что FIXED_PERIOD более сложна и учитывает тот факт, что приемник не может поддерживать и регулировать задержку до следующих вызовов send.Это может быть сложно продемонстрировать, потому что вам нужно измерить время, которое приемник тратит на ожидание следующего тика.

PS Обратите внимание, что эта функциональность помечена как устарела , то есть «дизайн соответствующих деклараций имеет серьезные известные недостатки, и они будут переработаны в будущем.» В этом случае причина в том, что он не интегрирован со структурированным параллелизмом. 

fun main() = runBlocking {
    println("\nFIXED_PERIOD")
    val tickerPeriodMode = ticker(100, 0, mode = TickerMode.FIXED_PERIOD)
    consumer(tickerPeriodMode)

    println("\nFIXED_DELAY")
    val tickerDelayMode = ticker(100, 0, mode = TickerMode.FIXED_DELAY)
    consumer(tickerDelayMode)
}

private suspend fun CoroutineScope.consumer(ticker: ReceiveChannel<Unit>) {
    val job = launch {
        var i = 0
        while (isActive) {
            val waitTime = measureTimeMillis {
                ticker.receive()
            }
            print("[%4d ms]".format(waitTime))

            if (i++ == 1) {
                delay(150)
                println(" adding extra 150ms delay")
            } else
                println(" going ahead")
        }
    }
    delay(1_000L)
    job.cancel()
    ticker.cancel() // indicate that no more elements are needed
}

Выход 

FIXED_PERIOD
[   1 ms] going ahead
[  91 ms] adding extra 150ms delay
[   0 ms] going ahead
[  46 ms] going ahead
[ 100 ms] going ahead
[ 102 ms] going ahead
[  98 ms] going ahead
[ 100 ms] going ahead
[  99 ms] going ahead
[ 100 ms] going ahead
[ 100 ms] going ahead

FIXED_DELAY
[   0 ms] going ahead
[ 105 ms] adding extra 150ms delay
[   0 ms] going ahead
[ 101 ms] going ahead
[ 100 ms] going ahead
[ 103 ms] going ahead
[ 103 ms] going ahead
[ 101 ms] going ahead
[ 101 ms] going ahead
[ 105 ms] going ahead
...