1. 程式人生 > >關於那些變化萬千,開箱即用的 Promise 高度封裝方法

關於那些變化萬千,開箱即用的 Promise 高度封裝方法

前言

在日常開發中,我們少不了使用 Promise,而透過封裝抽象方法,可以避免造輪子,寫出更加優雅的程式碼。例如:將任意函式,化為具有非同步能力的函式、改裝成具有並發上千萬請求的函式、使用 Web Worker 來使用不同執行緒、暫停若干秒再繼續。這裡就讓我們一起來動手封裝這些方法吧。

promisify

無論什麼函式,我們也可以將它化為非同步函式。

這裡使用 currying 來返回一個函式,再返回一個 Promise 來呼叫原本的函式。

而且,可以用 ...rest 來傳遞所有引數,而不是 arguments

  1. const promisify = func =>(...args)=>

  2. new

    Promise((resolve, reject)=>

  3.    func(...args,(err, result)=>(err ? reject(err): resolve(result)))

  4. );

使用方法

  1. const delay = promisify((d, cb)=> setTimeout(cb, d));

  2. delay(2000)

  3. .then(()=> console.log('Hello World!'));

值得一提的是,如果你的 Node.js 版本為 8 以上,你可以使用 util.promisify

  1. const util =require('util');

  2. const fs

    =require('fs');

  3. const stat = util.promisify(fs.stat);

  4. stat('.').then((stats)=>{

  5. // 做你要做的事情

  6. }).catch((error)=>{

  7. // 處理錯誤

  8. });

你也可以使用 async/await 版本:

  1. const util =require('util');

  2. const fs =require('fs');

  3. const stat = util.promisify(fs.stat);

  4. async function callStat(){

  5. const stats = await stat('.');

  6.  console.log(`This directory is owned by ${stats.uid}`

    );

  7. }

runAsync

使用 Web Worker 來在獨立執行緒呼叫函式,避免阻塞 UI 互動。

我們首先會使用 Blob 物件連結來建立一個 Worker,裡面的內容是純字串的函式。

然後,馬上使用這個 worker,並返回一個 Promise

監聽 onmessage 及 onerror 事件,然後處理返回的 data。

程式碼片段:

  1. const runAsync = fn =>{

  2. const worker =newWorker(

  3.    URL.createObjectURL(newBlob([`postMessage((${fn})());`]),{

  4.      type:'application/javascript; charset=utf-8'

  5. })

  6. );

  7. returnnewPromise((res, rej)=>{

  8.    worker.onmessage =({ data })=>{

  9.      res(data), worker.terminate();

  10. };

  11.    worker.onerror = err =>{

  12.      rej(err), worker.terminate();

  13. };

  14. });

  15. };

使用例子:

  1. const longRunningFunction =()=>{

  2. let result =0;

  3. for(let i =0; i <1000; i++){

  4. for(let j =0; j <700; j++){

  5. for(let k =0; k <300; k++){

  6.        result = result + i + j + k;

  7. }

  8. }

  9. }

  10. return result;

  11. };

  12. runAsync(longRunningFunction).then(console.log);// 209685000000

  13. runAsync(()=>10**3).then(console.log);// 1000

值得注意的是,由於函式執行的環境不同,所有變數和函式都需要在裡面定義。

使用外部變數的話,會出現問題:

  1. let outsideVariable =50;

  2. runAsync(()=>typeof outsideVariable).then(console.log);// 'undefined'

同時執行 Promise

如果想要一次性地幾千個請求的話,使用 Promise.all() 方法就可以達到並發的效果了。

使用方法

  1. const test = time =>newPromise(resolve =>{

  2.    setTimeout(()=> resolve(time), time);

  3. });

  4. const temp =[test(1000), test(2000), test(3000)];

  5. Promise.all(temp).then(console.log);// [1000, 2000, 3000]

runPromisesInSeries

如果你想要一個個串聯,執行一系列的 Promise的話,可以使用 Array.prototype.reduce() 來製造一個 Promise 的鏈。當下個 Promise resolved, 返回上一個 Promise。

  1. const runPromisesInSeries = ps => ps.reduce((p,next)=> p.then(next),Promise.resolve());

使用方法

  1. const delay = time =>newPromise(resolve =>{

  2.    console.log(time);

  3.    setTimeout(resolve, time);

  4. });

  5. const promiseSeries =[()=> delay(1000),()=> delay(2000)];

  6. runPromisesInSeries(promiseSeries);

sleep

簡單來說,就是讓函式等若干秒,然後再執行下一步。

  1. const sleep = ms =>newPromise(resolve => setTimeout(resolve, ms));

使用方法

  1. async function sleepyWork(){

  2.  console.log("等一秒");

  3.  await sleep(1000);

  4.  console.log('一秒過去了');

  5. }

isPromiseLike

我們可以簡單容易地判斷一個目標是否類似 Promise

我們可以使用判斷物件是否為 null,而且 typeof 的返回值是 object 或者 function,而且它擁有 .then 的屬性。

  1. const isPromiseLike = obj =>

  2.  obj !==null&&

  3. (typeof obj ==='object'||typeof obj ==='function')&&

  4. typeof obj.then==='function';

使用方法

  1. const promise =newPromise(resolve