So verwenden Sie pcntl und libevent in PHP, um die Timer-Funktion zu implementieren

Die Timer-Funktion ist in PHP implementiert und in der Mitte wird PHP-Multithreading verwendet. Dieser Artikel enthält eine Erklärung von pcntl.

PHP verwendet pcntl und libevent, um die Timer-Funktion zu implementieren. Schauen wir uns zunächst das Beispiel pcntl (PHP-Thread) an, das unten erläutert wird.

<?php  
function newChild($func_name) {  
    echo "enter newChild\n";  
    $args = func_get_args();  
    unset($args[0]);  
    $pid =  pcntl_fork();  
    if ($pid == 0) {  
        function_exists($func_name) and exit(call_user_func_array($func_name, $args)) or exit(-1);  
    } else if($pid == -1) {  
        echo "Couldn&#39;t create child process";  
    } else {  
        return $pid;  
    }  
}  
（PS：^_^不错的php开发交流群：256271784，验证：csl，有兴趣的话可以加入进来一起讨论）
function on_timer() {  
    echo "timer called\n";  
}  
   
/** 
 * @param $func string, function name 
 * @param $timeouts int, microtimes for time delay 
 */ 
function timer($func, $timeouts){  
   
    echo "enter timer\n";  
    $base = event_base_new();  
    $event = event_new();  
   
    event_set($event, 0, EV_TIMEOUT, $func);  
    event_base_set($event, $base);  
    event_add($event, $timeouts);  
   
    event_base_loop($base);  
}  
   
$pid = newChild("timer", "on_timer", 5000000);  
   
if ($pid > 0) {  
    echo "master process exit\n";  
}

PHP erweitert pcntl um „Multi-Threading“ (Prozess) zu implementieren
pcntl und Ticks
Ticks werden durch die Syntax „declare(ticks = n) {statement}“ definiert. Die Declare-Syntax kann derzeit nur Ticks akzeptieren. Er definiert Die Bedeutung von ticks = n besteht darin, dass ein Ereignis auftritt, wenn N Low-Level-Anweisungen in dem durch „declare“ angegebenen Anweisungsblock ausgeführt werden. Dieses Ereignis kann über register_tick_function($function_name) registriert werden.
Der Signalmechanismus von pcntl ist Wird basierend auf dem Ticks-Mechanismus implementiert. Wenn wir signalbezogene Funktionen in der pcntl-Funktionsfamilie verwenden, müssen wir die Syntaxstruktur „declare(ticks = n)“ voranstellen.
int pcntl_alarm(int $seconds) :
Nach $seconds Sekunden SIGALRM-Signal eine Nachricht an den Prozess senden, jeder Aufruf der pcntl_alarm-Methode bricht die zuvor eingestellte Uhr ab.
void pcntl_exec(string $path[, array $args[, array $env] ]):
Führen Sie ein Programm im aktuellen Prozessraum aus.
$path: Muss eine binäre ausführbare Datei oder ein Skriptdateipfad mit gültigen Skript-Header-Informationen sein (#!/usr/local/bin/php) .
$args: String-Argumente, die an die Programmliste übergeben werden sollen (Array-Form)
$envs: Umgebungsvariablen, die in Array-Form ausgeführt werden sollen (Schlüssel => Wert).
int pcntl_for k (void):
Erstellen Sie einen untergeordneten Prozess. Der untergeordnete Prozess unterscheidet sich vom übergeordneten Prozess nur in der PID (Prozessnummer) und der PPID (übergeordnete Prozessnummer).
Gibt den erstellten untergeordneten Prozess zurück pid, wenn der übergeordnete Thread ausgeführt wird, und 0 zurückgibt, wenn der untergeordnete Thread ausgeführt wird, wodurch ein untergeordneter Prozess erstellt wird. Wenn dies fehlschlägt, wird -1 im Kontext des übergeordneten Prozesses zurückgegeben und ein PHP-Fehler ausgelöst Um den Fork hier zu verstehen, müssen Sie wissen: pcntl_fork erstellt einen Verzweigungsknoten, der einer Markierung entspricht. Nach Abschluss des übergeordneten Prozesses beginnt der untergeordnete Prozess mit der Ausführung, was bedeutet, dass der Code nach pcntl_fork erfolgt Wird vom übergeordneten Prozess bzw. vom untergeordneten Prozess zweimal ausgeführt und die von den beiden Prozessen während der Ausführung erhaltenen Rückgabewerte sind unterschiedlich. Daher können der übergeordnete und der untergeordnete Prozess getrennt werden, um unterschiedliche Codes auszuführen.
int pcntl_getpriority([. int $pid = getmypid()[, int $process_identifier = PRIO_PROCESS]]):
Rufen Sie die Priorität des Prozesses ab, der der angegebenen $pid entspricht. Der Standardwert ist der durch getmypid() erhaltene Wert Prozess.
$pid: Wenn nicht angegeben, ist der Standardwert der aktuelle Prozess
$process_identifier: Einer der drei PRIO_PGRP, PRIO_USER, PRIO_PROCESS, der Standardwert ist PRIO_PROCESS die Prozessgruppe, und PRIO_USER bezieht sich auf die Priorität des Benutzerprozesses.
Gibt die Priorität des Prozesses zurück oder gibt false zurück, wenn ein Fehler auftritt. desto höher die Priorität.
bool pcntl_setpriority(int $priority[, int $pid = getmypid()[, int $process_identifier = PRIO_PROCESS]]:
Legt die Priorität des Prozesses fest.
$priority: Priorität Wert, im Bereich von -20 bis 20, ist die Standardpriorität 0. Wert Je kleiner der Wert, desto höher die Priorität
$pid: Wenn nicht angegeben, bezieht es sich auf den aktuellen Prozess : Die Bedeutung ist die gleiche wie bei pcntl_getpriority.
Gibt TRUE zurück, wenn die Einstellung erfolgreich ist, und FALSE, wenn sie fehlschlägt.
bool pcntl_signal_dispatch( void):
Rufen Sie den Handler des bevorstehenden Signals auf, das über pcntl_signal installiert wurde ().
Der Aufruf gibt TRUE zurück, wenn er erfolgreich ist, false, wenn er fehlschlägt.
php 5.3.3 Hinzugefügt
bool pcntl_signal(int $signo , callback $handler[, bool $restart_syscalls = true]):
Installieren Sie einen neuen Signalhandler $handler für das angegebene Signal $signo.
Der letzte Parameter versteht die Bedeutung nicht.
bool pcntl_sigprocmask(int $how, array $set[, array &$oldset]):
Sperrsignal hinzufügen, löschen oder festlegen, das spezifische Verhalten hängt vom Parameter $how ab
$how: SIG_BLOCK wird verwendet, um das Signal zum aktuellen Sperrsignal hinzuzufügen. Unter anderem wird SIG_UNBLOCK verwendet, um das Signal aus dem zu entfernen aktuelles Sperrsignal, und SIG_SETMASK wird verwendet, um das aktuelle Sperrsignal durch die angegebene Signalliste zu ersetzen.
$set: Die Liste der Signale, die hinzugefügt, entfernt oder gesetzt werden sollen.
$ oldset: wird verwendet, um die alte Sperre zurückzugeben Signal an den Anrufer.
Gibt TRUE bei Erfolg zurück, FALSE bei Fehler
int pcntl_sigtimedwait(array $set[, array &$siginfo[, int $seconds = 0]]]) :
pcntl_sigtimedwait macht eigentlich das Gleiche wie pcntl_sigwaitinfo(), aber pcntl_sigtimedwait verfügt über zwei weitere erweiterte Parameter $seconds und $nanoseconds, die es dem Skript ermöglichen, eine Verweilzeit von Upper limit anstelle einer unbegrenzten Wartezeit festzulegen : Liste der Signale, auf die gewartet werden muss
$siginfo: Wird verwendet, um dem Anrufer Informationen über das zu wartende Signal zurückzugeben. Informationen zum Inhalt finden Sie unter pcntl_sigwaitinfo
$seconds: Sekunden für die Timeout-Nummer
$nanoseconds: Anzahl der Nanosekunden für Timeout
Nach Erfolg gibt pcntl_sigtimedwiat() die Signalnummer zurück
int pcntl_sigwaitinfo(array $set[, array &$siginfo]):
Hängt das aktuelle Skript an und führt es aus, bis ein Signal ertönt in $set wird empfangen. Wenn eines der Signale empfangen wird (z. B. durch pcntl_sigprocmask gesperrt), wird pcntl_sigwaitinfo sofort zurückgegeben.
$set: Wartesignalliste
$siginfo: verwendet. Kehrt zu den Anruferinformationen zurück über das darauf wartende Signal, zu der folgende Informationen gehören:
1. Alle Signale haben die folgenden drei Informationen:
a) signo: Signalnummer
b) errno: Fehlernummer
c) Code: Signalcode
2. SIGCHLD signalspezifische Informationen
a) Status: Ausgangswert oder Signal
b) utime: Benutzerverbrauchszeit
c) stime: Systemverbrauchszeit
d) pid: Sendeprozess-ID
e) uid: echte Benutzer-ID des sendenden Prozesses
3. Informationen im Besitz von SIGILL, SIGFPE, SIGSEGV, SIGBUS
a) addr: Speicherort, an dem der Fehler aufgetreten ist
4. Eindeutige SIGPOLL-Informationen:
a) band: Bandereignis, Bedeutung unbekannt
b) fd: Dateideskriptor
Die Funktion wird erfolgreich ausgeführt und gibt die Signalnummer zurück
int pcntl_wait(int &$status [ , int *options = 0]):
Hängt den aktuellen Prozess an, bis ein untergeordneter Prozess beendet wird oder bis ein Signal die Beendigung des aktuellen Prozesses erfordert oder eine Signalverarbeitungsfunktion aufgerufen wird, wenn der untergeordnete Prozess beim Aufruf beendet wurde (. Üblicherweise als Zombie-Prozess bekannt), kehrt diese Funktion sofort zurück und alle Systemressourcen werden freigegeben.
$status wird zum Speichern der Statusinformationen des untergeordneten Prozesses verwendet, die von den folgenden Funktionen generiert werden: pcntl_wifexited, pcntl_wifstopped , pcntl_wifsignaled, pcntl_wexitstatus, pcntl_wtermsig, pcntl_wstopsig .
$options: Wenn Ihr System wait3 zulässt (die meisten BSD-ähnlichen Systeme), können Sie einen optionalen Optionsparameter angeben. Wenn dieser Parameter nicht bereitgestellt wird, verwendet wait den Systemaufruf. Wenn das System wait3 nicht zulässt und dieser Parameter keine Auswirkung hat, kann der Wert von $options 0 oder die beiden Konstanten WNOHANG und WUNTRACED sein.
Die Funktion gibt die PID des beendenden untergeordneten Prozesses oder -1 im Fehlerfall zurück , oder wenn WNOHANG als Option bereitgestellt wird (wait3 nicht verfügbares System) und kein gültiger untergeordneter Prozess vorhanden ist, wird 0 zurückgegeben Um dem übergeordneten Prozess einige Informationen zu überlassen, verlässt der untergeordnete Prozess die nächste Datenstruktur, die als Zombie bezeichnet wird, und wartet auf einen vom übergeordneten Prozess initiierten Wartevorgang, um seine Leiche einzusammeln. Der untergeordnete Prozess wird in der Zeit zwischen dem als Zombie-Prozess bezeichnet Ende des untergeordneten Prozesses (logisches Ende) und Sammlung seiner Leiche durch den übergeordneten Prozess. Nach dem Ende werden alle untergeordneten Prozesse an Init übergeben. Daher werden die Zombie-Prozesse recycelt Wenn der übergeordnete Prozess nie endet, belegen diese Zombie-Prozesse immer die Prozessnummer. Wenn die Prozessnummer erschöpft ist, kann kein neuer Prozess gestartet werden Sammeln Sie die Leichen der untergeordneten Prozesse, die von ihm selbst im übergeordneten Prozess generiert wurden.
int pcntl_waitpid(int $pid, int &$status[, int $options = 0 ]):
Hängt den aktuellen Prozess bis zum untergeordneten Prozess an mit der angegebenen $pid wird beendet, oder der aktuelle Prozess empfängt ein Exit-Signal oder empfängt ein IGE-Signal, um einen Signalhandler aufzurufen.
Wenn $pid angegeben ist, wurde der entsprechende untergeordnete Prozess beim Aufruf dieser Funktion beendet (Zombie-Status), Die Funktion kehrt sofort zurück und alle Systemressourcen werden freigegeben.
$pid: Prozessnummer, kleiner als -1 zeigt an, dass auf einen untergeordneten Prozess in der Prozessgruppe gewartet wird. Die Prozessgruppennummer ist der absolute Wert von $pid . Gleich -1 bedeutet, dass auf eine Verbotene Stadt gewartet wird, was mit dem Verhalten der Funktion pcntl_wait übereinstimmt. Gleich 0 bedeutet, dass auf einen untergeordneten Prozess in derselben Gruppe wie der aufrufende Prozess gewartet wird, und größer als 0 bedeutet, dass es sich um einen bestimmten Prozess handelt.
$status: wird verwendet, um den Status des untergeordneten Prozesses von der Funktion zurückzugeben. Diese Statusinformationen werden von den folgenden Funktionen generiert: pcntl_wifexited, pcntl_wifstopped, pcntl_wifsignaled, pcntl_wexitstatus, pcntl_wtermsig, pcntl_wstopsig.
$options: hat die gleiche Bedeutung wie $options von pcntl_wait
int pcntl_wexitstat us (int $status):
Gibt den Rückgabecode eines unterbrochenen untergeordneten Prozesses zurück. Diese Funktion ist nur nützlich, wenn die Funktion pcntl_wifexited TRUE zurückgibt.
Der Parameter $status ist die generierte Statusinformation von pcntl_waitpid.
bool pcntl_wifexited(int $status):
Überprüfen Sie, ob der angegebene Status anzeigt, dass der untergeordnete Prozess normal beendet wurde.
bool pcntl_wifsignaled(int $status):
Überprüfen Sie, ob der angegebene Status anzeigt dass der untergeordnete Prozess aufgrund des Empfangs eines bestimmten Signals beendet wurde.
bool pcntl_wifstopped(int $status):
Überprüfen Sie, ob $status anzeigen kann, dass der untergeordnete Prozess derzeit gestoppt ist. Diese Funktion generiert nur $status, wenn sie auf WUNTRACED wirkt Wird von der Funktion pcntl_waitpid als Wert des Parameters $options verwendet. Er ist nur oben gültig.
int pcntl_wstopsig(int $status):
Gibt die Nummer des Signals zurück, das den untergeordneten Prozess durch Analyse von $status stoppt. Diese Funktion ist nur gültig, wenn pcntl_wifsignaled TRUE zurückgibt.
int pcntl_wtermsig(int $status):
Gibt die Signalnummer zurück, die den Prozess unterbricht. Diese Funktion ist nur gültig, wenn pcntl_wifsignaled TRUE zurückgibt.

Die Oben finden Sie den gesamten Inhalt dieses Artikels. Ich hoffe, er wird zum Lernen aller beitragen. Weitere Informationen finden Sie auf der chinesischen PHP-Website für verwandte Inhalte!

Verwandte Empfehlungen:

Analyse der Unterschiede zwischen Decke, Boden, Rund und Intervall der PHP-Rundungsfunktionen

So verwenden Sie Curl in PHP, um das Hochladen und Empfangen von Dateien zu simulieren

Das obige ist der detaillierte Inhalt vonSo verwenden Sie pcntl und libevent in PHP, um die Timer-Funktion zu implementieren. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!