byjg / phpthread

example.php

Spacing +6 added lines, -6 removed lines

@@ -4,17 +4,17 @@ 
 // Method to be executed in a thread
 function Foo($t)
 {
-    echo "Starting thread #$t" . PHP_EOL;
+    echo "Starting thread #$t".PHP_EOL;
     
     sleep(1 * rand(1, 5));
     for ($i = 0; $i < 10; $i++) {
-        echo "Hello from thread #$t, i=$i" . PHP_EOL;
+        echo "Hello from thread #$t, i=$i".PHP_EOL;
         sleep(1);
     }
-    echo "Ending thread #$t" . PHP_EOL;
+    echo "Ending thread #$t".PHP_EOL;
 
     // Note: this line below require the file "config/cacheconfig.php" exists
-    return "$t: [[[[[[" . time() . "]]]]]]";
+    return "$t: [[[[[[".time()."]]]]]]";
 }
 
 try {
@@ -51,9 +51,9 @@ 
 
     // Note: this line below require the file "config/cacheconfig.php" exists
     foreach ($t as $thread) {
-        echo "Result: " . $thread->getResult() . "\n";
+        echo "Result: ".$thread->getResult()."\n";
     }
     
 } catch (Exception $e) {
-    echo 'Exception: ' . $e . PHP_EOL;
+    echo 'Exception: '.$e.PHP_EOL;
 }

src/Handler/ForkHandler.php

Spacing +1 added lines, -1 removed lines

@@ -73,7 +73,7 @@
      */
     public function start()
     {
-        $this->_threadKey = 'thread_' . rand(1000, 9999) . rand(1000, 9999) . rand(1000, 9999) . rand(1000, 9999);
+        $this->_threadKey = 'thread_'.rand(1000, 9999).rand(1000, 9999).rand(1000, 9999).rand(1000, 9999);
 
         if (($this->_pid = pcntl_fork()) == -1) {
             throw new RuntimeException('Couldn\'t fork the process');

src/Handler/PThreadHandler.php

Spacing +3 added lines, -3 removed lines

@@ -39,9 +39,9 @@ 
             return $this->loader;
         }
 
-        $path = __DIR__ . '/../../vendor/autoload.php';
+        $path = __DIR__.'/../../vendor/autoload.php';
         if (!file_exists($path)) {
-            $path = __DIR__ . '/../../../../autoload.php';
+            $path = __DIR__.'/../../../../autoload.php';
             if (!file_exists($path)) {
                 throw new \RuntimeException("Autoload path '$path' not found");
             }
@@ -87,7 +87,7 @@ 
      */
     public function getResult()
     {
-        if ($this->hasError && ( $this->hasError['type'] == E_ERROR || $this->hasError['type'] == E_USER_ERROR )) {
+        if ($this->hasError && ($this->hasError['type'] == E_ERROR || $this->hasError['type'] == E_USER_ERROR)) {
             throw new \RuntimeException(
                 sprintf(
                     'Thread error: "%s", in "%s" at line %d. <<--- ',

example_pool.php

Spacing +6 added lines, -6 removed lines

@@ -5,13 +5,13 @@ 
 // Method to be executed in a thread
 function Foo($t)
 {
-    echo "Starting thread #$t" . PHP_EOL;;
+    echo "Starting thread #$t".PHP_EOL; ;
     sleep(1 * rand(1, 5));
     for ($i = 0; $i < 10; $i++) {
-        echo "Hello from thread #$t, i=$i" . PHP_EOL;
+        echo "Hello from thread #$t, i=$i".PHP_EOL;
         sleep(1);
     }
-    echo "Ending thread #$t" . PHP_EOL;
+    echo "Ending thread #$t".PHP_EOL;
 
     return uniqid("Thread_{$t}_");
 }
@@ -33,18 +33,18 @@ 
     // Wait until there is no more active workers
     // You can use $threadPool->waitWorkers() instead the loop below
     while ($threadPool->activeWorkers() > 0) {
-        echo "Active Workers : " . $threadPool->activeWorkers() . "\n";
+        echo "Active Workers : ".$threadPool->activeWorkers()."\n";
         sleep(1);
     }
 
     // Get the return value from the thread.
     foreach ($threadPool->getThreads() as $thid) {
-        echo 'Result: ' . $threadPool->getThreadResult($thid) . "\n";
+        echo 'Result: '.$threadPool->getThreadResult($thid)."\n";
     }
 
     echo "\n\nEnded!\n";
 
 } catch (Exception $e) {
-    echo 'Exception: ' . $e . PHP_EOL;
+    echo 'Exception: '.$e.PHP_EOL;
 }