Function work

packages/arctic/src/util/queue.ts:21–32

(concurrency: number, items: T[], fn: (item: T) => Promise<void>)

}

export async function work<T>(concurrency: number, items: T[], fn: (item: T) => Promise<void>) {
  const pending = [...items]
  await Promise.all(
    Array.from({ length: concurrency }, async () => {
      while (true) {
        const item = pending.pop()
        if (item === undefined) return
        await fn(item)
      }
    }),
  )
}