欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  php教程

非常实用的PHP 多线程,线程池例子

程序员文章站 2022-04-05 15:26:10
...
<?php
/*
 * Homepage http://netkiller.github.io
 * Author: netkiller*/
class ExampleWorker extends Worker {

	public function __construct(Logging $logger) {
		$this->logger = $logger;
	}

	protected $logger;	
}

/* the collectable class implements machinery for Pool::collect */
class Work extends Stackable {
	public function __construct($number) {
		$this->number = $number;
	}
	public function run() {
		$this->worker
			->logger
			->log("%s executing in Thread #%lu",
				  __CLASS__, $this->worker->getThreadId());
		sleep(1);
		printf("runtime: %s, %d\n", date('Y-m-d H:i:s'), $this->number);
		$this->status = "OK";
	}
}

class Logging extends Stackable {

	protected function log($message, $args = []) {
		$args = func_get_args();	

		if (($message = array_shift($args))) {
			echo vsprintf("{$message}\n", $args);
		}
	}
}

$pool = new Pool(5, \ExampleWorker::class, [new Logging()]);

foreach (range(0, 100) as $number) {
	$pool->submit(new Work($number));
}


$pool->shutdown();

var_dump($pool);
?>