diff --git a/AGENTS.md b/AGENTS.md index 499dab8..4bc5ba9 100644 --- a/AGENTS.md +++ b/AGENTS.md @@ -165,7 +165,7 @@ $BT/apksigner verify 目标名.apk ### 版本号 -- `app/build.gradle`：`versionName "1.5.1"` / `versionCode 32`（18~21 被本机临时诊断包占用过） +- `app/build.gradle`：`versionName "1.5.1"` / `versionCode 33`（18~21 被本机临时诊断包占用过） - App 内显示统一用纯版本号（不加 `(versionCode)` 括号） - ⚠️ **发布构建已开启 NewApi 闸门**（`lint { checkReleaseBuilds true; fatal += ['NewApi'] }`）： 任何「调用了高于 `minSdk 21` 且未做版本守卫的 API」都会让 `assembleRelease` 直接失败。 @@ -470,6 +470,25 @@ $BT/apksigner verify 目标名.apk 不再推进、状态却是"无歌可播"，之后按切歌/播放都没有反应 —— 2026-09-26「点歌最后一首按切歌 → 播完卡死」就是这个僵尸态。 唯一例外是"马上要 `play()` 下一首"的路径（可以不停，避免切歌瞬间静音）。 +- **⚠️ 「切歌 → 公放」在老盒子上卡死（2026-09-26，极米 H1S）**：新设备正常、老设备卡死， + 排查出**三个叠加原因**，都已修掉，改动这块时必须同时守住： + 1. **不能共用 `io` 线程池**：`io` 只有 4 个线程，且"点歌即下即播"（`streamDownloadAndPlay`） + 这类几十秒的长任务也在里面。老设备网速慢，并发点几首歌就把池占满，切歌任务一直排队。 + → 切歌/随机续播改用 `randomPlayExecutor`（专用单线程守护线程）。 + 2. **不能现扫目录找候选**：候选来自 `localSongInventory()` + `library.scanLocal()`， + 代价是"每个文件在头尾各读约 4.3MB 做 TS 校验" + "遍历 `/storage/ 各挂载点` + （老 ROM 的失效挂载点会让 `File.listFiles()` **永久阻塞**）"。 + → 改为启动时后台**预热候选缓存**（`primeRandomCandidates()`：独立守护线程 + + `scanWithTimeout` 超时保护），下载完成即时补进缓存，切歌直接读缓存（零 I/O）。 + 3. **主线程不能做深度文件校验**：`Song.hasLocalFile()` 内部是 `SongFileValidator.inspect` + （头尾各读 4.3MB）。它曾被用在 `play()`、播放错误回调、`switchToLocalPlayback`， + 以及**逐行渲染**的 `songRowState()` 里 —— 慢存储上每次都是秒级，直接 ANR。 + → 播放/渲染路径统一改用**廉价检查** `MainActivity.hasPlayableLocalFile()` + （只看存在与大小），深度校验只留在后台（`localSongInventory()` / `isDownloaded()`）。 +- **⚠️ Kotlin 块注释会嵌套，注释里不能出现 `/*`**：写 `` `/storage/*` `` 时那个 `/*` 会开启一个 + **嵌套注释**，导致 KDoc 永远不闭合，后面的代码全被吞进注释里（报错是 + "Unclosed comment" + 一堆 "Missing '}'"，很难一眼看出）。注释里要写路径通配就写 + `/storage/ 各挂载点` 这种不含 `/*` 的说法。 - **弹窗分辨率自适应**：TV/投影/盒子的分辨率与 density 差异很大（1280x720、1920x1080， density 1.0~2.5），固定 dp 尺寸在矮屏上会被屏幕裁切。统一用 `fitDialogToScreen(dialog, scroll, content, preferredWidthDp, …)`：宽度取 `min(preferredWidthDp, 屏幕宽*0.94)`，高度把内容所在的 diff --git a/app/build.gradle b/app/build.gradle index ffe77c0..2eea7d4 100644 --- a/app/build.gradle +++ b/app/build.gradle @@ -11,7 +11,7 @@ android { applicationId "com.local.ktv" minSdk 21 targetSdk 25 - versionCode 32 + versionCode 33 versionName "1.5.1" ndk { // 双 ABI 打包:兼容 64 位(Exynos 1580 等 arm64-v8a)与 32 位设备(极米 Play 超越版 diff --git a/app/src/main/java/com/local/ktv/MainActivity.kt b/app/src/main/java/com/local/ktv/MainActivity.kt index 7484ad8..925e9de 100644 --- a/app/src/main/java/com/local/ktv/MainActivity.kt +++ b/app/src/main/java/com/local/ktv/MainActivity.kt @@ -136,6 +136,29 @@ class MainActivity : AppCompatActivity() { private val keyboardSearchRunnable = Runnable { performSearch() } private val io: ExecutorService = Executors.newFixedThreadPool(4) private val stateIo: ExecutorService = Executors.newSingleThreadExecutor() + + /** + * 「切歌 → 公放」专用单线程执行器。 + * + * ⚠️ **绝不能用 [io] 池**：它只有 4 个线程，"点歌即下即播"（`streamDownloadAndPlay`）这类 + * 几十秒的长任务也在里面。极米 H1S 上并发点几首歌就能把池占满，切歌任务于是一直排队 —— + * 旧歌播完后彻底没声、按什么都没反应（用户报的"老设备卡死"，新设备因下载快而看不出来）。 + */ + private val randomPlayExecutor: ExecutorService = Executors.newSingleThreadExecutor { runnable -> + Thread(runnable, "ktv-random-play").apply { isDaemon = true } + } + + /** + * 公放候选缓存（本机可播放歌曲）：启动时后台预热一次，下载完成后增量更新。 + * + * ⚠️ **切歌时不能现扫**：候选来自 `localSongInventory()` + `library.scanLocal()`， + * 代价是「每个文件在头尾各读约 4.3MB 做 TS 校验」+「遍历 `/storage/ 各挂载点` + * （老 ROM 上的失效挂载点会让 `File.listFiles()` 永久阻塞）」。新设备上很快， + * 极米 H1S 上足以让切歌看起来卡死。 + */ + private val randomCandidates = java.util.concurrent.ConcurrentHashMap() + @Volatile private var randomCandidatesPrimed = false + @Volatile private var randomCandidatesPriming = false private val library = SongLibrary() private lateinit var stateDatabase: KtvStateDatabase private lateinit var playbackEngine: KtvPlaybackEngine @@ -533,6 +556,9 @@ class MainActivity : AppCompatActivity() { // ⚠️ 只删可证明是广告的文件（多首歌内容完全相同）；**绝不能清空整个歌曲目录** —— // 1.4.10 那样做过，等于删掉公放曲库，导致「切歌」选不出下一首（新设备回归）。 io.execute { SongOkDownloadManager.purgeInjectedAdDuplicatesOnce(applicationContext) } + // 预热公放候选缓存（独立守护线程 + 内部超时），让之后的「切歌 → 公放」零 I/O。 + // 延后一点避开曲库加载/启动高峰，但不影响正确性：预热完成前切歌会走安全兜底路径。 + main.postDelayed({ primeRandomCandidates() }, 5_000L) main.postDelayed(remoteNetworkMonitor, 5000) // 网络状态监测: 断网提示 + 恢复后重建歌曲源会话/重试下载。 KtvNetworkMonitor.start(applicationContext) { online, initial -> @@ -5026,6 +5052,20 @@ class MainActivity : AppCompatActivity() { showDownloads() } + /** + * 判断歌曲是否已有可播放的本地文件（**廉价**检查：只看存在与大小）。 + * + * ⚠️ 播放路径上不要用 `Song.hasLocalFile()`：它内部是 `SongFileValidator.inspect`， + * 会在文件**头尾各读约 4.3MB** 做 TS 包校验 —— 极米 H1S 这类慢存储上一次调用就是好几秒， + * 足以让主线程 ANR（用户感知即"按了切歌卡死"）。深度校验统一交给后台 + * （`localSongInventory()` / `SongOkDownloadManager.isDownloaded()`）完成。 + */ + private fun hasPlayableLocalFile(song: Song?): Boolean { + val path = song?.path?.takeIf { it.isNotEmpty() } ?: return false + val file = File(path) + return file.isFile && file.length() >= SongFileValidator.MIN_VALID_FILE_SIZE + } + private fun play(song: Song?) { if (player == null) player = videoBackground if (song == null) return @@ -5033,7 +5073,7 @@ class MainActivity : AppCompatActivity() { // 远程日志: 点歌使用的源(本地文件 / 在线源)。 MiliLog.info( "PLAY id=${extractTid(song)} title=${song.title} src=" + - (if (song.hasLocalFile()) "local" else "online"), + (if (hasPlayableLocalFile(song)) "local" else "online"), ) // 取消仍在后台扫描的“已点播完后随机本地歌曲”请求，避免抢占新点歌曲。 randomLocalRequestSerial++ @@ -5054,7 +5094,7 @@ class MainActivity : AppCompatActivity() { updateBottomBar(song, true) scheduleAutoFullscreen() - if (song.hasLocalFile()) { + if (hasPlayableLocalFile(song)) { playLocalFile(song) } else { playbackPreparing = true @@ -5182,6 +5222,7 @@ class MainActivity : AppCompatActivity() { // 移到正式位置 tmpFile.renameTo(finalFile) song.path = finalFile.getAbsolutePath() + randomCandidates[stableId(song)] = song main.post(Runnable { hideDownloadProgress() @@ -5283,9 +5324,9 @@ class MainActivity : AppCompatActivity() { // 远程日志: 播放网络/解码错误实时上报。 MiliLog.error( "PLAY-ERR id=${song?.let(::extractTid)} title=${song?.title} what=$what extra=$extra" + - (if (song?.hasLocalFile() == true) " local" else " stream"), + (if (hasPlayableLocalFile(song)) " local" else " stream"), ) - if (songRetryCount < 2 && song != null && song.hasLocalFile()) { + if (songRetryCount < 2 && song != null && hasPlayableLocalFile(song)) { songRetryCount++ val retry = songRetryCount main.postDelayed(Runnable { @@ -5302,7 +5343,7 @@ class MainActivity : AppCompatActivity() { private fun switchToLocalPlayback(song: Song?) { if (currentSong == null || !currentSong!!.equals(song)) return - if (!song!!.hasLocalFile()) return + if (song == null || !hasPlayableLocalFile(song)) return var pos = 0 try { pos = player!!.currentPosition @@ -5445,6 +5486,8 @@ class MainActivity : AppCompatActivity() { main.post(Runnable { downloads.removeAll { stableId(it.song) == stableId(song) } song.path = localPath + // 立刻进公放候选缓存：不必等下次预热扫描，新下载的歌马上能被随机到。 + randomCandidates[stableId(song)] = song refreshSongAdapter() val shouldAddToQueue = pendingQueueSongIds.remove(stableId(song)) Log.i( @@ -5653,17 +5696,21 @@ class MainActivity : AppCompatActivity() { } persistRuntimeState() - io.execute { - val localSongs = localSongInventory() - library.scanLocal().forEach { song -> - val file = song.path?.let(::File) ?: return@forEach - if (SongFileValidator.inspect( - file, - SongFileValidator.requiresTransportStream(file), - ).valid - ) { - localSongs.getOrPut(stableId(song)) { song } - } + // ⚠️ 两条硬约束： + // 1) 必须用 randomPlayExecutor（专用线程），否则会被几十秒的下载任务挤在后面排队； + // 2) 必须优先读预热缓存，不能在切歌时现扫目录（老盒子上"逐文件校验 + 遍历 /storage/ 各挂载点" + // 会让切歌看起来卡死）。 + randomPlayExecutor.execute { + val localSongs = LinkedHashMap() + randomCandidates.forEach { (id, song) -> localSongs[id] = song } + if (localSongs.isEmpty()) { + // 缓存还没预热好（例如刚开机就切歌）：做一次**安全的**库存查询兜底。 + // 刻意不调用 library.scanLocal() —— 它会遍历 /storage/ 各挂载点，老 ROM 的失效挂载点 + // 可能让 File.listFiles() 永久阻塞；外部目录交给带超时的预热流程去补。 + runCatching { + localSongInventory().forEach { (id, song) -> localSongs[id] = song } + }.onFailure { Log.w(TAG, "random candidates fallback failed", it) } + primeRandomCandidates() } val allLocalSongs = localSongs.values.toList() main.post { @@ -8778,6 +8825,66 @@ class MainActivity : AppCompatActivity() { private fun countDownloadedFiles(): Int = localSongInventory().size + /** + * 预热公放候选缓存（启动时调用一次；下载完成后由回调增量补充）。 + * + * 用**独立守护线程**而不是 [io] 池：里面的 `library.scanLocal()` 在老盒子上可能永久阻塞， + * 绝不能占住 io 线程；[scanWithTimeout] 保证即使它卡住，也只损失"导入目录/外置存储"那部分候选， + * 已下载曲库照样可用。 + */ + private fun primeRandomCandidates() { + if (randomCandidatesPriming || randomCandidatesPrimed) return + randomCandidatesPriming = true + Thread({ + val startedAt = System.currentTimeMillis() + runCatching { + // 1) 已下载曲库：只读我们自己的目录 + 曲库 DB，安全。 + localSongInventory().forEach { (id, song) -> randomCandidates.putIfAbsent(id, song) } + // 2) 导入目录 / 外置存储：遍历 /storage/ 各挂载点 有阻塞风险，必须带超时。 + val scanned = scanWithTimeout(RANDOM_SCAN_TIMEOUT_MS) { library.scanLocal() } + if (scanned == null) { + MiliLog.warn("RANDOM-CACHE 目录扫描超时(${RANDOM_SCAN_TIMEOUT_MS}ms)，仅使用已下载曲库") + } else { + scanned.forEach { song -> + val file = song.path?.let(::File) ?: return@forEach + if (SongFileValidator.inspect( + file, + SongFileValidator.requiresTransportStream(file), + ).valid + ) { + randomCandidates.putIfAbsent(stableId(song), song) + } + } + } + }.onFailure { Log.w(TAG, "prime random candidates failed", it) } + randomCandidatesPrimed = true + randomCandidatesPriming = false + MiliLog.info( + "RANDOM-CACHE 预热完成 size=${randomCandidates.size} " + + "用时=${System.currentTimeMillis() - startedAt}ms", + ) + }, "ktv-random-prime").apply { isDaemon = true }.start() + } + + /** + * 在独立守护线程里执行"可能永久阻塞"的文件系统扫描，超时返回 null。 + * + * 不能放进任何线程池：老盒子（极米 H1S，非标准 ROM）上 `/storage/ 各挂载点` 里的失效挂载点 + * 会让 `File.listFiles()` 无限期阻塞，占住池线程会连带拖死后续所有任务。 + */ + private fun scanWithTimeout(timeoutMs: Long, block: () -> T): T? { + val holder = java.util.concurrent.atomic.AtomicReference() + val done = java.util.concurrent.CountDownLatch(1) + Thread({ + runCatching { holder.set(block()) } + done.countDown() + }, "ktv-scan").apply { isDaemon = true }.start() + val finished = runCatching { + done.await(timeoutMs, java.util.concurrent.TimeUnit.MILLISECONDS) + }.getOrDefault(false) + return if (finished) holder.get() else null + } + private fun localSongInventory(): LinkedHashMap { val result = LinkedHashMap() library.muse.localPathSongs().forEach { song -> @@ -9766,7 +9873,7 @@ class MainActivity : AppCompatActivity() { return SongRowState( current = currentSong?.equals(song) == true, queued = orderQueue!!.contains(song), - local = song.hasLocalFile(), + local = hasPlayableLocalFile(song), downloading = isDownloading(song), failed = taskState.startsWith("失败"), paused = taskState.contains("暂停") || taskState.contains("中断"), @@ -10000,7 +10107,7 @@ class MainActivity : AppCompatActivity() { } private fun isSongReadyForQueue(song: Song): Boolean = - SongOkDownloadManager.isDownloaded(song) || song.hasLocalFile() + hasPlayableLocalFile(song) || SongOkDownloadManager.isDownloaded(song) private fun addReadySongToQueue(song: Song) { if (orderQueue!!.contains(song)) return @@ -10598,6 +10705,8 @@ class MainActivity : AppCompatActivity() { private const val LEGACY_PACKAGE = "com.origjoy.local.ktv" private const val LEGACY_KTV_ID = "10006789" // 门店/包厢 id private const val HEARTBEAT_INTERVAL_MS = 3600_000L + /** 公放候选预热时，外部目录扫描（可能遍历 /storage/ 各挂载点）的超时上限。 */ + private const val RANDOM_SCAN_TIMEOUT_MS = 4_000L // ===== 主题色(对标原版麦动 配色) ===== /** 主背景:极深蓝黑(原版 #080C12 系) */