芝麻web文件管理V1.00

编辑当前文件:/home/qrafawbu/qrafiqxcreativeagency.com/accounts/office/vendor/amphp/sync/src/LocalMutex.php
<?php namespace Amp\Sync; use Amp\CallableMaker; use Amp\Deferred; use Amp\Promise; use Amp\Success; class LocalMutex implements Mutex { use CallableMaker; // kept for BC only /** @var bool */ private $locked = false; /** @var Deferred[] */ private $queue = []; /** {@inheritdoc} */ public function acquire(): Promise { if (!$this->locked) { $this->locked = true; return new Success(new Lock(0, \Closure::fromCallable([$this, 'release']))); } $this->queue[] = $deferred = new Deferred; return $deferred->promise(); } private function release(): void { if (!empty($this->queue)) { $deferred = \array_shift($this->queue); $deferred->resolve(new Lock(0, \Closure::fromCallable([$this, 'release']))); return; } $this->locked = false; } }