主页 / user-21775425

MaBed's questions

Martin Hope
MaBed
Asked: 2024-11-26 20:30:28 +0800 CST
  • 7

我有少数生产者，他们各自向自己的流发出数据，然后我将它们合并为一个，进一步处理这些值并使用它们：

fun makeInputFlow() = flow {
    while (shouldMakeRequest()) {
        // make (possibly blocking) network request
        // do some CPU-intensive operations
        results.forEach { emit(it) }
        yield()
    }
}

suspend fun runFlows() {
    val flow1 = makeInputFlow()
    val flow2 = makeInputFlow()
    val flow3 = makeInputFlow()

    val merged = listOf(flow1, flow2, flow3)
        .merge()
    merged.collect { println(it) }
}

这是可行的，但看起来只有一个流程实际上在当时产生了值。CPU 大部分时间都处于空闲状态。

有没有办法在自己的协程/线程中安全地运行每个流程，以便所有流程并行产生值？

multithreading
Martin Hope
MaBed
Asked: 2024-11-23 18:10:15 +0800 CST
  • 5

我有一个键值对流（例如Flow<Pair<String, Int>>），我想根据键对其进行去抖动/节流，这样当出现一些具有非唯一键的对序列时，我只会进一步发出最后一个。例如：

val throttled = flow {
        emit("A" to 1)    // emits at t=0
        delay(100)
        emit("B" to 6)    // emits at t=100
        delay(100)
        emit("A" to 7)    // emits at t=200
        delay(100)
        emit("A" to 2)    // emits at t=300
        delay(100)
        emit("B" to 8)    // emits at t=400
        delay(300)
        emit("A" to 3)    // emits at t=700
    }
    .throttle(201.milliseconds)
    // ...

应在以下位置生产：(B, 6)，，，。(A, 2)(B, 8)(A, 3)

基本上，每当密钥的新值到达时，超时就应该“重置”，并且应该等待指定的持续时间，然后再将对发送到下游。值可以偶尔流入，但不应该留下任何对来等待另一对进入。

使用当前流 API 可以实现这一点吗？

kotlin
Martin Hope
MaBed
Asked: 2024-09-25 17:25:21 +0800 CST
  • 6

我想根据毫秒（纪元）时间戳计算数组中的索引。该数组长度为 167，每个索引为一周中的小时（即索引0指向星期一的 0:00、24星期二的 0:00、28星期二的 4:00，...）。我想到这个解决方案，它有效：

function getIndex(timestamp) {
  const hoursInDay = 24;
  const date = new Date(timestamp);
  const dayIndex = (date.getUTCDay() + 6) % 7; // index from Monday
  const hourIndex = date.getUTCHours();
  return dayIndex * hoursInDay + hourIndex;
}

问题是这很慢。我们有几千个这样的时间戳，但处理它们的时间非常有限。

是否有一种纯数值的方法可以达到相同的效果，这样我们就不必Date每次都构建和使用？

javascript