danog/parallel
1
0
Fork 0
mirror of https://github.com/danog/parallel.git synced 2024-11-26 20:34:40 +01:00
Code Issues Projects Releases Wiki Activity

More appropriate method names

Browse Source
This commit is contained in:
coderstephen 2015-07-10 17:48:50 -05:00
parent a4bb4b601b
commit e9f09077c9
2 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Forking/Synchronized.php
View File

@ -35,7 +35,7 @@ abstract class Synchronized
*/
public function lock()
{
$this->semaphore->lock();
$this->semaphore->acquire();
}
/**
@ -43,7 +43,7 @@ abstract class Synchronized
*/
public function unlock()
{
$this->semaphore->unlock();
$this->semaphore->release();
}
/**

14
src/Semaphore.php
View File

@ -33,7 +33,7 @@ class Semaphore implements \Serializable
{
$this->key = abs(crc32(spl_object_hash($this)));
$this->maxLocks = $maxLocks;
$this->handle = sem_get($this->key, $maxLocks, $permissions, 0);
$this->handle = sem_get($this->key, $maxLocks, $permissions, 1);
if ($this->handle === false) {
throw new SemaphoreException('Failed to create the semaphore.');
@ -51,11 +51,11 @@ class Semaphore implements \Serializable
}
/**
* Locks the semaphore.
* Acquires a lock from the semaphore.
*
* Blocks until the semaphore is locked.
* Blocks until a lock can be acquired.
*/
public function lock()
public function acquire()
{
if (!sem_acquire($this->handle)) {
throw new SemaphoreException('Failed to lock the semaphore.');
@ -63,9 +63,9 @@ class Semaphore implements \Serializable
}
/**
* Unlocks the semaphore.
* Releases a lock to the semaphore.
*/
public function unlock()
public function release()
{
if (!sem_release($this->handle)) {
throw new SemaphoreException('Failed to unlock the semaphore.');
@ -106,6 +106,6 @@ class Semaphore implements \Serializable
// Get the semaphore key and attempt to re-connect to the semaphore in
// memory.
list($this->key, $this->maxLocks) = unserialize($serialized);
$this->handle = sem_get($this->key, $maxLocks);
$this->handle = sem_get($this->key, $maxLocks, 0666, 1);
}
}