69 lines
1.2 KiB
PHP
69 lines
1.2 KiB
PHP
<?php /*
|
|
|
|
Advanced usage
|
|
|
|
*/
|
|
|
|
require_once("ThreadQueue.php");
|
|
|
|
|
|
|
|
|
|
// function is a static method of a class
|
|
|
|
abstract class class1 {
|
|
|
|
static 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";
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// we want 3 jobs in parallel instead of the default 2
|
|
$TQ = new ThreadQueue("class1::parallel_task", 3);
|
|
|
|
|
|
// add tasks
|
|
$TQ->add("one");
|
|
$TQ->add("two");
|
|
$TQ->add("three");
|
|
$TQ->add("four");
|
|
$TQ->add("five");
|
|
$TQ->add("six");
|
|
|
|
// Oops! We changed our mind, let's remove awaiting jobs.
|
|
// Existing threads will run, but jobs not started will be removed.
|
|
$TQ->flush();
|
|
|
|
|
|
// let's add jobs again.
|
|
$TQ->add("seven");
|
|
$TQ->add("eight");
|
|
$TQ->add("nine");
|
|
$TQ->add("ten");
|
|
$TQ->add("eleven");
|
|
$TQ->add("twelve");
|
|
|
|
|
|
|
|
|
|
// wait until all threads exit
|
|
|
|
while( $numberOfThreads = count($TQ->threads()) ){
|
|
usleep(500000); // optional
|
|
|
|
echo "waiting for all ($numberOfThreads) jobs done...\n";
|
|
$TQ->tick(); // mandatory!
|
|
|
|
// ha-ha! we can change the number of parallel executions realtime.
|
|
$TQ->queueSize = 4;
|
|
|
|
}
|
|
|
|
echo "all process finished.\n";
|
|
|