@a417420427/queue

an js queue

使用

import Queue from '@a417420427/queue'
const queue = new Queue({ concurrency: 3 })

const sleep = (time: number) =>
  new Promise((resolve) => setTimeout(resolve, time))

const currentTime = () => Date.now()
let timeStamp = currentTime()
queue.push(async () => {
  await sleep(1000)
  console.log('sleep 1000ms after ' + (currentTime() - timeStamp))
})
queue.push(async () => {
  await sleep(2000)
  console.log('sleep 2000ms after ' + (currentTime() - timeStamp))
})
queue.push(async () => {
  await sleep(3000)
  console.log('sleep 3000ms after ' + (currentTime() - timeStamp))
})
queue.push(() => {
  console.log('worked after ' + (currentTime() - timeStamp))
})
queue.push(async () => {
  await sleep(1000)
  console.log('over after ' + (currentTime() - timeStamp))
})

queue.start()

// 输出
/**
sleep 1000ms after 1037
worked after 1037
sleep 2000ms after 2100
over after 2100
sleep 3000ms after 4184
 * 
*/