X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2FmultiFunctionExample.js;h=93d4e78b3d0465b35b823fd18dc2cbc203c66e31;hb=17a9a09416d6c07f560eb0c79bd031d8c0125d4e;hp=76b6bbfbff95a347c677e81c6587d5df8c1e2da6;hpb=87a12b1289a70e4b26f2ea40ba3cbfc2ad4d97ea;p=poolifier.git diff --git a/examples/multiFunctionExample.js b/examples/multiFunctionExample.js index 76b6bbfb..93d4e78b 100644 --- a/examples/multiFunctionExample.js +++ b/examples/multiFunctionExample.js @@ -1,12 +1,16 @@ -const FixedThreadPool = require('../lib/fixed') -const pool = new FixedThreadPool(15, './multifunctionWorker.js', { +const { FixedThreadPool } = require('poolifier') +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({ functionName: 'fn0', input: 'hello' }) .then(res => console.log(res)) + .catch(err => console.error(err)) +pool + .execute({ functionName: 'fn1', input: 'multiple functions' }) + .then(res => console.log(res)) + .catch(err => console.error(err)) setTimeout(pool.destroy.bind(pool), 3000)