是否有一种实际的方法可以在PHP中实现多线程模型，无论是真正的还是仅对其进行仿真。 一段时间以前，建议您可以强制操作系统加载PHP可执行文件的另一个实例并处理其他同时进行的进程。
这样做的问题是，当PHP代码完成执行PHP实例后，它仍保留在内存中，因为无法从PHP中杀死它。 因此，如果您正在模拟多个线程，则可以想象会发生什么。 因此，我仍在寻找一种可以在PHP中有效完成或模拟多线程的方法。 有任何想法吗？
可以在php中进行多线程
是的，您可以使用pthreads在PHP中执行多线程
从PHP文档中：
pthreads is an object-orientated API that provides all of the tools needed for multi-threading in PHP. PHP applications can create, read, write, execute and synchronize with Threads, Workers and Threaded objects.
Warning:
The pthreads extension cannot be used in a web server environment. Threading in PHP should therefore remain to CLI-based applications only.
简单测试
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
| #!/usr/bin/php
<?php
class AsyncOperation extends Thread {
public function __construct($arg) {
$this->arg = $arg;
}
public function run() {
if ($this->arg) {
$sleep = mt_rand(1, 10);
printf('%s: %s -start -sleeps %d' ."
", date("g:i:sa"), $this->arg, $sleep);
sleep($sleep);
printf('%s: %s -finish' ."
", date("g:i:sa"), $this->arg);
}
}
}
// Create a array
$stack = array();
//Initiate Multiple Thread
foreach ( range("A","D") as $i ) {
$stack[] = new AsyncOperation($i);
}
// Start The Threads
foreach ( $stack as $t ) {
$t->start();
}
?> |
首轮
1
2
3
4
5
6
7
8
| 12:00:06pm: A -start -sleeps 5
12:00:06pm: B -start -sleeps 3
12:00:06pm: C -start -sleeps 10
12:00:06pm: D -start -sleeps 2
12:00:08pm: D -finish
12:00:09pm: B -finish
12:00:11pm: A -finish
12:00:16pm: C -finish |
第二次跑
1
2
3
4
5
6
7
8
| 12:01:36pm: A -start -sleeps 6
12:01:36pm: B -start -sleeps 1
12:01:36pm: C -start -sleeps 2
12:01:36pm: D -start -sleeps 1
12:01:37pm: B -finish
12:01:37pm: D -finish
12:01:38pm: C -finish
12:01:42pm: A -finish |
真实的例子
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
| error_reporting(E_ALL);
class AsyncWebRequest extends Thread {
public $url;
public $data;
public function __construct($url) {
$this->url = $url;
}
public function run() {
if (($url = $this->url)) {
/*
* If a large amount of data is being requested, you might want to
* fsockopen and read using usleep in between reads
*/
$this->data = file_get_contents($url);
} else
printf("Thread #%lu was not provided a URL
", $this->getThreadId());
}
}
$t = microtime(true);
$g = new AsyncWebRequest(sprintf("http://www.google.com/?q=%s", rand() * 10));
/* starting synchronization */
if ($g->start()) {
printf("Request took %f seconds to start", microtime(true) - $t);
while ( $g->isRunning() ) {
echo".";
usleep(100);
}
if ($g->join()) {
printf(" and %f seconds to finish receiving %d bytes
", microtime(true) - $t, strlen($g->data));
} else
printf(" and %f seconds to finish, request failed
", microtime(true) - $t);
} |
为什么不使用popen？
1
2
3
4
5
6
7
8
9
10
11
| for ($i=0; $i<10; $i++) {
// open ten processes
for ($j=0; $j<10; $j++) {
$pipe[$j] = popen('script2.php', 'w');
}
// wait for them to finish
for ($j=0; $j<10; ++$j) {
pclose($pipe[$j]);
}
} |
可用的PHP中没有线程，但是可以通过将HTTP请求用作异步调用来进行并发编程。
将curl的超时设置设置为1，并对要彼此关联的进程使用相同的session_id，则可以与会话变量进行通信，如下面的示例所示。使用这种方法，您甚至可以关闭浏览器，并发进程仍在服务器上。
不要忘记像这样验证正确的会话ID：
http://localhost/test/verifysession.php?sessionid=[the correct id]
startprocess.php
1
2
3
4
5
6
7
8
| $request ="http://localhost/test/process1.php?sessionid=".$_REQUEST["PHPSESSID"];
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $request);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_TIMEOUT, 1);
curl_exec($ch);
curl_close($ch);
echo $_REQUEST["PHPSESSID"]; |
process1.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
| set_time_limit(0);
if ($_REQUEST["sessionid"])
session_id($_REQUEST["sessionid"]);
function checkclose()
{
global $_SESSION;
if ($_SESSION["closesession"])
{
unset($_SESSION["closesession"]);
die();
}
}
while(!$close)
{
session_start();
$_SESSION["test"] = rand();
checkclose();
session_write_close();
sleep(5);
} |
verifysession.php
1
2
3
4
5
| if ($_REQUEST["sessionid"])
session_id($_REQUEST["sessionid"]);
session_start();
var_dump($_SESSION); |
closeprocess.php
1
2
3
4
5
6
| if ($_REQUEST["sessionid"])
session_id($_REQUEST["sessionid"]);
session_start();
$_SESSION["closesession"] = true;
var_dump($_SESSION); |
虽然您无法线程化，但您确实在php中具有一定程度的过程控制。这里有用的两个功能集是：
过程控制功能
http://www.php.net/manual/en/ref.pcntl.php
POSIX功能
http://www.php.net/manual/en/ref.posix.php
您可以使用pcntl_fork来分叉您的进程-返回子进程的PID。然后，您可以使用posix_kill丢弃该PID。
也就是说，如果您杀死了一个父进程，则应该向子进程发送一个信号，告诉它死亡。如果php本身无法识别，则可以注册一个函数来对其进行管理，并使用pcntl_signal进行干净退出。
pthreads PECL扩展使使用线程成为可能
http://www.php.net/manual/en/book.pthreads.php
我知道这是一个老问题，但是对于搜索的人来说，有一个用C编写的PECL扩展现在可以提供PHP多线程功能，它位于此处https://github.com/krakjoe/pthreads
您可以使用exec()运行命令行脚本(例如命令行php)，如果将输出通过管道传输到文件，则脚本将不会等待命令完成。
我不太记得php CLI语法，但是您想要这样的东西：
1
| exec("/path/to/php -f '/path/to/file.php' | '/path/to/output.txt'"); |
我认为出于安全原因，很多共享托管服务器默认都禁用了exec()，但值得一试。
您可以模拟线程。 PHP可以通过popen(或proc_open)运行后台进程。可以通过stdin和stdout与这些进程进行通信。当然，这些进程本身可以是php程序。那可能与您将获得的接近。
pcntl_fork呢？
请查看我们的手册页以获取示例：PHP pcntl_fork
1
2
3
4
5
6
7
8
9
10
11
12
13
| <?php
$pid = pcntl_fork();
if ($pid == -1) {
die('could not fork');
} else if ($pid) {
// we are the parent
pcntl_wait($status); //Protect against Zombie children
} else {
// we are the child
}
?> |
由于PECL pthreads≥2.0.0，因此可以使用Thread类。
我知道这已经很老了，但是您可以看看http://phpthreadlib.sourceforge.net/
它支持双向线程间通信，并且具有内置的保护功能，可以杀死子线程(防止孤立线程)。
根据您要执行的操作，您还可以使用curl_multi来实现它。
如果pcntl_fork启用了安全模式，则在Web服务器环境中将不起作用。在这种情况下，它将仅在PHP的CLI版本中起作用。
您可以选择：
multi_curl
一个可以使用系统命令
理想的情况是用C语言创建一个线程函数并用PHP进行编译/配置。现在，该功能将成为PHP的功能。
在撰写当前评论时，我对PHP线程一无所知。我来这里亲自寻找答案，但是一种解决方法是，从Web服务器接收请求的PHP程序将整个答案公式委托给控制台应用程序，该控制台应用程序将其输出，请求的答案存储到二进制文件中。并且启动控制台应用程序的PHP程序逐字节返回该二进制文件，作为对收到的请求的答复。控制台应用程序可以用服务器上运行的任何编程语言编写，包括那些具有适当线程支持的语言，包括使用OpenMP的C ++程序。
一种不可靠，肮脏的技巧是使用PHP执行控制台应用程序" uname"，
并将该控制台命令的输出打印到HTML输出中，以查找服务器软件的确切版本。然后，将完全相同版本的软件安装到VirtualBox实例，编译/组装所需的任何完全独立的(最好是静态的)二进制文件，然后将其上传到服务器。从那时起，PHP应用程序可以在具有适当多线程功能的控制台应用程序中使用那些二进制文件。当服务器管理员未将所有必需的编程语言实现安装到服务器时，这是一种肮脏，不可靠的解决方法。需要注意的是，PHP应用程序收到控制台应用程序的每个请求都会终止/退出/ get_killed。
至于托管服务管理员对这种服务器使用模式的看法，我想这可以归结为文化。在北欧，服务提供商必须提供广告，并且如果允许执行控制台命令并且允许上传非恶意软件文件，并且服务提供商有权在几分钟甚至30秒后终止任何服务器进程，那么托管服务管理员就没有理由提出适当的投诉。在美国和西欧，情况/文化大不相同，我相信在美国和/或西欧，托管服务提供商很有可能会
拒绝为使用上述技巧的托管服务客户提供服务。考虑到我在美国托管服务方面的个人经验以及我从其他人那里听说的有关西欧托管服务的信息，这只是我的猜测。截至我撰写当前评论(2018_09_01)时，我对南欧托管服务提供商，南欧网络管理员的文化规范一无所知。
可能是我错过了一些东西，但是exec在我在Windows中使用的Windows环境中对我来说不是异步的，它像魅力一样工作；)
1
2
3
| $script_exec ="c:/php/php.exe c:/path/my_ascyn_script.php";
pclose(popen("start /B". $script_exec,"r")); |
多线程意味着同时执行多个任务或进程，尽管没有直接的方法可以在php中实现多线程，但我们可以通过以下代码在php中实现，但通过以下方法可以实现几乎相同的结果。
1
2
3
4
5
6
7
8
| chdir(dirname(__FILE__)); //if you want to run this file as cron job
for ($i = 0; $i < 2; $i += 1){
exec("php test_1.php $i > test.txt &");
//this will execute test_1.php and will leave this process executing in the background and will go
//to next iteration of the loop immediately without waiting the completion of the script in the
//test_1.php , $i is passed as argument . |
}
Test_1.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
| $conn=mysql_connect($host,$user,$pass);
$db=mysql_select_db($db);
$i = $argv[1]; //this is the argument passed from index.php file
for($j = 0;$j<5000; $j ++)
{
mysql_query("insert into test set
id='$i',
comment='test',
datetime=NOW()");
} |
这将同时执行两次test_1.php，并且两个进程将同时在后台运行，因此您可以在php中实现多线程。
这个家伙在php中做得非常好
