Communication par sémaphore et mémoire partagée basée sur la communication de processus PHP

Cet article présente principalement les informations pertinentes sur les sémaphores et la communication en mémoire partagée dans les connaissances de base de la communication des processus PHP. Les amis dans le besoin peuvent le consulter

Parce qu'il n'est pas certain qui s'exécute en premier entre les processus, qui dépend de l'algorithme de planification des processus du noyau, qui est plus compliqué. Par conséquent, il est possible que plusieurs processus accèdent à la mémoire partagée en même temps, provoquant des erreurs imprévisibles. Le nom sémaphore prête à confusion, mais il est très facile à comprendre en raison de sa signification anglaise originale.

sémaphore anglais [ˈseməfɔ:(r)] vt. Envoyer un signal, un drapeau

Semblable au rôle d'un commandant.

Regardons l'utilisation d'un sémaphore pseudocode.

1. Créez un identifiant unique de sémaphore

$ftok = ftok(__FILE__, 'a');

2. Créez un identifiant de ressource de sémaphore

$sem_resouce_id = sem_get($ftok);.

3. Accepter le sémaphore

sem_acqure($sem_resource_id);

4. Libérer le sémaphore

sem_release($sem_resource_id);

5. Détruire le sémaphore

sem_remove($sem_resource_id);

Un exemple non civilisé nous permettra de mieux comprendre comment ce sémaphore est utilisé dans la vie. Après l'avoir compris, nous pouvons l'appliquer à notre domaine de programmation.
Une entreprise n’a qu’une seule salle de bain. Ensuite, lorsque quelqu'un va aux toilettes, il doit se procurer un cadenas (sémaphore), indiquant que les toilettes sont utilisées. Le code est le suivant :

sem_acqure($sem_resource_id);

Ensuite, après que l'employé ait utilisé les toilettes, il doit ouvrir la serrure et libérer la serrure (sémaphore), indiquant que d'autres peuvent maintenant, utilisez-le. Le code est le suivant :

sem_release($sem_resource_id);

Avec un simple verrou, on peut savoir si les toilettes actuelles (mémoire partagée) peuvent être utilisées. Cet exemple n’est pas élégant, mais il illustre le propos. Ce blog est aussi un blog de bon goût, ce qui n'est vraiment pas facile. . . . Voici un exemple de code :

<?php
//创建共享内存区域
$shm_key = ftok(__FILE__, &#39;a&#39;);
$shm_id = shm_attach($shm_key, 1024, 0755);

//var_dump($shm_id);die(); resource(4) of type (sysvshm)
const SHARE_KEY = 1;
$child_list = [];

//加入信号量
$sem_id = ftok(__FILE__, &#39;b&#39;);
$signal = sem_get($sem_id);

//$signal resource(5) of type (sysvsem)


for ($i = 0; $i < 3; $i++) {
  $pid = pcntl_fork();
  if ($pid == -1) {
    exit("Fork fail!".PHP_EOL);
  } elseif ($pid == 0) {
    //获取信号量
    sem_acquire($signal);
    if (shm_has_var($shm_id,SHARE_KEY)) {
      $count = shm_get_var($shm_id, SHARE_KEY);
      $count++;
      //模拟业务处理
      $sec = rand(1, 3);
      sleep($sec);
      shm_put_var($shm_id, SHARE_KEY, $count);
    } else {
      $count = 0;
      $sec = rand(1, 3);
      sleep($sec);
      shm_put_var($shm_id, SHARE_KEY, $count);
    }

    echo "child process: ".getmypid()." is writing! now count is: $count ".PHP_EOL;

    //释放信号量
    sem_release($signal);
    exit("child process".getmypid()."end".PHP_EOL);
  } else {
    $child_list[] = $pid;
  }
}

while (count($child_list) > 0) {
  foreach ($child_list as $key => $pid) {
    $status = pcntl_waitpid($pid, $status);
    if ($status > 0 || $status == -1) {
      unset($child_list[$key]);
    }
  }
  sleep(1);
}

$count = shm_get_var($shm_id, SHARE_KEY);
echo " $count  ".PHP_EOL;

//销毁信号量
sem_remove($signal);

shm_remove($shm_id);
shm_detach($shm_id);

Pour plus d'articles liés aux sémaphores et à la communication en mémoire partagée basée sur la communication de processus PHP, veuillez faire attention au PHP Site chinois !