Goatworks/Capital
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

⏪ Rollback to fix bugs

Browse Source
This commit is contained in:
LittleSheep 2024-09-18 23:56:00 +08:00
parent 0c2f5f9bba
commit 6ab960d399
1 changed files with 3 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
pages/gallery/new.vue
View File

@ -133,33 +133,10 @@ async function submit() {
}
}
const queue = []
const limit = 3 // Set the concurrency limit
for (let i = 0; i < chunks.length; i++) {
// Wrap the promise with an object that holds the promise itself
const task = uploadChunks(chunks[i]).then(
() => ({ chunk: chunks[i], status: "fulfilled" }),
() => ({ chunk: chunks[i], status: "rejected" }),
)
queue.push(task)
// If the number of running tasks exceeds the limit, wait for one to finish
if (queue.length >= limit) {
// Wait for any one task to finish
const finishedTask = await Promise.race(queue)
// Find and remove the finished task's promise from the queue
queue.splice(
queue.findIndex((p) => p === task),
1,
)
for (let i = 0; i < chunks.length; i += limit) {
const chunkSlice = chunks.slice(i, i + limit)
await Promise.all(chunkSlice.map(uploadChunks))
}
}
// Await remaining tasks after the loop finishes
await Promise.all(queue)
if (multipartInfo.value["is_uploaded"]) {
console.log(`[PAPERCLIP] Entire file has been uploaded in ${multipartProgress.total} chunk(s)`)