Introduction to Advanced Queue

The advanced-queue library offers a comprehensive suite of powerful APIs for efficient task management. Whether you’re looking to handle concurrent tasks, implement sophisticated retry mechanisms, or ensure smooth task prioritization, advanced-queue has got you covered. Below, we delve into several key features and how you can leverage them in your applications.

Queue Initialization

Initialization of a queue is straightforward. Here’s how you can create an instance of advanced-queue:

  
    const { AdvancedQueue } = require('advanced-queue');
    const queue = new AdvancedQueue();
  

Adding Tasks to the Queue

Adding tasks is simple with the add method:

  
    queue.add(async () => {
      console.log('Task executed');
    });
  

Handling Concurrent Tasks

The concurrency parameter allows you to manage multiple tasks:

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

Task Prioritization

Assign priorities to tasks to make sure critical jobs are processed first:

  
    queue.add(async () => {
      console.log('High priority task');
    }, { priority: 1 });

    queue.add(async () => {
      console.log('Low priority task');
    }, { priority: 5 });
  

Retry Mechanism

Implement robust retry logic with exponential backoff:

  
    queue.add(async () => {
      console.log('Retrying task');
      throw new Error('Task failure');
    }, { retries: 5, backoff: 1000 });
  

Task Cancellation

Cancel tasks when necessary:

  
    const task = queue.add(async () => {
      console.log('Cancelable task');
    });

    task.cancel();
  

Pause and Resume Queue

Pause and resume task execution:

  
    queue.pause();

    queue.add(async () => {
      console.log('Task while paused');
    });

    queue.resume();
  

Queue Events

Listen to queue events for better control and debugging:

  
    queue.on('taskStart', (task) => {
      console.log(`Task started: ${task.id}`);
    });

    queue.on('taskEnd', (task) => {
      console.log(`Task ended: ${task.id}`);
    });
  

Advanced Queue App Example

Here is a simple app example integrating the APIs above:

  
    const { AdvancedQueue } = require('advanced-queue');
    const queue = new AdvancedQueue({ concurrency: 2 });

    queue.on('taskStart', (task) => {
      console.log(`Task started: ${task.id}`);
    });

    queue.on('taskEnd', (task) => {
      console.log(`Task ended: ${task.id}`);
    });

    queue.add(async () => {
      console.log('High priority task');
    }, { priority: 1 });

    queue.add(async () => {
      console.log('Low priority task');
    }, { priority: 5 });
    
    queue.add(async () => {
      console.log('Retrying task');
      throw new Error('Task failure');
    }, { retries: 3, backoff: 500 });
    
    queue.pause();
    
    queue.add(async () => {
      console.log('Task while paused');
    });

    queue.resume();
  

Utilizing these advanced APIs, your applications can handle a wide range of task management scenarios with ease and efficiency.

Hash: bdb3fd26d1c4fd1d633d666c73c00fc986a9637e777c4d4da6a43d0665658dfd