Queue

const queue = new Queue(options?: QueueOptions);

add<T>(fn: () => PromiseLike<T> | T, options?: AddOptions): Promise<T>

addAll<T>(fns: (() => Promise<T>)[], options?: AddOptions): Promise<T[]>

pause(): void

resume(): void

clear(): void

get size(): number

get pending(): number

get onIdle(): Promise<void>

import { Queue } from '@temelj/async';

const queue = new Queue({ concurrency: 2 });

const results = await Promise.all([
  queue.add(() => fetchData(1)),
  queue.add(() => fetchData(2)),
  queue.add(() => fetchData(3)),
  queue.add(() => fetchData(4)),
]);

console.log(results);

import { Queue } from '@temelj/async';

const queue = new Queue({ concurrency: 1 });

queue.add(() => console.log('Low priority'), { priority: 0 });
queue.add(() => console.log('High priority'), { priority: 10 });
queue.add(() => console.log('Medium priority'), { priority: 5 });

// Output:
// High priority
// Medium priority
// Low priority

import { Queue } from '@temelj/async';

const queue = new Queue({ concurrency: 2 });

queue.add(async () => {
  await delay(100);
  console.log('Task 1');
});

queue.add(async () => {
  await delay(50);
  console.log('Task 2');
});

// Wait for all tasks to complete
await queue.onIdle;
console.log('All tasks done');

import { Queue } from '@temelj/async';

const queue = new Queue({ concurrency: 1 });

queue.add(() => console.log('Task 1'));
queue.add(() => console.log('Task 2'));

queue.pause();
console.log('Queue paused');

queue.add(() => console.log('Task 3'));

setTimeout(() => {
  console.log('Resuming queue');
  queue.resume();
}, 1000);

import { Queue } from '@temelj/async';

const queue = new Queue({ 
  concurrency: 2,
  autoStart: false 
});

// Add tasks while paused
queue.add(() => fetchData(1));
queue.add(() => fetchData(2));
queue.add(() => fetchData(3));

console.log(`${queue.size} tasks queued`);

// Start processing when ready
queue.resume();

import { Queue } from '@temelj/async';

const queue = new Queue({ concurrency: 2 });
const controller = new AbortController();

const task1 = queue.add(
  async () => {
    await delay(1000);
    return 'Done';
  },
  { signal: controller.signal }
);

// Cancel task
controller.abort();

try {
  await task1;
} catch (error) {
  console.log('Task cancelled');
}

import { Queue } from '@temelj/async';

const queue = new Queue({ concurrency: 5 });

const userIds = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10];

const users = await queue.addAll(
  userIds.map(id => async () => {
    const response = await fetch(`/api/users/${id}`);
    return await response.json();
  })
);

console.log(`Fetched ${users.length} users`);

import { Queue } from '@temelj/async';

const queue = new Queue({ concurrency: 1 });

queue.add(async () => {
  await delay(100);
  console.log('This will run');
});

queue.add(() => console.log('This will be cleared'));
queue.add(() => console.log('This will be cleared too'));

queue.clear();

await queue.onIdle;
console.log('Done');