byjg / phpthread

example_pool.php

Indentation +25 added lines, -25 removed lines

@@ -5,48 +5,48 @@
 // 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;
-		sleep(1);
-	}
+    for ($i = 0; $i < 10; $i++)
+    {
+        echo "Hello from thread #$t, i=$i" . PHP_EOL;
+        sleep(1);
+    }
     echo "Ending thread #$t" . PHP_EOL;
 
-	return uniqid("Thread_{$t}_");
+    return uniqid("Thread_{$t}_");
 }
 
 
 try
 {
-	// Create a instance of the ThreadPool
-	$threadPool = new \ByJG\PHPThread\ThreadPool();
+    // Create a instance of the ThreadPool
+    $threadPool = new \ByJG\PHPThread\ThreadPool();
 
-	// Create the threads
+    // Create the threads
     for ($i = 0; $i < 10; $i++)
     {
-		// Queue a worker pointing to "Foo" function and pass the required parameters
+        // Queue a worker pointing to "Foo" function and pass the required parameters
         $threadPool->queueWorker('Foo', [ $i ]);
     }
 
-	// Starts all the threads in the queue
-	$threadPool->startWorkers();
+    // Starts all the threads in the queue
+    $threadPool->startWorkers();
 
-	// Wait until there is no more active workers
-	while($threadPool->activeWorkers() > 0)
-	{
-		echo "Active Workers : " . $threadPool->activeWorkers() . "\n";
-		sleep(1);
-	}
+    // Wait until there is no more active workers
+    while($threadPool->activeWorkers() > 0)
+    {
+        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";
-	}
+    // Get the return value from the thread.
+    foreach ($threadPool->getThreads() as $thid)
+    {
+        echo 'Result: ' . $threadPool->getThreadResult($thid) . "\n";
+    }
 
-	echo "\n\nEnded!\n";
+    echo "\n\nEnded!\n";
 
 }
 catch (Exception $e)

Spacing +8 added lines, -8 removed lines

@@ -5,14 +5,14 @@ 
 // 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}_");
 }
@@ -27,23 +27,23 @@ 
     for ($i = 0; $i < 10; $i++)
     {
 		// Queue a worker pointing to "Foo" function and pass the required parameters
-        $threadPool->queueWorker('Foo', [ $i ]);
+        $threadPool->queueWorker('Foo', [$i]);
     }
 
 	// Starts all the threads in the queue
 	$threadPool->startWorkers();
 
 	// Wait until there is no more active workers
-	while($threadPool->activeWorkers() > 0)
+	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";
@@ -51,6 +51,6 @@ 
 }
 catch (Exception $e)
 {
-    echo 'Exception: ' . $e . PHP_EOL;
+    echo 'Exception: '.$e.PHP_EOL;
 }
 

src/Thread.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');

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;
 }