register generate thumb event to before_exit & use async maplimit to …

…20 concurrency
Robin-front · Mar 20, 2018 · 82383be · 82383be
1 parent 8b3e99b
commit 82383be
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 5 deletions.
diff --git a/index.js b/index.js
@@ -16,6 +16,7 @@ if (!lazyload || !lazyload.enable) {
   return;
 }
 
+const concurrency = lazyload.concurrency || 20;
 const loadingImgPath = lazyload.loadingImg || '/js/lazyload-plugin/loading.svg';
 const thumbPath = lazyload.thumbPath || './images/thumb';
 const thumbTargetFolder = path.resolve(hexo.base_dir, 'public/', thumbPath);
@@ -144,9 +145,10 @@ hexo.extend.filter.register('after_post_render', function (data) {
   return data;
 });
 
-hexo.extend.filter.register('after_generate', async function loopPipe() {
-  log('start processing thumb');
-  return await async.mapLimit(waitForThumb, 5, async function (url) {
+hexo.extend.filter.register('before_exit', async function loopPipe() {
+  if (!waitForThumb.length) { return false; }
+  log('start processing ' + waitForThumb.length +' thumb');
+  return await async.mapLimit(waitForThumb, concurrency, async function (url) {
     const response = await generateThumb(url);
     return response;
   }, (err) => {
@@ -155,4 +157,4 @@ hexo.extend.filter.register('after_generate', async function loopPipe() {
     // console.log('results', results)
     log('All thumb process successed !');
   });
-});
+}, 1);
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "hexo-lazyload",
-  "version": "1.2.4",
+  "version": "1.2.5",
   "description": "use IntersectionObserver api to improve lazyload performance",
   "main": "index.js",
   "scripts": {