50 lines
856 B
PHP
50 lines
856 B
PHP
<?php /*
|
|
|
|
Basic usage
|
|
|
|
for beginners: it is for command-line only execution. Webservers do not support threads.
|
|
|
|
*/
|
|
|
|
require_once("ThreadQueue.php");
|
|
|
|
|
|
|
|
|
|
// it is the function that will be called several times
|
|
|
|
function parallel_task($arg){
|
|
echo "task with parameter '$arg' starts\n";
|
|
sleep( rand(2,5) ); // wait for random seconds
|
|
echo "task with parameter '$arg' ENDS\n";
|
|
}
|
|
|
|
|
|
|
|
// create a queue instance with a callable function name
|
|
$TQ = new ThreadQueue("parallel_task");
|
|
|
|
|
|
// add tasks
|
|
$TQ->add("one");
|
|
$TQ->add("two");
|
|
$TQ->add("three");
|
|
$TQ->add("four");
|
|
$TQ->add("five");
|
|
|
|
|
|
|
|
|
|
// wait until all threads exit
|
|
|
|
while( count( $TQ->threads() ) ){ // there are existing processes in the background?
|
|
sleep(1); // optional
|
|
|
|
echo "waiting for all jobs done...\n";
|
|
$TQ->tick(); // mandatory!
|
|
|
|
}
|
|
|
|
echo "all process finished.\n";
|
|
|