NodeJs入門教程之定時器和隊列

來源：懂視網(wǎng) 責編：小采時間：2020-11-27 22:00:20

NodeJs入門教程之定時器和隊列

NodeJs入門教程之定時器和隊列:一,介紹與需求 1.1,介紹定時任務（node-schedule)，是針對Node.js的一種靈活的cron-like和not-cron-like作業(yè)調(diào)度程序。它允許您使用可選的遞歸規(guī)則將作業(yè)(任意函數(shù))安排在特定日期執(zhí)行。它在任何給定的時間只使用一個計時器(而不是每秒鐘/分鐘重新評估

推薦度：

點擊下載本文 文檔為doc格式

導讀NodeJs入門教程之定時器和隊列:一,介紹與需求 1.1,介紹定時任務（node-schedule)，是針對Node.js的一種靈活的cron-like和not-cron-like作業(yè)調(diào)度程序。它允許您使用可選的遞歸規(guī)則將作業(yè)(任意函數(shù))安排在特定日期執(zhí)行。它在任何給定的時間只使用一個計時器(而不是每秒鐘/分鐘重新評估

6個占位符從左到右分別代表：秒、分、時、日、月、周幾

*表示通配符，匹配任意，當秒是*時，表示任意秒數(shù)都觸發(fā)，其它類推

// 每分鐘的第30秒觸發(fā)： '30 * * * * *'
// 每小時的1分30秒觸發(fā) ：'30 1 * * * *'
// 每天的凌晨1點1分30秒觸發(fā) ：'30 1 1 * * *'
// 每月的1日1點1分30秒觸發(fā) ：'30 1 1 1 * *'
// 2016年的1月1日1點1分30秒觸發(fā) ：'30 1 1 1 2016 *'
// 每周1的1點1分30秒觸發(fā) ：'30 1 1 * * 1'
// 每分鐘的1-10秒都會觸發(fā)，其它通配符依次類推 ：'1-10 * * * * *'

調(diào)用定時器：

 nodeTimer.scheduleTimer('30 * * * * *',function(err){
 if(!err){
 console.log('scheduleTimer:' + new Date());
 }
 });

效果：

2、對象文本語法定時器

second (0-59)

minute (0-59)

hour (0-23)

date (1-31)

month (0-11)

year

dayOfWeek (0-6) Starting with Sunday

//每周一的下午15：03：30觸發(fā)，其它組合可以根據(jù)我代碼中的注釋參數(shù)名自由組合
nodeTimer.scheduleTimer({hour: 15, minute: 3, second: 30},function(err){
 if(!err){
 console.log('scheduleTimer:' + new Date());
 }
 });

效果:

3、基于日期的定時器

var date = new Date(2019, 01, 07, 15, 03, 30);
nodeTimer.scheduleTimer(date,function(err){
 if(!err){
 console.log('scheduleTimer:' + new Date());
 }
 });

4、遞歸規(guī)則定時器

參數(shù)與對象文本語法定時器的參數(shù)類似

var rule = new schedule.RecurrenceRule();
rule.dayOfWeek = [0, new schedule.Range(4, 6)];//每周四，周五，周六執(zhí)行
rule.hour = 15;
rule.minute = 0;
nodeTimer.scheduleTimer(rule,function(err){
 if(!err){
 console.log('scheduleTimer:' + new Date());
 }
 });

5、取消定時器

// 取消定時器
// 調(diào)用 定時器對象的cancl()方法即可
nodeTimer.scheduleCancel = () => {
 // 定時器取消
 cancelTimer.cancel();
 console.log('定時器成功取消');
}

調(diào)用：

 nodeTimer.scheduleCancel()

效果：

三,隊列

第一步：安裝async

 npm install --save async

第二步：封裝方法

queue相當于一個加強版的parallel，主要是限制了worker數(shù)量，不再一次性全部執(zhí)行。當worker數(shù)量不夠用時，新加入的任務將會排隊等候，直到有新的worker可用。

該函數(shù)有多個點可供回調(diào)，如worker用完時、無等候任務時、全部執(zhí)行完時等。

const async = require('async');
 /**
 *隊列
 * @param obj ：obj對象 包含執(zhí)行時間
 * @param callback ：回調(diào)函數(shù)
 */
const nodeQueue = async.queue(function (obj, callback) {
 setTimeout(function () {
 // 需要執(zhí)行的代碼的回調(diào)函數(shù)
 if(typeof callback==='function'){
 callback();
 }
 }, obj.time)
}, 1)

// worker數(shù)量將用完時，會調(diào)用saturated函數(shù)
nodeQueue.saturated = function() { 
 console.log('all workers to be used'); 
}
 
// 當最后一個任務交給worker執(zhí)行時，會調(diào)用empty函數(shù)
nodeQueue.empty = function() { 
 console.log('no more tasks wating'); 
}
 
// 當所有任務都執(zhí)行完時，會調(diào)用drain函數(shù)
nodeQueue.drain = function() { 
 console.log('all tasks have been processed'); 
}
module.exports = nodeQueue;

第三步：調(diào)用方法

const nodeQueue = require('./node_queue.js');
 for (let i = 0; i < 10; i++) {
 nodeQueue.push({ name: 1, time: 2000 }, function (err) {
 console.log('隊列執(zhí)行錯誤信息==',err);
 if(!err){
 // 需要執(zhí)行的代碼或函數(shù)
 console.log('需要執(zhí)行的代碼或函數(shù)第',i+1,'個')
 }
 })
 };

效果：