X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2FmultiFunctionExample.js;h=213736ea037899024da9e9aab20213ebf518de40;hb=8f4878b72252b92146ae968357450df53cfa8fa7;hp=d1314aa94149fe7324fda3df0b91e240f9865532;hpb=60fbd6d6188b0902d157fd0cde04d6af3a391e32;p=poolifier.git diff --git a/examples/multiFunctionExample.js b/examples/multiFunctionExample.js index d1314aa9..213736ea 100644 --- a/examples/multiFunctionExample.js +++ b/examples/multiFunctionExample.js @@ -1,12 +1,16 @@ const { FixedThreadPool } = require('poolifier') -const pool = new FixedThreadPool(15, './multifunctionWorker.js', { +const pool = new FixedThreadPool(15, './multiFunctionWorker.js', { errorHandler: e => console.error(e), onlineHandler: () => console.log('worker is online') }) -pool.execute({ fname: 'fn0', input: 'hello' }).then(res => console.log(res)) pool - .execute({ fname: 'fn1', input: 'multifunction' }) + .execute({ text: 'hello' }, 'fn0') .then(res => console.log(res)) + .catch(err => console.error(err)) +pool + .execute({ text: 'multiple functions' }, 'fn1') + .then(res => console.log(res)) + .catch(err => console.error(err)) -setTimeout(pool.destroy.bind(pool), 3000) +setTimeout(pool.destroy(), 3000)