ins-async-tasks

Simple And Easy to manage lots of async tasks in ways of Serial And Parallel provide five API as bellow: waterfall,waterfallList,all,allList,chuckTask exmaples in Usage

Install

    npm install ins-async-tasks --save

Usage

   import * as AsyncTasks from 'ins-async-tasks';
   //or
   const AsyncTasks=require('ins-async-tasks');

API examples

data structure information

define settledValue,task,tasks

    const task=()=>new Promise((resolve,reject)=>{})
    const tasks=[task]
    const settledValue=[
        {
            status: 'fulfilled',
            value:"your resolved data can be string or any object",
        },
          {
            status: 'rejected',
            reason:new Error('error detail message')
        },
        {
            status: 'fulfilled',
            value:"your resolved data can be string or any object",
        }
    // ]

waterfallList()

Compose and execute tasks from array in ways of serial

Effect：
  Task1 ----->|
  Task2    -------->|
  Task3         --->|
  Exec ---------------------->|

    const list=[1,2,3]
    const res=await AsyncTasks.waterfallList(list,(item,i,resolve,reject)=>{
        if(i!=1){
            setTimeout(()=>{
                resolve(`data${i+1}`)
            },i*1000)
        }else{
            reject(new Error(`task with index of ${i} failed`)
        }
    })
    // res is settledValue;

waterfall()

Different types of tasks will be executed in ways of serial

Effect：
  Task1 ----->|
  Task2    -------->|
  Task3         --->|
  Exec ---------------------->|

    const res=await AsyncTasks.waterfall([task1,task2,task3])
    // res is settledValue;

allList()

Compose and execute tasks from array in ways of parallel and ignore error

Effect：
  Task1 ----->|
  Task2 -------->|
  Task3 --->|
   Exec --------->|

    const list=[1,2,3]
    const res=await AsyncTasks.allList(list,(item,i,resolve,reject)=>{
        if(i!=1){
            setTimeout(()=>{
                resolve(`data${i+1}`)
            },i*1000)
        }else{
            reject(new Error(`task with index of ${i} failed`)
        }
    })
    // res=['data1','data3']

all()

Different types of tasks will be executed in ways of parallel and ignore error

Effect：
  Task1 ----->|
  Task2 -------->|
  Task3 --->|
   Exec -------->|

    const res=await AsyncTasks.all([task1,task2,task3])
    // if task2 has error, res=["data1","data3"]

allSettleList()

Different types of tasks will be executed in ways of parallel the same effect with AsyncTasks.allList but return settled value

    const list=[1,2,3]
    const res=await AsyncTasks.allSettleList(list,(item,i,resolve,reject)=>{
        if(i!=1){
            setTimeout(()=>{
                resolve(`data${i+1}`)
            },i*1000)
        }else{
            reject(new Error(`task with index of ${i} failed`)
        }
    })
    // res is settledValue;

allSettle()

Different types of tasks will be executed in ways of parallel the same effect with AsyncTasks.all but return settled value

    const res=await AsyncTasks.all([task1,task2,task3])
    // res is settledValue;

chunkTask()

Large numbers of Tasks chunked with group and Executed,the tasks in group are executed in parallel,different groups are in serial. error will be ignored.

Effect：
  Task1 ----->|
  Task2 -------->|
  Task3 --->|
  Group1 -------->|
 Wait          |-->|
  Task4        ----->|
  Task5        -------->|
  Task6        ----------->|
  Group2       ------------>|
 Wait                  |-->|
  Task7                ----------->|

    //group chunked with 3 tasks,and sleep for 1000 milliseconds between different groups;

    const res=await AsyncTasks.chunkTask(tasks,3,1000)
    // res=[
    //     [ "data1","data2","data3"],
    //     ["data4","data5","data6"],
    //     [,"data7"],
    // ]
    const flatResult=res.flat();
    // flatResult=["data1","data2","data3","data4","data5","data6","data7"]

chunkSettle()

the same effect with chunkTask but catch all error and reject;

    //group chunked with 3 tasks,and sleep for 1000 milliseconds between different groups;
    const res=await AsyncTasks.chunkSettle(tasks,3,1000)
    const flatResult=res.flat();
    // flatResult is settledValue