krakjoe · December 17, 2015 07:59 · May 14, 2013 · May 14, 2013 · May 14, 2013 · May 14, 2013
diff --git a/leak.php b/leak.php
@@ -1,9 +1,4 @@
 <?php
-
-class Jobs extends \Stackable {
-    function run() {}
-}
-
 class Job extends \Stackable {
     function run() {
         $this->isComplete = TRUE;
@@ -14,26 +9,75 @@ class MyWorker extends \Worker {
     function run() {}
 }
 
-$jobs = [];
-$worker = new MyWorker($jobs);
-$worker->start();
-
-for ($i=0;;) {
-    $worker->stack($jobs[] = new Job);
-
-    if (!(++$i%500)) {
-        $mem = memory_get_usage();
-        $stacked = $worker->getStacked();
-
-        echo str_pad($i, 9), "mem usage: $mem | stack size: $stacked\n";
-
-        // Manual garbage collection doesn't help; it only makes the code really slow without mitigating memory growth.
-        if (!($i%500)) foreach ($jobs as $id => $job) {
+/*
+* Container for workers and jobs
+*/
+class MyPool {
+    public $workers = [];
+    public $jobs = [];
+
+    /*
+    * Preinitialize Worker Threads
+    */
+    public function __construct($max, $inherit = PTHREADS_INHERIT_NONE) {
+        if ($max) {
+            /* create threads */
+            for ($start = 0; $start < $max; $start++) {
+                $this->workers[
+                    $start] = new MyWorker();
+                $this->workers[
+                    $start]->start($inherit);
+            }
+        }
+    }
+
+    /* submit to random worker */   
+    public function submit(Job $job){
+        if (count($this->workers)) {
+           $this->workers[
+             array_rand($this->workers)]->stack(
+                $this->jobs[]=$job);  
+
+        } else $this->workers[0]->stack(
+            $this->jobs[]=$job);
+    }
+
+    /* clean pool */
+    public function clean() {
+        foreach ($this->jobs as $id => $job) {
             if (is_object($job) && 
                 $job->isComplete) {
                 unset(
-                    $jobs[$id]);
+                    $this->jobs[$id]);
             }
         }
     }
+}
+
+/* normal array */
+$start = microtime(true);
+
+/* create wrapper round multiple workers */
+/* @NOTE see what happens when you raise amount of available workers ... */
+$pool = new MyPool(1);
+
+printf(
+    "JOB\tMem\tReal\tTime\tJPS\n");
+$last = [];
+
+for ($i=0;;) {
+    $pool->submit(new Job());
+
+    if (($i++%5000)==0) {
+
+        echo vsprintf("%d\t%d\t%d\t%.4f\t%d\n", $last=array(
+            "job" => $i,
+            "mem" => memory_get_usage(),
+            "real" => memory_get_usage(true),
+            "runtime" => $runtime = (microtime(true) - $start),
+            "jps" => ceil($i / $runtime)
+        ));
+
+        $pool->clean();
+    }   
 }
diff --git a/leak.php b/leak.php
@@ -28,7 +28,7 @@ function run() {}
         echo str_pad($i, 9), "mem usage: $mem | stack size: $stacked\n";
 
         // Manual garbage collection doesn't help; it only makes the code really slow without mitigating memory growth.
-        foreach ($jobs as $id => $job) {
+        if (!($i%500)) foreach ($jobs as $id => $job) {
             if (is_object($job) && 
                 $job->isComplete) {
                 unset(

diff --git a/leak.php b/leak.php
@@ -1,5 +1,5 @@
 <?php
-
+ 
 class Jobs extends \Stackable {
     function run() {}
 }
@@ -9,27 +9,30 @@ function run() {
         $this->isComplete = TRUE;
     }
 }
-
+ 
 class MyWorker extends \Worker {
     function run() {}
 }
 
-$jobs = new Jobs;
-$worker = new MyWorker;
+$jobs = [];
+$worker = new MyWorker($jobs);
 $worker->start();
 
 for ($i=0;;) {
-    $worker->stack($jobs[$i] = new Job);
-    $stacked = $worker->getStacked();
-
+    $worker->stack($jobs[] = new Job);
+
     if (!(++$i%500)) {
         $mem = memory_get_usage();
+        $stacked = $worker->getStacked();
+
         echo str_pad($i, 9), "mem usage: $mem | stack size: $stacked\n";
 
         // Manual garbage collection doesn't help; it only makes the code really slow without mitigating memory growth.
-        foreach ((array)$jobs as $id => $job) {
-            if ($job->isComplete) {
-                unset($jobs[$id]);
+        foreach ($jobs as $id => $job) {
+            if (is_object($job) && 
+                $job->isComplete) {
+                unset(
+                    $jobs[$id]);
             }
         }
     }

diff --git a/leak.php b/leak.php
@@ -27,7 +27,7 @@ function run() {}
         echo str_pad($i, 9), "mem usage: $mem | stack size: $stacked\n";
 
         // Manual garbage collection doesn't help; it only makes the code really slow without mitigating memory growth.
-        foreach ($jobs as $id => $job) {
+        foreach ((array)$jobs as $id => $job) {
             if ($job->isComplete) {
                 unset($jobs[$id]);
             }

diff --git a/leak.php b/leak.php
@@ -15,7 +15,7 @@ function run() {}
 }
 
 $jobs = new Jobs;
-$worker = new MyWorker($jobs);
+$worker = new MyWorker;
 $worker->start();
 
 for ($i=0;;) {

diff --git a/leak.php b/leak.php
@@ -0,0 +1,36 @@
+<?php
+
+class Jobs extends \Stackable {
+    function run() {}
+}
+
+class Job extends \Stackable {
+    function run() {
+        $this->isComplete = TRUE;
+    }
+}
+
+class MyWorker extends \Worker {
+    function run() {}
+}
+
+$jobs = new Jobs;
+$worker = new MyWorker($jobs);
+$worker->start();
+
+for ($i=0;;) {
+    $worker->stack($jobs[$i] = new Job);
+    $stacked = $worker->getStacked();
+
+    if (!(++$i%500)) {
+        $mem = memory_get_usage();
+        echo str_pad($i, 9), "mem usage: $mem | stack size: $stacked\n";
+
+        // Manual garbage collection doesn't help; it only makes the code really slow without mitigating memory growth.
+        foreach ($jobs as $id => $job) {
+            if ($job->isComplete) {
+                unset($jobs[$id]);
+            }
+        }
+    }
+}