From c7c22e3db1c826bcfb2bc66651ec480aae0d4ae0 Mon Sep 17 00:00:00 2001 From: yo mama Date: Sat, 4 Apr 2015 01:00:59 -0700 Subject: first --- node_modules/webworker-threads/examples/demo.js | 31 +++++++++++++++++++++++++ 1 file changed, 31 insertions(+) create mode 100644 node_modules/webworker-threads/examples/demo.js (limited to 'node_modules/webworker-threads/examples/demo.js') diff --git a/node_modules/webworker-threads/examples/demo.js b/node_modules/webworker-threads/examples/demo.js new file mode 100644 index 0000000..63316ae --- /dev/null +++ b/node_modules/webworker-threads/examples/demo.js @@ -0,0 +1,31 @@ +var http= require('http'); + +function fibo (n) { + return n > 1 ? fibo(n - 1) + fibo(n - 2) : 1; +} + +function fast (req,res) { + process.stdout.write('·'); + res.end("FAST"); +} + +function slow (req,res) { + process.stdout.write('•'); + res.end("SLOW -> "+ fibo(40)); +} + +var numThreads= parseInt(process.argv[2], 10) || 5; +console.log("Using "+ numThreads+ " threads."); +var Worker= require('webworker-threads'); +var threadPool= Worker.createPool(numThreads).all.eval(fibo); + +function tagg (req,res) { + threadPool.any.eval('fibo(40)', function (err, data) { + process.stdout.write('❚'); + res.end("TAGG -> "+ data); //Threads A GoGo + }); +} + +http.createServer(fast).listen(12345), console.log("fast @ localhost:12345"); +http.createServer(slow).listen(12346), console.log("slow @ localhost:12346"); +http.createServer(tagg).listen(12347), console.log("useThreads @ localhost:12347"); -- cgit v1.2.3-70-g09d2