Я для себя написал такой простенький код: fun <Request> CoroutineScope.batcher(

Question

Я для себя написал такой простенький код: fun <Request> CoroutineScope.batcher(

batchSize: Int = 100,
capacity: Int = batchSize * 3,
executor: suspend (List<Request>) -> Unit
) = actor<Request>(capacity = capacity) {
while (!isClosedForReceive) {
val list = mutableListOf(receive())
while (list.size < batchSize) {
list += poll() ?: break
}
executor(list)
}
}

работает по такому принципу.
* канал для приема "Request"
* executor, который умеет обрабатывать пачкой запросы List<Request>
* взять 1-й элемент через вызов suspended recieve
* затем через неблокирующий poll добрать сколько можно до первого null или если batchSize превышен
* вызвать executor
* при этом канал постоянно принимает новые запросы до определенного лимита.

#kotlin #programming #russian

0

28.06.2019

1 ответов

14 просмотров

Vladimir Petraković · Accepted Answer

Vladimir Petraković

Выглядит неплохо. Не знал про poll() и что-то не понял, чем от него отличается receiveOrNull().

0

28.06.2019

169 похожих чатов

Я для себя написал такой простенький код: fun <Request> CoroutineScope.batcher(

1 ответов

Похожие вопросы