* @link bitcoin:1P5FAZ4QhXCuwYPnLZdk3PJsqePbu1UDDA Donations * @license WTFPL */ class SemaphoreMutex extends LockMutex { /** * @var resource The semaphore id. */ private $semaphore; /** * Sets the semaphore id. * * Use {@link sem_get()} to create the semaphore id. * * Example: * * $semaphore = sem_get(ftok(__FILE__, "a")); * $mutex = new SemaphoreMutex($semaphore); * * * @param resource semaphore The semaphore id. * @throws \InvalidArgumentException The semaphore id is not a valid resource. */ public function __construct($semaphore) { if (!is_resource($semaphore)) { throw new \InvalidArgumentException("The semaphore id is not a valid resource."); } $this->semaphore = $semaphore; } /** * @internal */ protected function lock() { if (!sem_acquire($this->semaphore)) { throw new LockAcquireException("Failed to acquire the Semaphore."); } } /** * @internal */ protected function unlock() { if (!sem_release($this->semaphore)) { throw new LockReleaseException("Failed to release the Semaphore."); } } }