byjg / phpthread

example.php

Spacing +6 added lines, -6 removed lines

@@ -6,17 +6,17 @@ 
 // Method to be executed in a thread
     public function bar($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()."]]]]]]";
     }
 }
 
@@ -47,9 +47,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;
 }

example_pool.php

Spacing +6 added lines, -6 removed lines

@@ -7,13 +7,13 @@ 
 // Method to be executed in a thread
     public function bar($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}_");
     }
@@ -38,18 +38,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;
 }
 

src/Thread.php

Spacing +1 added lines, -1 removed lines

@@ -50,7 +50,7 @@
             $this->threadInstance = new ForkHandler();
         } else {
             throw new RuntimeException(
-                'PHP need to be compiled with ZTS extension or compiled with the --enable-pcntl. ' .
+                'PHP need to be compiled with ZTS extension or compiled with the --enable-pcntl. '.
                 'Windows is not supported.'
             );
         }

src/Handler/ForkHandler.php

Indentation +1 added lines, -1 removed lines

@@ -123,7 +123,7 @@
         $cache->release($key);
 
         if (is_object($result) && (is_subclass_of($result, '\\Error') || is_subclass_of($result, '\\Exception'))) {
-             throw $result;
+                throw $result;
         }
 
         return $result;

Spacing +2 added lines, -2 removed lines

@@ -54,7 +54,7 @@ 
      */
     public function execute()
     {
-        $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');
@@ -74,7 +74,7 @@ 
             }
 
             try {
-                $return = call_user_func_array($callable, (array)$args);
+                $return = call_user_func_array($callable, (array) $args);
 
                 if (!is_null($return)) {
                     $this->saveResult($return);

src/Handler/PThreadHandler.php

Spacing +3 added lines, -3 removed lines

@@ -37,9 +37,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");
             }
@@ -62,7 +62,7 @@ 
         }
 
         try {
-            $this->result = call_user_func_array($callable, (array)$this->args);
+            $this->result = call_user_func_array($callable, (array) $this->args);
         // Executed only in PHP 7, will not match in PHP 5.x
         } catch (\Throwable $ex) {
             $this->result = $ex;