Introduction to qjobs

qjobs is a powerful job queue manager designed to optimize and streamline your application’s task processing. It allows you to efficiently manage and process jobs, making it incredibly useful for applications dealing with a large number of background tasks. In this blog post, we’ll go through various qjobs APIs and provide you with code snippets to help you get started. Additionally, we will include a comprehensive app example that ties all the introduced APIs together.

Installation

npm install qjobs

Basic Usage

 const QJobs = require('qjobs');
const q = new QJobs({maxConcurrency: 2, timeout: 5000});
function task(data, done) {
  console.log('Processing:', data);
  setTimeout(done, 1000);
}
q.add(task, 'job1'); q.add(task, 'job2'); q.add(task, 'job3');
q.start(); 

Advanced API Examples

Setting Maximum Concurrency

 q.setMaxConcurrency(3); 

Setting Timeout

 q.setTimeout(10000); // Set timeout to 10 seconds 

Handling Job Completion

 q.on('end', () => {
  console.log('All jobs completed!');
}); 

Error Handling

 q.on('error', (err) => {
  console.error('Job error:', err);
}); 

Comprehensive App Example

Let’s put everything together into a comprehensive example

 const QJobs = require('qjobs');
const q = new QJobs({maxConcurrency: 2, timeout: 5000});
function downloadFile(url, done) {
  console.log('Downloading:', url);
  setTimeout(() => {
    console.log('Downloaded:', url);
    done();
  }, 2000);
}
function processFile(data, done) {
  console.log('Processing:', data);
  setTimeout(() => {
    console.log('Processed:', data);
    done();
  }, 1000);
}
q.add(downloadFile, 'http://example.com/file1'); q.add(downloadFile, 'http://example.com/file2'); q.add(processFile, 'file1-data'); q.add(processFile, 'file2-data');
q.on('end', () => {
  console.log('All download and processing jobs completed!');
});
q.on('error', (err) => {
  console.error('Job error:', err);
});
q.start(); 

By following this example, you can handle downloading and processing files efficiently using qjobs. With its powerful concurrency management features, you can optimize your job processing tasks easily.

Hash: d5ca407433bff1be164cb701c0819c941b8a45f7a9649d625da589265fcc84cc