2015-08-02 04:51:45 +02:00
|
|
|
<?php
|
|
|
|
namespace Icicle\Concurrent\Sync;
|
|
|
|
|
|
|
|
/**
|
2015-08-31 11:19:49 +02:00
|
|
|
* A non-blocking counting semaphore.
|
2015-08-02 04:51:45 +02:00
|
|
|
*
|
|
|
|
* Objects that implement this interface should guarantee that all operations
|
|
|
|
* are atomic.
|
|
|
|
*/
|
2015-08-31 11:19:49 +02:00
|
|
|
interface SemaphoreInterface extends \Countable
|
2015-08-02 04:51:45 +02:00
|
|
|
{
|
2015-08-31 11:19:49 +02:00
|
|
|
/**
|
|
|
|
* Gets the number of currently available locks.
|
|
|
|
*
|
|
|
|
* @return int The number of available locks.
|
|
|
|
*/
|
|
|
|
public function count();
|
|
|
|
|
2015-08-02 04:51:45 +02:00
|
|
|
/**
|
2015-08-10 05:30:11 +02:00
|
|
|
* @coroutine
|
|
|
|
*
|
2015-08-07 22:32:18 +02:00
|
|
|
* Acquires a lock from the semaphore asynchronously.
|
2015-08-02 04:51:45 +02:00
|
|
|
*
|
2015-08-31 11:19:49 +02:00
|
|
|
* If there are one or more locks available, this function resolve imsmediately with a lock and the lock count is
|
|
|
|
* decreased. If no locks are available, the semaphore waits asynchronously for a lock to become available.
|
|
|
|
*
|
|
|
|
* @return \Generator Resolves with a lock object when the acquire is successful.
|
2015-08-10 05:30:11 +02:00
|
|
|
*
|
|
|
|
* @resolve \Icicle\Concurrent\Sync\Lock
|
2015-08-02 04:51:45 +02:00
|
|
|
*/
|
|
|
|
public function acquire();
|
|
|
|
}
|