PHP 프로세스 통신을 기반으로 한 세마포어 및 공유 메모리 통신

이번 글에서는 PHP 프로세스 통신의 기본 지식 중 세마포어와 공유 메모리 통신에 관한 관련 정보를 주로 소개하고 있습니다. 프로세스 간에 누가 먼저 실행하는지 알 수 없기 때문에 도움이 필요한 친구들이 확인하시면 됩니다. 이는 커널의 프로세스 스케줄링 알고리즘에 따라 달라지며 더 복잡합니다. 결과적으로 여러 프로세스가 동시에 공유 메모리에 액세스하여 예측할 수 없는 오류가 발생할 수 있습니다. 세마포어(Semaphore)라는 이름은 혼란스러울 수 있지만 원래의 영어 의미를 바탕으로 보면 매우 이해하기 쉽습니다.

세마포어 영어 [ˈseməfɔ:(r)] vt. 신호, 깃발 보내기

지휘관 역할과 유사합니다.

의사코드 세마포어의 사용법을 살펴보겠습니다.

1. 세마포어 고유 식별자를 생성합니다

$ftok = ftok(__FILE__, 'a');2. 세마포어 리소스 ID를 생성합니다

3. 세마포 승인$sem_resouce_id = sem_get($ftok);

4. 세마포 해제sem_acqure($sem_resource_id);

5. 세마포어 파괴

sem_release($sem_resource_id);

미개한 예를 통해 이 세마포어가 생활에서 어떻게 사용되는지 더 쉽게 이해할 수 있습니다. 이해한 후에는 프로그래밍 분야에 적용할 수 있습니다. sem_remove($sem_resource_id);회사에는 화장실이 하나뿐입니다. 그런 다음 누군가 화장실에 갈 때 화장실이 사용 중임을 나타내는 자물쇠(세마포어)를 얻어야 합니다. 코드는 다음과 같습니다.

그런 다음 직원이 화장실을 사용한 후 자물쇠를 열고 자물쇠(세마포어)를 해제해야 다른 사람이 할 수 있음을 나타냅니다. 이제 그것을 사용하십시오. 코드는 다음과 같습니다. sem_acqure($sem_resource_id);

간단한 잠금 장치로 현재 화장실(공유 메모리)을 사용할 수 있는지 여부를 알 수 있습니다. 이 예는 우아하지는 않지만 요점을 보여줍니다. 이 블로그도 맛깔스러운 블로그인데 정말 쉽지 않네요. . . . 다음은 샘플 코드입니다. sem_release($sem_resource_id);

<?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);

PHP 프로세스 통신을 기반으로 한 세마포어 및 공유 메모리 통신과 관련된 더 많은 기사를 보려면 PHP 중국어 웹사이트를 참고하세요. !