A partir dessa pergunta, me veio a curiosidade de querer aprender mais sobre o assunto, então pesquisando mais a fundo, acabei me deparando com mais dúvida sobre o assunto. Pois vi que existe uma cadeia de formas de utilizar Threads.
Podemos ver as threads como pequenos processos. A grande diferença das threads é que elas compartilham os mesmos recursos e endereçamento de memória. Ou seja, é como se tivéssemos um processo que dividido em processos menores, onde há um chaveamento entre eles, cada um executando um pouco (como ocorre nos processos), mas agora eles compartilham os mesmos dados e recursos, e tem um mesmo objetivo, trabalham juntos. E achei curioso, já que as vezes tive que apanhar bastante para melhorar o desempenho de sistemas complexos que ainda estão muito lentos, e que precisam utilizar sub sistemas para melhorar sua performance.
Considerando o meu caso, numa implementação futura, gostaria de saber o que exatamente muda entre os três exemplos abaixo, e quando devo usar um ou outro e vise-versa:
Exemplo de Fork:
$pid = pcntl_fork();
if ($pid == -1) {
die('Erro ao lançar thread');
} else if ($pid) {
// thread principal
//aguardamos a thread child terminar
pcntl_wait($status);
echo "Processo child terminado\n";
exit(0);
} else {
//thread secundario
//mudamos para um usuário não privilegiado
posix_setuid(1000);
posix_setgid(1000);
//colocamos a thread para fazer algo,
//ate que uma condição seja satisfeita e ela termine
$i=0;
while(true){
if (file_exists('/tmp/stop')){
echo "Terminado thread";
exit(0);
}
echo "Iteração : ". ++$i . "\n";
sleep(2);
}
}
Exemplo de Thread:
// Classe que aguarda um tempo aleatorio e depois imprime algo na tela
class AguardaRand extends Thread {
// ID da thread (usado para identificar a ordem que as threads terminaram)
protected $id;
// Construtor que apenas atribui um ID para identificar a thread
public function __construct($id) {
$this->id = $id;
}
// Metodo principal da thread, que sera acionado quando chamarmos "start"
public function run() {
// Sortear um numero entre 1 e 4
$tempo_rand = mt_rand(1, 4);
// Aguardar o tempo sorteado
sleep($tempo_rand);
// Imprimir quem e' a thread e quanto tempo ela aguardou
printf(
"Sou a thread %d e aguardei %d segundos\n",
$this->id,
$tempo_rand
);
}
}
//Execucao do codigo
// Criar um vetor com 10 threads do mesmo tipo
$vetor = array();
for ($id = 0; $id < 10; $id++) {
$vetor[] = new AguardaRand($id);
}
// Iniciar a execucao das threads
foreach ($vetor as $thread) {
$thread->start();
}
// Encerrar o script
exit(0);
Exemplo de Pipe:
for ($i=0; $i<10; $i++) {
// abre 10 processos
for ($j=0; $j<10; $j++) {
$pipe[$j] = popen('script2.php', 'w');
}
// espera a finalização do processo
for ($j=0; $j<10; ++$j) {
pclose($pipe[$j]);
}
}