Maison  >  Article  >  développement back-end  >  Explication détaillée de la communication entre sémaphore et mémoire partagée basée sur la communication de processus PHP

Explication détaillée de la communication entre sémaphore et mémoire partagée basée sur la communication de processus PHP

墨辰丷
墨辰丷original
2018-05-25 11:26:321129parcourir

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 l'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);


Ce qui précède est l'intégralité du contenu de cet article, j’espère qu’il vous sera utile. L’apprentissage de chacun aide.


Recommandations associées :

Utilisation de la mémoire partagée PHP et signalAnalyse des cas d'utilisation du contrôle

Explication détaillée de l'utilisation de la mémoire partagée PHP et du contrôle du signal

Utilisation de la mémoire partagée PHP et du signal Analyse des instances de contrôle

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!

Déclaration:
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn