nv-task-event-loop
- nv-task-event-loop
- simple-loop running until all tasks success
install
- npm install nv-task-event-loop
usage
example
parallel
const {creat_ploop} = require("nv-task-event-loop")
var [ploop,forest] = creat_ploop()
function tsk(rs,rj,self) {
console.log(self.name,"start:",new Date())
setTimeout(
() => {
let cond = (Math.random() >0.5)?true:false;
if(cond) {
console.log(self.name,"succ:",new Date())
rs(Math.random())
} else {
console.log(self.name,"fail:",new Date())
rj(Math.random())
}
},
Math.random()*10000 + 2000
)
}
ploop.add("t0",tsk)
ploop.add("t1",tsk)
ploop.add("t2",tsk)
ploop.add("t3",tsk)
> ploop.$sdfs_
[
Ploop [1 %d1d7c4ad:1% ] {},
Base [2 %d1d7c4ad:2% ] {},
Base [3 %d1d7c4ad:3% ] {},
Base [4 %d1d7c4ad:4% ] {},
Base [5 %d1d7c4ad:5% ] {}
]
>
ploop.start()
>
t0 start: 2021-11-28T10:43:23.418Z
t1 start: 2021-11-28T10:43:23.418Z
t2 start: 2021-11-28T10:43:23.419Z
t3 start: 2021-11-28T10:43:23.419Z
> t3 succ: 2021-11-28T10:43:26.360Z
t2 fail: 2021-11-28T10:43:28.069Z
Uncaught 0.9377473180908764
> t2 start: 2021-11-28T10:43:28.077Z
t2 fail: 2021-11-28T10:43:30.684Z
Uncaught 0.6864665600383024
> t2 start: 2021-11-28T10:43:30.690Z
t1 succ: 2021-11-28T10:43:31.986Z
t0 succ: 2021-11-28T10:43:33.250Z
t2 succ: 2021-11-28T10:43:35.453Z
> ploop.$sdfs_
[ Ploop [1 %8a1501d4:1% ] {} ]
>
ploop.add("t4",tsk)
t4 start: 2021-11-28T10:44:09.914Z
> t4 succ: 2021-11-28T10:44:13.400Z
ploop.add("t5",tsk)
ploop.add("t6",tsk)
ploop.add("t7",tsk)
ploop.add("t8",tsk)
> t8 succ: 2021-11-28T11:56:08.026Z
t6 succ: 2021-11-28T11:56:09.034Z
ploop.pause()
> ploop.$sdfs_
[
Ploop [1 %33ad3d8f:1% ] {},
Base [14 %33ad3d8f:14% ] { name: 't5'},
Base [15 %33ad3d8f:15% ] { name: 't7'}
]
>
t5 start: 2021-11-28T11:57:10.168Z
t7 start: 2021-11-28T11:57:10.168Z
undefined
> t7 fail: 2021-11-28T11:57:12.341Z
Base [15 %33ad3d8f:15% ] { name: 't7'}
t7 start: 2021-11-28T11:57:12.345Z
Uncaught 0.8067136495847074
> t5 fail: 2021-11-28T11:57:12.611Z
Base [14 %33ad3d8f:14% ] { name: 't5'}
t5 start: 2021-11-28T11:57:12.614Z
Uncaught 0.9457326949590821
> t7 succ: 2021-11-28T11:57:16.558Z
Base [15 %33ad3d8f:15% ] { name: 't7'}
t5 fail: 2021-11-28T11:57:18.550Z
Base [14 %33ad3d8f:14% ] { name: 't5' }
t5 start: 2021-11-28T11:57:18.551Z
Uncaught 0.6334435325094092
> t5 fail: 2021-11-28T11:57:24.162Z
Base [14 %33ad3d8f:14% ] { name: 't5' }
t5 start: 2021-11-28T11:57:24.163Z
Uncaught 0.5462425557406225
> t5 succ: 2021-11-28T11:57:29.638Z
Base [14 %33ad3d8f:14% ] { name: 't5'}
>
> ploop.$sdfs_
[ Ploop [1 %33ad3d8f:1% ] {} ]
>
serial
const {creat_sloop} = require("nv-task-event-loop")
var [sloop,forest] = creat_sloop()
function tsk(rs,rj,self) {
console.log(self.name,"start:",new Date())
setTimeout(
() => {
let cond = (Math.random() >0.5)?true:false;
if(cond) {
console.log(self.name,"succ:",new Date())
rs(Math.random())
} else {
console.log(self.name,"fail:",new Date())
rj(Math.random())
}
},
Math.random()*10000 + 2000
)
}
sloop.append('t0',tsk)
sloop.append('t1',tsk)
sloop.append('t2',tsk)
sloop.append('t3',tsk)
> sloop.$sdfs_
[
Sloop [1 %8a478ae0:1% ] {},
Base [2 %8a478ae0:2% ] { name: 't0' },
Base [3 %8a478ae0:3% ] { name: 't1' },
Base [4 %8a478ae0:4% ] { name: 't2' },
Base [5 %8a478ae0:5% ] { name: 't3' }
]
> sloop.start()
t0 start: 2021-11-28T12:47:04.080Z
undefined
> t0 succ: 2021-11-28T12:47:10.862Z
t1 start: 2021-11-28T12:47:10.865Z
> t1 fail: 2021-11-28T12:47:14.998Z
t2 start: 2021-11-28T12:47:15.001Z
Uncaught 0.03766741199616952
> t2 succ: 2021-11-28T12:47:18.500Z
t3 start: 2021-11-28T12:47:18.501Z
> sloop.history_
[
Base [2 %134f4119:2% ] { name: 't0' },
Base [3 %134f4119:3% ] { name: 't1' },
Base [4 %134f4119:4% ] { name: 't2' }
]
> t3 fail: 2021-11-28T12:47:28.235Z
t1 start: 2021-11-28T12:47:28.237Z
Uncaught 0.7733557460726412
> sloop.t1 fail: 2021-11-28T12:47:37.725Z
t3 start: 2021-11-28T12:47:37.727Z
Uncaught 0.22587428091340156
> sloop.$sdfs_
[
Sloop [1 %134f4119:1% ] {},
Base [3 %134f4119:3% ] { name: 't1' },
Base [5 %134f4119:5% ] { name: 't3' }
]
> t3 succ: 2021-11-28T12:47:48.713Z
t1 start: 2021-11-28T12:47:48.715Z
> t1 succ: 2021-11-28T12:47:52.615Z
undefined
> sloop.$sdfs_
[ Sloop [1 %134f4119:1% ] {} ]
sloop.append('t4',tsk)
t4 start: 2021-11-28T13:02:35.788Z
> t4 fail: 2021-11-28T13:02:42.063Z
t4 start: 2021-11-28T13:02:42.064Z
Uncaught 0.967356516505113
> t4 fail: 2021-11-28T13:02:51.727Z
t4 start: 2021-11-28T13:02:51.728Z
Uncaught 0.44575593589624285
> t4 fail: 2021-11-28T13:02:59.898Z
t4 start: 2021-11-28T13:02:59.899Z
Uncaught 0.3339230914494107
> t4 succ: 2021-11-28T13:03:11.244Z
>
sloop.append('t5',tsk)
sloop.append('t6',tsk)
sloop.append('t7',tsk)
sloop.append('t8',tsk)
t5 succ: 2021-11-28T13:04:24.811Z
t6 start: 2021-11-28T13:04:24.813Z
sloop.pause()
> sloop.$sdfs_.map(r=>r.state_)
[ Symbol(paused), Symbol(paused), Symbol(init), Symbol(init) ]
>
> sloop.$sdfs_
[
Sloop [1 %d17eb72e:1% ] {},
Base [11 %d17eb72e:11% ] { name: 't6' },
Base [9 %d17eb72e:9% ] { name: 't7' },
Base [10 %d17eb72e:10% ] { name: 't8' }
]
>
> sloop.continue()
t6 start: 2021-11-28T13:06:08.702Z
undefined
> t6 fail: 2021-11-28T13:06:11.066Z
t7 start: 2021-11-28T13:06:11.068Z
Uncaught 0.28002167582813486
> t7 fail: 2021-11-28T13:06:19.158Z
t8 start: 2021-11-28T13:06:19.159Z
Uncaught 0.7690404739981405
> t8 fail: 2021-11-28T13:06:30.440Z
t6 start: 2021-11-28T13:06:30.441Z
Uncaught 0.6015427168849683
> t6 succ: 2021-11-28T13:06:39.316Z
t7 start: 2021-11-28T13:06:39.317Z
> sloop.$sdfs_
[
Sloop [1 %d17eb72e:1% ] {},
Base [9 %d17eb72e:9% ] { name: 't7' },
Base [10 %d17eb72e:10% ] { name: 't8' }
]
> t7 fail: 2021-11-28T13:06:51.253Z
t8 start: 2021-11-28T13:06:51.255Z
Uncaught 0.34902555913841415
> t8 succ: 2021-11-28T13:07:00.086Z
t7 start: 2021-11-28T13:07:00.087Z
> sloop.$sdfs_
[ Sloop [1 %d17eb72e:1% ] {}, Base [9 %d17eb72e:9% ] { name: 't7' } ]
> t7 fail: 2021-11-28T13:07:05.210Z
t7 start: 2021-11-28T13:07:05.211Z
Uncaught 0.8291153904570607
> sloop.$sdfs_t7 succ: 2021-11-28T13:07:13.078Z
[ Sloop [1 %d17eb72e:1% ] {} ]
>
sloop.append('t9',tsk)
> sloop.append('t9',tsk)
t9 start: 2021-11-28T13:07:51.439Z
undefined
> t9 fail: 2021-11-28T13:07:55.871Z
t9 start: 2021-11-28T13:07:55.872Z
Uncaught 0.4758705378679222
> t9 succ: 2021-11-28T13:08:02.955Z
>
> sloop.history_
[
Base [11 %d17eb72e:11% ] { name: 't6' },
Base [9 %d17eb72e:9% ] { name: 't7' },
Base [10 %d17eb72e:10% ] { name: 't8' },
Base [11 %d17eb72e:11% ] { name: 't6' },
Base [9 %d17eb72e:9% ] { name: 't7' },
Base [10 %d17eb72e:10% ] { name: 't8' },
Base [9 %d17eb72e:9% ] { name: 't7' },
Base [9 %d17eb72e:9% ] { name: 't7' },
Base [12 %d17eb72e:12% ] { name: 't9' },
Base [12 %d17eb72e:12% ] { name: 't9' }
]
> sloop.max_history_size_
10
APIS
- creat_ploop(forest,max_size,rtrn_forest=true)
- creat_ploop(max_history_size=10,forest,max_size,rtrn_forest=true)
LICENSE