<?php
class workerThread extends Thread {
public function __construct($i){
$this->i=$i;
}
public function run(){
while(true){
echo $this->i;
sleep(1);
}
}
}
for($i=0;$i<50;$i++){
$workers[$i]=new workerThread($i);
$workers[$i]->start();
}
?>
The Thread class
(PECL pthreads >= 2.0.0)
Introdução
When the start method of a Thread is invoked, the run method code will be executed in separate Thread, in parallel.
After the run method is executed the Thread will exit immediately, it will be joined with the creating Thread at the appropriate time.
Aviso
Relying on the engine to determine when a Thread should join may cause undesirable behaviour; the programmer should be explicit, where possible.
Resumo da classe
/* Métodos */
/* Métodos herdados */
}Índice
- Thread::getCreatorId — Identification
- Thread::getCurrentThread — Identification
- Thread::getCurrentThreadId — Identification
- Thread::getThreadId — Identification
- Thread::isJoined — State Detection
- Thread::isStarted — State Detection
- Thread::join — Synchronization
- Thread::start — Execution
add a note
User Contributed Notes 3 notes
german dot bernhardt at gmail dot com ¶
10 years ago
german dot bernhardt at gmail dot com ¶
8 years ago
<?php
# ERROR GLOBAL VARIABLES IMPORT
$tester=true;
function tester(){
global $tester;
var_dump($tester);
}
tester(); // PRINT -> bool(true)
class test extends Thread{
public function run(){
global $tester;
tester(); // PRINT -> NULL
}
}
$workers=new test();
$workers->start();
?>
312036773 at qq dot com ¶
8 years ago
<?php
class STD extends Thread{
public function put(){
$this->synchronized(function(){
for($i=0;$i<7;$i++){
printf("%d\n",$i);
$this->notify();
if($i < 6)
$this->wait();
else
exit();
sleep(1);
}
});
}
public function flush(){
$this->synchronized(function(){
for($i=0;$i<7;$i++){
flush();
$this->notify();
if($i < 6)
$this->wait();
else
exit();
}
});
}
}
class A extends Thread{
private $std;
public function __construct($std){
$this->std = $std;
}
public function run(){
$this->std->put();
}
}
class B extends Thread{
private $std;
public function __construct($std){
$this->std = $std;
}
public function run(){
$this->std->flush();
}
}
ob_end_clean();
echo str_repeat(" ", 1024);
$std = new STD();
$ta = new A($std);
$tb = new B($std);
$ta->start();
$tb->start();
