PHP
Extensión de roscado múltiple
Buscar..
Observaciones
Con
pthreads
v3pthreads
solo se puede cargar cuando se usa elcli
SAPI, por lo que es una buena práctica mantener la directivaextension=pthreads.so
enphp-cli.ini
SOLAMENTE, si está utilizando PHP7 y Pthreads v3.
Si está utilizando Wamp en Windows , debe configurar la extensión en php.ini :
Abre php \ php.ini y agrega:
extension=php_pthreads.dll
Con respecto a los usuarios de Linux , debe reemplazar .dll
por .so
:
extension=pthreads.so
Puede ejecutar este comando directamente para agregarlo a php.ini
(cambie /etc/php.ini
con su ruta personalizada)
echo "extension=pthreads.so" >> /etc/php.ini
Empezando
Para comenzar con subprocesos múltiples, necesitaría el pthreads-ext
para php, que puede ser instalado por
$ pecl install pthreads
y añadiendo la entrada a php.ini
.
Un ejemplo simple:
<?php
// NOTE: Code uses PHP7 semantics.
class MyThread extends Thread {
/**
* @var string
* Variable to contain the message to be displayed.
*/
private $message;
public function __construct(string $message) {
// Set the message value for this particular instance.
$this->message = $message;
}
// The operations performed in this function is executed in the other thread.
public function run() {
echo $this->message;
}
}
// Instantiate MyThread
$myThread = new MyThread("Hello from an another thread!");
// Start the thread. Also it is always a good practice to join the thread explicitly.
// Thread::start() is used to initiate the thread,
$myThread->start();
// and Thread::join() causes the context to wait for the thread to finish executing
$myThread->join();
Uso de piscinas y trabajadores
La agrupación proporciona una abstracción de mayor nivel de la funcionalidad de Worker, incluida la gestión de referencias en la forma requerida por pthreads. De: http://php.net/manual/en/class.pool.php
Los grupos y los trabajadores proporcionan un mayor nivel de control y facilidad de creación de subprocesos múltiples
<?php
// This is the *Work* which would be ran by the worker.
// The work which you'd want to do in your worker.
// This class needs to extend the \Threaded or \Collectable or \Thread class.
class AwesomeWork extends Thread {
private $workName;
/**
* @param string $workName
* The work name wich would be given to every work.
*/
public function __construct(string $workName) {
// The block of code in the constructor of your work,
// would be executed when a work is submitted to your pool.
$this->workName = $workName;
printf("A new work was submitted with the name: %s\n", $workName);
}
public function run() {
// This block of code in, the method, run
// would be called by your worker.
// All the code in this method will be executed in another thread.
$workName = $this->workName;
printf("Work named %s starting...\n", $workName);
printf("New random number: %d\n", mt_rand());
}
}
// Create an empty worker for the sake of simplicity.
class AwesomeWorker extends Worker {
public function run() {
// You can put some code in here, which would be executed
// before the Work's are started (the block of code in the `run` method of your Work)
// by the Worker.
/* ... */
}
}
// Create a new Pool Instance.
// The ctor of \Pool accepts two parameters.
// First: The maximum number of workers your pool can create.
// Second: The name of worker class.
$pool = new \Pool(1, \AwesomeWorker::class);
// You need to submit your jobs, rather the instance of
// the objects (works) which extends the \Threaded class.
$pool->submit(new \AwesomeWork("DeadlyWork"));
$pool->submit(new \AwesomeWork("FatalWork"));
// We need to explicitly shutdown the pool, otherwise,
// unexpected things may happen.
// See: http://stackoverflow.com/a/23600861/23602185
$pool->shutdown();