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 +3 added lines, -3 removed lines

@@ -5,7 +5,7 @@ 
 // 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++)
 	{
@@ -27,14 +27,14 @@ 
     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";
 		sleep(1);

Braces +1 added lines, -2 removed lines

@@ -48,8 +48,7 @@
 
 	echo "\n\nEnded!\n";
 
-}
-catch (Exception $e)
+} catch (Exception $e)
 {
     echo 'Exception: ' . $e . PHP_EOL;
 }