46 lines
1.1 KiB
PHP
46 lines
1.1 KiB
PHP
<?php
|
|
|
|
namespace App\Services;
|
|
|
|
use RuntimeException;
|
|
|
|
/** Local process exclusion; OS releases the lock if a worker is terminated. */
|
|
class ReplenishmentProcessLock
|
|
{
|
|
/** @var resource|null */
|
|
private $handle = null;
|
|
|
|
public function acquire(): bool
|
|
{
|
|
if ($this->handle !== null) {
|
|
throw new RuntimeException('Verificação periódica já adquirida nesta instância.');
|
|
}
|
|
$handle = fopen(storage_path('framework/replenishment-command.lock'), 'c');
|
|
if ($handle === false) {
|
|
throw new RuntimeException('Não foi possível abrir o controlo da verificação periódica.');
|
|
}
|
|
if (! flock($handle, LOCK_EX | LOCK_NB)) {
|
|
fclose($handle);
|
|
|
|
return false;
|
|
}
|
|
$this->handle = $handle;
|
|
|
|
return true;
|
|
}
|
|
|
|
public function release(): void
|
|
{
|
|
if ($this->handle !== null) {
|
|
flock($this->handle, LOCK_UN);
|
|
fclose($this->handle);
|
|
$this->handle = null;
|
|
}
|
|
}
|
|
|
|
public function __destruct()
|
|
{
|
|
$this->release();
|
|
}
|
|
}
|