이 글은 주로 PHP 세마포어의 사용법과 예제를 소개합니다. 관심 있는 친구들이 참고하면 좋습니다.
이론적 근거:
Semaphore: 세마포라고도 함, 프로세스(스레드 동기화 문제)를 해결하는 데 사용됨, 잠금과 유사, 액세스하기 전에 잠금을 획득(획득하지 않은 경우 획득) 기다려) 접속 후 잠금을 해제하세요.
Critical resources: 한 번에 하나의 프로세스만 액세스할 수 있는 리소스입니다.
Critical section: 중요한 리소스에 액세스하는 각 프로세스의 코드 섹션을 중요한 섹션이라고 합니다.
프로세스 상호 배제: 두 개 이상의 프로세스가 동일한 공유 변수 집합의 임계 섹션에 들어갈 수 없습니다. 동시에, 즉 한 프로세스가 중요한 리소스에 액세스하고 있고 다른 프로세스는 해당 리소스에 액세스하기 전에 기다려야 합니다.
프로세스 동기화여러 프로세스 간의 실행 순서를 결정하고 데이터 경쟁 문제를 피하는 방법, 즉 여러 프로세스가 함께 잘 실행되도록 하는 방법을 주로 연구합니다.
예제는 다음과 같습니다.
$key=ftok(__FILE__,'t'); /** * 获取一个信号量资源 int $key [, int $max_acquire = 1 [, int $perm = 0666 [, int $auto_release = 1 ]]] $max_acquire:最多可以多少个进程同时获取信号 $perm:权限 默认 0666 $auto_release:是否自动释放信号量 */ $sem_id=sem_get($key); #获取信号 sem_acquire($seg_id); //do something 这里是一个原子性操作 //释放信号量 sem_release($seg_id); //把次信号从系统中移除 sem_remove($sem_id); //可能出现的问题 $fp = sem_get(fileinode(__DIR__), 100); sem_acquire($fp); $fp2 = sem_get(fileinode(__DIR__), 1)); sem_acquire($fp2);
PHP에서 읽기-쓰기 세마포어 구현:
class rw_semaphore { const READ_ACCESS = 0; const WRITE_ACCESS = 1; /** * @access private * @var resource - mutex semaphore */ private $mutex; /** * @access private * @var resource - read/write semaphore */ private $resource; /** * @access private * @var int */ private $writers = 0; /** * @access private * @var int */ private $readers = 0; /** * Default constructor * * Initialize the read/write semaphore */ public function __construct() { $mutex_key = ftok('/home/cyrus/development/php/sysvipc/rw_semaphore.php', 'm'); $resource_key = ftok('/home/cyrus/development/php/sysvipc/rw_semaphore.php', 'r'); $this->mutex = sem_get($mutex_key, 1); $this->resource = sem_get($resource_key, 1); } /** * Destructor * * Remove the read/write semaphore */ public function __destruct() { sem_remove($this->mutex); sem_remove($this->resource); } /** * Request acess to the resource * * @param int $mode * @return void */ private function request_access($access_type = self::READ_ACCESS) { if ($access_type == self::WRITE_ACCESS) { sem_acquire($this->mutex); /* update the writers counter */ $this->writers++; sem_release($this->mutex); sem_acquire($this->resource); } else { sem_acquire($this->mutex); if ($this->writers > 0 || $this->readers == 0) { sem_release($this->mutex); sem_acquire($this->resource); sem_acquire($this->mutex); } /* update the readers counter */ $this->readers++; sem_release($this->mutex); } } private function request_release($access_type = self::READ_ACCESS) { if ($access_type == self::WRITE_ACCESS) { sem_acquire($this->mutex); /* update the writers counter */ $this->writers--; sem_release($this->mutex); sem_release($this->resource); } else { sem_acquire($this->mutex); /* update the readers counter */ $this->readers--; if ($this->readers == 0) sem_release($this->resource); sem_release($this->mutex); } } /** * Request read access to the resource * * @return void */ public function read_access() { $this->request_access(self::READ_ACCESS); } /** * Release read access to the resource * * @return void */ public function read_release() { $this->request_release(self::READ_ACCESS); } /** * Request write access to the resource * * @return void */ public function write_access() { $this->request_access(self::WRITE_ACCESS); } /** * Release write access to the resource * * @return void */ public function write_release() { $this->request_release(self::WRITE_ACCESS); } }
원자적 연산을 달성하기 위한 공유 메모리 + 신호
$SHM_KEY = ftok("/home/joeldg/homeymail/shmtest.php", 'R'); $shmid = sem_get($SHM_KEY, 1024, 0644 | IPC_CREAT); $data = shm_attach($shmid, 1024); // we now have our shm segment // lets place a variable in there shm_put_var ($data, $inmem, "test"); // now lets get it back. we could be in a forked process and still have // access to this variable. printf("shared contents: %s\n", shm_get_var($data, $inmem)); shm_detach($data);
요약: 위 내용은 이 기사의 전체 내용입니다. 모든 사람에게 유용할 수 있기를 바랍니다. 학습 도움.
관련 권장 사항:
PHP로 캡슐화된 MSSql 작업 클래스 및 완전한 예제 분석
Oracle 데이터베이스를 연결하는 방법 PHP 그리고 그 단순성 분석
위 내용은 PHP 세마포어의 사용법과 예의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!