altavir/idiomatic-kotlin-course
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add examples for services

Browse Source
This commit is contained in:
Alexander Nozik 2024-12-12 20:52:51 +03:00
parent 598e1c931c
commit b7279b55c2
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/kotlin/microservice/pricingService.kt
View File

@ -36,6 +36,9 @@ fun CoroutineScope.launchPriceUpdate(
): Job = launch { ): Job = launch {
val cache = ArrayDeque<Pair<Instant, BigDecimal>>() val cache = ArrayDeque<Pair<Instant, BigDecimal>>()
//restore from db
val now = Clock.System.now()
cache.addAll(db.restorePrice((now-duration)..now))
//read job //read job
launch { launch {
@ -61,7 +64,7 @@ fun CoroutineScope.launchPriceUpdate(
//cache cleanup job //cache cleanup job
launch { launch {
while (isActive) { while (isActive) {
delay(1.minutes) delay(10.minutes)
val now = Clock.System.now() val now = Clock.System.now()
cache.removeIf { now - it.first > duration } cache.removeIf { now - it.first > duration }
} }