lzc256
/
AquaDX
mirror of https://github.com/hykilpikonna/AquaDX
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

@Volatile List<>

pull/106/head
Menci 2025-01-12 04:06:49 +08:00
parent 3d66b7e022
commit 7ef27ebe22
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/icu/samnyan/aqua/sega/maimai2/handler/GetGameRankingHandler.kt
View File

@ -10,6 +10,7 @@ import org.springframework.scheduling.annotation.Scheduled
import org.springframework.stereotype.Component import org.springframework.stereotype.Component
import java.time.LocalDateTime import java.time.LocalDateTime
import java.time.format.DateTimeFormatter import java.time.format.DateTimeFormatter
import kotlin.concurrent.Volatile
/** /**
* @author samnyan (privateamusement@protonmail.com) * @author samnyan (privateamusement@protonmail.com)
@ -20,7 +21,9 @@ class GetGameRankingHandler(
private val queryFactory: JPAQueryFactory private val queryFactory: JPAQueryFactory
) : BaseHandler { ) : BaseHandler {
private data class MusicRankingItem(val musicId: Int, val weight: Long) private data class MusicRankingItem(val musicId: Int, val weight: Long)
private var musicRankingCache: Array<MusicRankingItem> = emptyArray()
@Volatile
private var musicRankingCache: List<MusicRankingItem> = emptyList()
init { init {
// To make sure the cache is initialized before the first request, // To make sure the cache is initialized before the first request,
@ -52,7 +55,7 @@ class GetGameRankingHandler(
.limit(QUREY_LIMIT) .limit(QUREY_LIMIT)
.fetch() .fetch()
.map { MusicRankingItem(it.get(cMusicId)!!, it.get(cUserCount)!!) } .map { MusicRankingItem(it.get(cMusicId)!!, it.get(cUserCount)!!) }
.toTypedArray() .toList()
logger.info("Refreshed music ranking cache: ${musicRankingCache.size} items") logger.info("Refreshed music ranking cache: ${musicRankingCache.size} items")
} }