82 lines
1.9 KiB
JavaScript
82 lines
1.9 KiB
JavaScript
|
/*
|
|||
|
|
开发环境不开启定时器
|
|||
|
|
*/
|
|||
|
|
const isStartTimer = process.env.NODE_ENV !== 'development'
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @function 定时器
|
|||
|
|
* @param fn { function } 执行过程
|
|||
|
|
* @param duration { timestamp } 间隔时间
|
|||
|
|
* @param immediate { boolean } 是否立即执行
|
|||
|
|
* @returns {{stop(): void, restart: restart}}
|
|||
|
|
*/
|
|||
|
|
export default function timer(fn, duration = 5 * 1000, immediate = true) {
|
|||
|
|
// 执行队列
|
|||
|
|
let processes = []
|
|||
|
|
let _args = []
|
|||
|
|
// 定义定时器
|
|||
|
|
let timer = null
|
|||
|
|
let _duration = duration
|
|||
|
|
// 过程支持list和单一函数
|
|||
|
|
if (Array.isArray(fn)) {
|
|||
|
|
processes.push.apply(processes, fn)
|
|||
|
|
} else {
|
|||
|
|
processes.push(fn)
|
|||
|
|
}
|
|||
|
|
/**
|
|||
|
|
* @function 过程执行器
|
|||
|
|
* @param processes { Array<function> | function }
|
|||
|
|
* @param args { any }
|
|||
|
|
* @returns {Promise<void>}
|
|||
|
|
*/
|
|||
|
|
const exec = async (processes, ...args) => {
|
|||
|
|
_args = args
|
|||
|
|
try {
|
|||
|
|
if (timer) {
|
|||
|
|
clearTimeout(timer)
|
|||
|
|
timer = null
|
|||
|
|
}
|
|||
|
|
for (let process of processes) {
|
|||
|
|
if (typeof process === 'function') {
|
|||
|
|
await process(..._args)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
} catch (e) {
|
|||
|
|
console.error('TimerError:', e)
|
|||
|
|
} finally {
|
|||
|
|
if (!isStartTimer) return false
|
|||
|
|
timer = setTimeout(() => {
|
|||
|
|
exec(processes, ..._args)
|
|||
|
|
}, _duration)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if (immediate) {
|
|||
|
|
exec(processes)
|
|||
|
|
}
|
|||
|
|
return {
|
|||
|
|
stop () {
|
|||
|
|
if (timer) {
|
|||
|
|
clearTimeout(timer)
|
|||
|
|
timer = null
|
|||
|
|
processes = null
|
|||
|
|
_args = null
|
|||
|
|
}
|
|||
|
|
},
|
|||
|
|
clearParams () {
|
|||
|
|
_args = []
|
|||
|
|
},
|
|||
|
|
/**
|
|||
|
|
* 定时器重启
|
|||
|
|
* @param args { { params: Array<any>, duration: number } } 回调的参数
|
|||
|
|
*/
|
|||
|
|
restart: function (options = {}) {
|
|||
|
|
const { params = [], duration } = options
|
|||
|
|
// 不能用全等，对象中的undefined 与 undefined 不是全等
|
|||
|
|
if (duration != undefined || duration != null) {
|
|||
|
|
_duration = duration
|
|||
|
|
}
|
|||
|
|
exec(processes, ...(params || []))
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|