repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
refactor: refine worker interface definition
[poolifier.git]
/
examples
/
multiFunctionExample.js
diff --git
a/examples/multiFunctionExample.js
b/examples/multiFunctionExample.js
index 0c4b749e6bbdabc5d542de614e47706a22ab7f09..055f143fdafae8ee1eb82e65f161d0f69f6b2e4e 100644
(file)
--- a/
examples/multiFunctionExample.js
+++ b/
examples/multiFunctionExample.js
@@
-1,16
+1,16
@@
const { FixedThreadPool } = require('poolifier')
const { FixedThreadPool } = require('poolifier')
-const pool = new FixedThreadPool(15, './multi
f
unctionWorker.js', {
+const pool = new FixedThreadPool(15, './multi
F
unctionWorker.js', {
errorHandler: e => console.error(e),
errorHandler: e => console.error(e),
- onlineHandler: () => console.
log
('worker is online')
+ onlineHandler: () => console.
info
('worker is online')
})
pool
})
pool
- .execute({
fname: 'fn0', input: 'hello' }
)
- .then(res => console.
log
(res))
+ .execute({
text: 'hello' }, 'fn0'
)
+ .then(res => console.
info
(res))
.catch(err => console.error(err))
pool
.catch(err => console.error(err))
pool
- .execute({
fname: 'fn1', input: 'multifunction' }
)
- .then(res => console.
log
(res))
+ .execute({
text: 'multiple functions' }, 'fn1'
)
+ .then(res => console.
info
(res))
.catch(err => console.error(err))
.catch(err => console.error(err))
-setTimeout(pool.destroy
.bind(pool
), 3000)
+setTimeout(pool.destroy
(
), 3000)