byjg / phpthread

example_pool.php

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