From 18660844e6382efe2af378faf84396488c1998c4 Mon Sep 17 00:00:00 2001
From: static <kmc7468@naver.com>
Date: Tue, 8 Jul 2025 04:31:19 +0900
Subject: [PATCH] =?UTF-8?q?=EC=8D=B8=EB=84=A4=EC=9D=BC=EC=9D=84=20?=
 =?UTF-8?q?=EC=9D=BC=EA=B4=84=EC=A0=81=EC=9C=BC=EB=A1=9C=20=EC=83=9D?=
 =?UTF-8?q?=EC=84=B1=ED=95=98=EB=8A=94=20=EA=B2=BD=EC=9A=B0=20=EB=B0=9C?=
 =?UTF-8?q?=EC=83=9D=ED=95=98=EB=8D=98=20Out=20of=20Memory=20=EB=AC=B8?=
 =?UTF-8?q?=EC=A0=9C=20=ED=95=B4=EA=B2=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../settings/thumbnails/File.svelte           |  1 +
 .../settings/thumbnails/service.svelte.ts     | 66 +++++++++++++++++--
 2 files changed, 62 insertions(+), 5 deletions(-)

diff --git a/src/routes/(fullscreen)/settings/thumbnails/File.svelte b/src/routes/(fullscreen)/settings/thumbnails/File.svelte
index 8d413ec..8977fc7 100644
--- a/src/routes/(fullscreen)/settings/thumbnails/File.svelte
+++ b/src/routes/(fullscreen)/settings/thumbnails/File.svelte
@@ -1,5 +1,6 @@
 <script module lang="ts">
   const subtexts = {
+    queued: "대기 중",
     "generation-pending": "준비 중",
     generating: "생성하는 중",
     "upload-pending": "업로드를 기다리는 중",
diff --git a/src/routes/(fullscreen)/settings/thumbnails/service.svelte.ts b/src/routes/(fullscreen)/settings/thumbnails/service.svelte.ts
index 97c00d2..79a4022 100644
--- a/src/routes/(fullscreen)/settings/thumbnails/service.svelte.ts
+++ b/src/routes/(fullscreen)/settings/thumbnails/service.svelte.ts
@@ -8,6 +8,7 @@ import type { FileThumbnailUploadRequest } from "$lib/server/schemas";
 import { requestFileDownload } from "$lib/services/file";
 
 export type GenerationStatus =
+  | "queued"
   | "generation-pending"
   | "generating"
   | "upload-pending"
@@ -23,6 +24,10 @@ interface File {
 
 const workingFiles = new Map<number, Writable<GenerationStatus>>();
 
+let queue: (() => void)[] = [];
+let memoryUsage = 0;
+const MEMORY_LIMIT = 100 * 1024 * 1024; // 100 MiB
+
 export const persistentStates = $state({
   files: [] as File[],
 });
@@ -86,18 +91,66 @@ const requestThumbnailUpload = limitFunction(
   { concurrency: 4 },
 );
 
+const enqueue = async (
+  status: Writable<GenerationStatus> | undefined,
+  fileInfo: FileInfo,
+  priority = false,
+) => {
+  if (status) {
+    status.set("queued");
+  } else {
+    status = writable("queued");
+    workingFiles.set(fileInfo.id, status);
+    persistentStates.files = persistentStates.files.map((file) =>
+      file.id === fileInfo.id ? { ...file, status } : file,
+    );
+  }
+
+  let resolver;
+  const promise = new Promise((resolve) => {
+    resolver = resolve;
+  });
+
+  if (priority) {
+    queue = [() => resolver!(), ...queue];
+  } else {
+    queue.push(resolver!);
+  }
+
+  await promise;
+};
+
 export const requestThumbnailGeneration = async (fileInfo: FileInfo) => {
   let status = workingFiles.get(fileInfo.id);
   if (status && get(status) !== "error") return;
 
-  status = writable("generation-pending");
-  workingFiles.set(fileInfo.id, status);
-  persistentStates.files = persistentStates.files.map((file) =>
-    file.id === fileInfo.id ? { ...file, status } : file,
-  );
+  if (workingFiles.values().some((status) => get(status) !== "error")) {
+    await enqueue(status, fileInfo);
+  }
+  while (memoryUsage >= MEMORY_LIMIT) {
+    await enqueue(status, fileInfo, true);
+  }
 
+  if (status) {
+    status.set("generation-pending");
+  } else {
+    status = writable("generation-pending");
+    workingFiles.set(fileInfo.id, status);
+    persistentStates.files = persistentStates.files.map((file) =>
+      file.id === fileInfo.id ? { ...file, status } : file,
+    );
+  }
+
+  let fileSize = 0;
   try {
     const file = await requestFileDownload(fileInfo.id, fileInfo.contentIv!, fileInfo.dataKey!);
+    fileSize = file.byteLength;
+
+    memoryUsage += fileSize;
+    if (memoryUsage < MEMORY_LIMIT) {
+      queue.shift()?.();
+    }
+
     const thumbnail = await generateThumbnail(
       status,
       file,
@@ -110,5 +163,8 @@ export const requestThumbnailGeneration = async (fileInfo: FileInfo) => {
     }
   } catch {
     status.set("error");
+  } finally {
+    memoryUsage -= fileSize;
+    queue.shift()?.();
   }
 };