mirror of
https://github.com/danog/parallel.git
synced 2024-12-11 08:39:48 +01:00
65 lines
1.5 KiB
PHP
65 lines
1.5 KiB
PHP
<?php
|
|
|
|
namespace Amp\Parallel\Sync;
|
|
|
|
use Amp\Promise;
|
|
use Amp\Success;
|
|
use Amp\Sync\ThreadedMutex;
|
|
use function Amp\call;
|
|
|
|
/**
|
|
* A thread-safe container that shares a value between multiple threads.
|
|
*
|
|
* @deprecated ext-pthreads development has been halted, see https://github.com/krakjoe/pthreads/issues/929
|
|
*/
|
|
final class ThreadedParcel implements Parcel
|
|
{
|
|
/** @var \Amp\Sync\ThreadedMutex */
|
|
private $mutex;
|
|
|
|
/** @var \Threaded */
|
|
private $storage;
|
|
|
|
/**
|
|
* Creates a new shared object container.
|
|
*
|
|
* @param mixed $value The value to store in the container.
|
|
*/
|
|
public function __construct($value)
|
|
{
|
|
$this->mutex = new ThreadedMutex;
|
|
$this->storage = new Internal\ParcelStorage($value);
|
|
}
|
|
|
|
/**
|
|
* {@inheritdoc}
|
|
*/
|
|
public function unwrap(): Promise
|
|
{
|
|
return new Success($this->storage->get());
|
|
}
|
|
|
|
/**
|
|
* @return \Amp\Promise
|
|
*/
|
|
public function synchronized(callable $callback): Promise
|
|
{
|
|
return call(function () use ($callback): \Generator {
|
|
/** @var \Amp\Sync\Lock $lock */
|
|
$lock = yield $this->mutex->acquire();
|
|
|
|
try {
|
|
$result = yield call($callback, $this->storage->get());
|
|
|
|
if ($result !== null) {
|
|
$this->storage->set($result);
|
|
}
|
|
} finally {
|
|
$lock->release();
|
|
}
|
|
|
|
return $result;
|
|
});
|
|
}
|
|
}
|