说说Cold Flow冷流和Hot Flow热流？ - 强人自传

671 字

3 分钟

说说Cold Flow冷流和Hot Flow热流？

2022-03-06

Kotlin

/

Android

说说Cold Flow冷流和Hot Flow热流？#

说起_Flow_可以分为冷流和热流，结合官网和网络上的一些解释，其实分别可以概括成一句话

冷流就是不消费，不生产，多次消费，多次生产，一对一关系
热流就是只要创建，有无消费，都生产，一对多关系你说什么，不是特别清晰，那笔者用一个表来展示冷流和热流的区别吧

冷流	热流
它仅在有收集器的时候才有数据	即使没有收集器，它也会发出数据
它不存储数据	它可以存储数据
它不能有多个收集器	它允许有多个收集器

在_Cold Flow_中，在多个收集器的情况下，完整的流程将从每个收集器的开始而开始，执行任务并将值发送到它们相应的收集器。这就像一对一的映射。1个收集器的1个生产流量。这意味着冷流不能有多个收集器，因为它将为每个收集器创建一个新流。在_Hot Flow_中，在多个收集器的情况下，流将继续发出值，收集器从它们开始收集的地方获取值。这就像 1 对 N 映射，N 个收集器对应1个生产流量，这意味着一个热流可以有多个收集器。如此我们写些伪代码来辅助说明下吧：

冷流示例

假设我们有一个_Cold Flow_，它以 1 秒的间隔发出 1 到 5

1
fun getNumbersColdFlow():ColdFlow<Int> {
2
    return someColdFlow {
3
        (1..5).forEach {
4
            delay(1000)
5
            emit(it)
6
        }
7
    }
8
}

我们创建两个收集器进行收集:

1
val numbersColdFlow = getNumbersColdFlow()
2

3
numbersColdFlow
4
    .collect {
5
        println("1st Collector: $it")
6
    }
7

8
delay(2500)
9

10
numbersColdFlow
11
    .collect {
12
        println("2nd Collector: $it")
13
    }

那么输出将是：

1
1st Collector: 1
2
1st Collector: 2
3
1st Collector: 3
4
1st Collector: 4
5
1st Collector: 5
6

7
2nd Collector: 1
8
2nd Collector: 2
9
2nd Collector: 3
10
2nd Collector: 4
11
2nd Collector: 5

我们这两个收集器从一开始就会得到所有的值，会从头到尾全部一点不落的拿到

热流示例

假设我们有一个_Hot Flow_，它同样以1秒的间隔发出1到5

1
fun getNumbersHotFlow(): HotFlow<Int> {
2
    return someHotflow {
3
        (1..5).forEach {
4
            delay(1000)
5
            emit(it)
6
        }
7
    }
8
}

现在我们继续创建两个收集器进行收集：

1
val numbersHotFlow = getNumbersHotFlow()
2

3
numbersHotFlow
4
    .collect {
5
        println("1st Collector: $it")
6
    }
7

8
delay(2500)
9

10
numbersHotFlow
11
    .collect {
12
        println("2nd Collector: $it")
13
    }

输出将是

1
1st Collector: 1
2
1st Collector: 2
3
1st Collector: 3
4
1st Collector: 4
5
1st Collector: 5
6

7
2nd Collector: 3
8
2nd Collector: 4
9
2nd Collector: 5

可以看到，第一个收集器将会接收到所有的值，由于第二个收集器将会2500毫秒之后开始收集，所以它只会收集那些2500毫秒之后的值。

说说Cold Flow冷流和Hot Flow热流？

作者

强人自传

发布于

2022-03-06

许可协议

CC BY-NC-SA 4.0

reified来实现真泛型

ThreadLocalMap 怎么解决 Hash 冲突的？

说说Cold Flow冷流和Hot Flow热流？