task_farmer_quickstart_with_concurrency_controlled_worker.ts

1import { TaskFarmer } from 'task-farmer';
2
3/**
4 * Define the input data type and the worker function.
5 * The worker function processes a single item and returns a result.
6 */
7interface MyTask {
8  id: number;
9  name: string;
10}
11
12const tasks: MyTask[] = [
13  { id: 1, name: 'Task 1' },
14  { id: 2, name: 'Task 2' },
15  { id: 3, name: 'Task 3' },
16  { id: 4, name: 'Task 4' },
17  { id: 5, name: 'Task 5' },
18];
19
20async function worker(task: MyTask): Promise<string> {
21  // Simulate an asynchronous operation (e.g., API call or file processing)
22  return new Promise((resolve) => {
23    setTimeout(() => {
24      console.log(`Finished processing: ${task.name}`);
25      resolve(`Result for ${task.name}`);
26    }, 1000);
27  });
28}
29
30async function run() {
31  // Initialize the TaskFarmer with the worker and concurrency limit (e.g., 2)
32  const farmer = new TaskFarmer<MyTask, string>(worker, { concurrency: 2 });
33
34  // Add tasks to the farmer and wait for all results
35  try {
36    const results = await farmer.run(tasks);
37    console.log('All tasks completed:');
38    console.log(results);
39  } catch (error) {
40    console.error('An error occurred during task processing:', error);
41  }
42}
43
44run();