PHP プログラミングにおける同時実行性

<?php// build the individual requests as above, but do not execute them$ch_1 = curl_init('http://www.baidu.com/');$ch_2 = curl_init('http://www.baidu.com/');curl_setopt($ch_1, CURLOPT_RETURNTRANSFER, true);curl_setopt($ch_2, CURLOPT_RETURNTRANSFER, true);// build the multi-curl handle, adding both $ch$mh = curl_multi_init();curl_multi_add_handle($mh, $ch_1);curl_multi_add_handle($mh, $ch_2);// execute all queries simultaneously, and continue when all are complete$running = null;do {   curl_multi_exec($mh, $running);   $ch = curl_multi_select($mh);   if($ch !== 0){	   $info = curl_multi_info_read($mh);	   if($info){		   var_dump($info);		   $response_1 = curl_multi_getcontent($info['handle']);		   echo "$response_1 \n";		   break;	   }   }} while ($running > 0);//close the handlescurl_multi_remove_handle($mh, $ch_1);curl_multi_remove_handle($mh, $ch_2);curl_multi_close($mh);

<?php$client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);//设置事件回调函数$client->on("connect", function($cli) {	$req = "GET / HTTP/1.1\r\n	Host: www.baidu.com\r\n	Connection: keep-alive\r\n	Cache-Control: no-cache\r\n	Pragma: no-cache\r\n\r\n";	for ($i=0; $i < 3; $i++) {		$cli->send($req);	}});$client->on("receive", function($cli, $data){	echo "Received: ".$data."\n";	exit(0);	$cli->sleep(); // swoole >= 1.7.21});$client->on("error", function($cli){	echo "Connect failed\n";});$client->on("close", function($cli){	echo "Connection close\n";});//发起网络连接$client->connect('183.207.95.145', 80, 1);

<?php$workers = [];$worker_num = 3;//创建的进程数$finished = false;$lock = new swoole_lock(SWOOLE_MUTEX);for($i=0;$i<$worker_num ; $i++){	$process = new swoole_process('process');	//$process->useQueue();	$pid = $process->start();	$workers[$pid] = $process;}foreach($workers as $pid => $process){	//子进程也会包含此事件	swoole_event_add($process->pipe, function ($pipe) use($process, $lock, &$finished) {		$lock->lock();		if(!$finished){			$finished = true;			$data = $process->read();			echo "RECV: " . $data.PHP_EOL;		}		$lock->unlock();	});}function process(swoole_process $process){	$response = 'http response';	$process->write($response);	echo $process->pid,"\t",$process->callback .PHP_EOL;}for($i = 0; $i < $worker_num; $i++) {	$ret = swoole_process::wait();	$pid = $ret['pid'];	echo "Worker Exit, PID=".$pid.PHP_EOL;}

<?phpclass Foo extends Stackable {	public $url;	public $response = null;	public function __construct(){		$this->url = 'http://www.baidu.com';	}	public function run(){}}class Process extends Worker {	private $text = "";	public function __construct($text,$object){		$this->text = $text;		$this->object = $object;	}	public function run(){		while (is_null($this->object->response)){			print " Thread {$this->text} is running\n";			$this->object->response = 'http response';			sleep(1);		}	}}$foo = new Foo();$a = new Process("A",$foo);$a->start();$b = new Process("B",$foo);$b->start();echo $foo->response;

package mainimport (	"fmt")func main() {	var result chan string = make(chan string, 1)	for index := 0;  index< 3; index++ {		go doRequest(result)	}	res, ok := <-result	if ok {		fmt.Println("received ", res)	}}func doRequest(result chan string)  {	response := "http response"	defer func() {		if x := recover(); x != nil {			fmt.Println("Unable to send: %v", x)		}	}()	result <- response	close(result)}