update: use parallel limit

ChanceYu · Dec 1, 2024 · a77c044 · a77c044
1 parent 20903dc
commit a77c044
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 6 deletions.
diff --git a/server/update.js b/server/update.js
@@ -23,13 +23,12 @@ let newData = null
 /**
  * 更新 git 仓库
  */
-function handleUpdate() {
-  if (utils.WORKFLOW) {
-    handleFeed()
-  } else {
+async function handleUpdate() {
+  if (!utils.WORKFLOW) {
     utils.log('开始更新抓取')
-    git.pull().exec(handleFeed)
+    await git.pull()
   }
+  handleFeed()
 }
 
 /**
@@ -98,7 +97,7 @@ function handleFeed() {
     })())
   }))
 
-  Async.series(tasks, async () => {
+  Async.parallelLimit(tasks, 5, async () => {
     if (newData.length) {
       fs.outputJsonSync(LINKS_PATH, linksJson)
       await writemd(newData, linksJson)

diff --git a/server/utils.js b/server/utils.js
@@ -27,6 +27,8 @@ const tags = fs.readJsonSync(TAGS_PATH)
  */
 const WORKFLOW = !!process.env.WORKFLOW
 
+console.log('WORKFLOW:', WORKFLOW)
+
 module.exports = {
   WORKFLOW,
   /**