PHPプロセス通信に基づくセマフォと共有メモリ通信

この記事では、PHPのプロセス通信の基礎知識のうち、セマフォと共有メモリ通信に関する関連情報を中心に紹介していますので、必要な方はぜひご覧ください

プロセス間で誰が最初に実行するかはカーネルプロセスに依存します。スケジューリング アルゴリズムはより複雑です。その結果、複数のプロセスが同時に共有メモリにアクセスし、予期しないエラーが発生する可能性があります。セマフォという名前は紛らわしいですが、元の英語の意味に基づいて理解するのは非常に簡単です。

セマフォ 英語 [ˈseməfɔ:(r)] vt. 信号を送る、セマフォを上げる

指揮官の役割に似ています。

疑似コード セマフォの使用法を見てみましょう。

1. セマフォの一意の識別子を作成します

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

2、创建信号量资源ID

$sem_resouce_id = sem_get($ftok);

3、接受信号量

sem_acqure($sem_resource_id);

4、释放信号量

sem_release($sem_resource_id);

5、销毁信号量

sem_remove($sem_resource_id);

举个不文雅的例子，使我们容易理解这个信号量在生活中的用法。理解之后可以套用到我们编程领域。
一家公司只有一个卫生间。那么当有人上厕所的时候，都要获取一把锁（信号量），表示卫生间正在使用。代码如下：

sem_acqure($sem_resource_id);

那么员工上完厕所之后，就需要将锁打开，释放锁（信号量），表示现在可以允许别人使用。代码如下：

sem_release($sem_resource_id);
2. セマフォのリソース ID を作成します

$sem_resouce_id = sem_get ($ftok);

3. セマフォを受け入れる

sem_acqure($sem_resource_id);

🎜4. セマフォを解放する🎜🎜🎜sem_resource_id ) ;🎜🎜5. セマフォを破棄します🎜🎜🎜sem_remove($sem_resource_id);🎜🎜🎜非文明的な例により、日常生活におけるこのセマフォの役割を簡単に理解できます。理解した後は、プログラミング分野に応用できます。 🎜会社にはトイレが1つしかありません。次に、誰かがトイレに行くときは、トイレが使用中であることを示すロック (セマフォ) を取得する必要があります。コードは次のとおりです: 🎜🎜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 中国語 Web サイトに注目してください。 🎜