日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時間:8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
Node.js知識—如何實現(xiàn)線程睡眠?

本文轉(zhuǎn)載自微信公眾號「Nodejs技術(shù)?!?,作者五月君。轉(zhuǎn)載本文請聯(lián)系Nodejs技術(shù)棧公眾號。

成都創(chuàng)新互聯(lián)公司是一家專注于成都做網(wǎng)站、網(wǎng)站設(shè)計與策劃設(shè)計,弓長嶺網(wǎng)站建設(shè)哪家好?成都創(chuàng)新互聯(lián)公司做網(wǎng)站,專注于網(wǎng)站建設(shè)十載,網(wǎng)設(shè)計領(lǐng)域的專業(yè)建站公司;建站業(yè)務(wù)涵蓋:弓長嶺等地區(qū)。弓長嶺做網(wǎng)站價格咨詢:028-86922220

Node.js 小知識 記錄一些工作中或 “Nodejs技術(shù)?!?交流群中大家遇到的一些問題,有時一個小小的問題背后也能延伸出很多新的知識點,解決問題和總結(jié)的過程本身也是一個成長的過程,在這里與大家共同分享成長。

使用 JavaScript/Node.js 的開發(fā)者如果遇到需要實現(xiàn)延遲的任務(wù),可能會有疑問????? 為什么這里沒有類似 Java 中 Thread.sleep() 這樣的方式來實現(xiàn)線程睡眠,本文講解如何在 Node.js 中實現(xiàn)一個 sleep() 函數(shù)。

一:糟糕的 “循環(huán)空轉(zhuǎn)”

下面這段代碼是糟糕的,Node.js 是以單進程、單線程的方式啟動,所有的業(yè)務(wù)代碼都工作在主線程,這樣會造成 CPU 持續(xù)占用,主線程阻塞對 CPU 資源也是一種浪費,與真正的線程睡眠相差甚遠。

 
 
 
 
  1. const start = new Date(); 
  2. while (new Date() - start < 2000) {} 

 

運行之后如上圖所示,CPU 暴漲,同時也會破壞事件循環(huán)調(diào)度,導(dǎo)致其它任務(wù)無法執(zhí)行。

二:定時器 + Promise 實現(xiàn) sleep

通過定時器延遲執(zhí)行函數(shù) setTimeout + Promise 的鏈式依賴實現(xiàn),本質(zhì)是創(chuàng)建一個新的 Promise 對象,待定時器延遲時間到了執(zhí)行 resolve 函數(shù)這時 then 才會執(zhí)行,這里 Node.js 執(zhí)行線程是沒有進行睡眠的,事件循環(huán)和 V8 等都是正常運行的。但這也是目前通用的一種解決方案,因為你不能讓主線程阻塞,否則程序就無法繼續(xù)工作了。

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

在 Node.js 中還可以利用 util 模塊提供的 promisify 方法實現(xiàn),一種快捷方式。

 
 
 
 
  1. const { promisify } = require('util'); 
  2. const sleep = promisify(setTimeout); 

因為是基于定時器與 Promise 所以也自然是異步的方式了,使用時也要注意,如下所示:

 
 
 
 
  1. // async await 的方式 
  2. async function test() { 
  3.   console.log(1); 
  4.   await sleep(3000); 
  5.   console.log(2); 
  6.  
  7. // Promise 的鏈式調(diào)用方式 
  8. async function test() { 
  9.   console.log(1); 
  10.   sleep(3000).then(() => { 
  11.     console.log(2); 
  12.   }); 

三:零 CPU 開銷真正的事件循環(huán)阻止 sleep 實現(xiàn)

ECMA262 草案提供了 Atomics.wait API 來實現(xiàn)線程睡眠,它會真正的阻塞事件循環(huán),阻塞線程直到超時。

該方法 Atomics.wait(Int32Array, index, value[, timeout]) 會驗證給定的 Int32Array 數(shù)組位置中是否仍包含其值,在休眠狀態(tài)下會等待喚醒或直到超時,返回一個字符串表示超時還是被喚醒。

同樣的因為我們的業(yè)務(wù)是工作在主線程,避免在主線程中使用,在 Node.js 的工作線程中可以根據(jù)實際需要使用。

 
 
 
 
  1. /** 
  2.  * 真正的阻塞事件循環(huán),阻塞線程直到超時,不要在主線程上使用  
  3.  * @param {Number} ms delay 
  4.  * @returns {String} ok|not-equal|timed-out 
  5.  */ 
  6. function sleep(ms) { 
  7.   const valid = ms > 0 && ms < Infinity; 
  8.   if (valid === false) { 
  9.     if (typeof ms !== 'number' && typeof ms !== 'bigint') { 
  10.       throw TypeError('ms must be a number'); 
  11.     } 
  12.     throw RangeError('ms must be a number that is greater than 0 but less than Infinity'); 
  13.   } 
  14.  
  15.   return Atomics.wait(int32, 0, 0, Number(ms)) 
  16.  
  17. sleep(3000) 

由于本節(jié)我們僅是在講解 sleep 的實現(xiàn),所以關(guān)于 Atomics.wait 方法睡眠之后如何被其它線程喚醒也不再此處講了,之后我會寫一講 Node.js 中的工作線程相關(guān)文章,到時會再次介紹。

四:基于 N-API 擴展使用 C 語言實現(xiàn) sleep

通過 Addon 的方式使用 N-API 編寫 C/C++ 插件,借助其提供的系統(tǒng) sleep() 函數(shù)實現(xiàn)。

 
 
 
 
  1. // sleep.c 
  2. #include  
  3. #include  
  4. #include  
  5.  
  6. napi_value sleepFn(napi_env env, napi_callback_info info) { 
  7.   napi_status status; 
  8.   size_t argc = 1; 
  9.   napi_value argv[1]; 
  10.  
  11.   status = napi_get_cb_info(env, info, &argc, argv, NULL, NULL); 
  12.   assert(status == napi_ok); 
  13.   if (argc < 1) { 
  14.     napi_throw_type_error(env, NULL, "ms is required"); 
  15.     return NULL; 
  16.   } 
  17.  
  18.   napi_valuetype valueType; 
  19.   napi_typeof(env, argv[0], &valueType); 
  20.   if (valueType != napi_number) { 
  21.     napi_throw_type_error(env, NULL, "ms must be a number"); 
  22.     return NULL; 
  23.   } 
  24.  
  25.   int64_t s; 
  26.   napi_get_value_int64(env, argv[0], &s); 
  27.   sleep(s); 
  28.   return NULL; 
  29.  
  30. napi_value init(napi_env env, napi_value exports) { 
  31.   napi_status status; 
  32.   napi_property_descriptor descriptor = { 
  33.     "sleep", 
  34.     0, 
  35.     sleepFn, 
  36.     0, 
  37.     0, 
  38.     0, 
  39.     napi_default, 
  40.     0 
  41.   }; 
  42.   status = napi_define_properties(env, exports, 1, &descriptor); 
  43.   assert(status == napi_ok); 
  44.   return exports; 
  45.  
  46. NAPI_MODULE(sleep, init); 

經(jīng)過一系列編譯之后,引入 .node 文件直接使用。

 
 
 
 
  1. // app.js 
  2. const { sleep } = require('./build/Release/sleep.node'); 
  3. sleep(3); 

五:easy-sleep 模塊

這是筆者寫的一個小模塊 https://github.com/qufei1993/easy-sleep,其實也是對以上幾種方法的整合,包含了 C 插件的編寫,使用如下:

 
 
 
 
  1. // Install 
  2. npm install easy-sleep -S 
  3.  
  4. // Async sleep 
  5. const { sleep } = require('easy-sleep'); 
  6. await sleep(3000); 
  7.  
  8. // Thread sleep 
  9. const { Thread } = require('easy-sleep'); 
  10. Thread.sleep(); 

 

總結(jié)

由于 JavaScript 是單線程的語言,通常我們都是工作在主線程,如果真的讓線程睡眠了,事件循環(huán)也會被阻塞,后續(xù)的程序就無法正常工作了,大多數(shù)情況,我們也是簡單的對 setTimeout 函數(shù)做一些封裝實現(xiàn)延遲功能。在瀏覽器/Node.js 的工作線程下可以根據(jù)實際需要決定是否需要工作線程睡眠。


當前名稱:Node.js知識—如何實現(xiàn)線程睡眠?
文章轉(zhuǎn)載:http://www.dlmjj.cn/article/dpjjsoo.html