++puts() tests

xk · Mar 23, 2012 · 92c8526 · 92c8526
1 parent b525538
commit 92c8526
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 3 deletions.
diff --git a/test/test27_puts_event_loop.js b/test/test27_puts_event_loop.js
@@ -8,7 +8,7 @@ pool.on('again', function onAgain () {
 
 function ƒ () {
   puts(" ["+ thread.id+ "]"+ (++i));
-  thread.emit('again', 0);
+  thread.emit('again');
 }
 
 pool.all.eval(ƒ).all.eval('i=0').all.eval('ƒ()');
diff --git a/test/test28_puts_nextTick_loop.js b/test/test28_puts_nextTick_loop.js
@@ -4,10 +4,11 @@ console.log("Using "+ i+ " threads.");
 
 function program () {
   var i= 0;
-  (function ƒ () {
+  function ƒ () {
     puts(" ["+ thread.id+ "]"+ (++i));
     thread.nextTick(ƒ);
-  })();
+  }
+  ƒ();
 }
 
 pool.all.eval(program).all.eval('program()');
diff --git a/test/test29_puts_callback_loop.js b/test/test29_puts_callback_loop.js
@@ -0,0 +1,14 @@
+var i= parseInt(process.argv[2], 10) || 2;
+var pool= require('threads_a_gogo').createPool(i);
+console.log("Using "+ i+ " threads.");
+
+function ƒ () {
+  puts(" ["+ thread.id+ "]"+ (++i));
+  //if (!(i%1e3)) gc();
+}
+
+function callback (err, data) {
+  this.eval('ƒ()', callback);
+}
+
+pool.all.eval('i=0').all.eval(ƒ).all.eval('ƒ()', callback);