Компонент Symfony Lock не блокируется — как исправить?

Question

Компонент Symfony Lock не блокируется — как исправить?

я недавно обновился до Symfony 3.4.x, реорганизовал LockHandler из-за предупреждения об устаревании и впал в странное поведение.

Код в команде перед рефакторингом:

class FooCommand
{
protected function configure() { /* ... does not matter ... */ }
protected function lock() : bool
{
$resource = $this->getName();
$lock     = new \Symfony\Component\Filesystem\LockHandler($resource);

return $lock->lock();
}
protected function execute()
{
if (!$this->lock()) return 0;

// Execute some task
}
}

И это мешает запускать две команды одновременно — вторая просто заканчивается без выполнения работы. Это хорошо.

Но после предложенного рефакторинга он позволяет запускать много команд одновременно. Это ФАЙЛ. Как предотвратить казнь? Новый код:

class FooCommand
{
protected function configure() { /* ... does not matter ... */ }
protected function lock() : bool
{
$resource = $this->getName();
$store    = new \Symfony\Component\Lock\FlockStore(sys_get_temp_dir());
$factory  = new \Symfony\Component\Lock\Factory($store);
$lock     = $factory->createLock($resource);

return $lock->acquire();
}
protected function execute()
{
if (!$this->lock()) return 0;

// Execute some task
}
}

NB # 1: Меня не волнует много серверов или около того, только один экземпляр приложения.

NB # 2: Если процесс был убит, новая команда должна разблокироваться и работать.

3

locking php symfony symfony3.4

Решение

Другие решения

Других решений пока нет …

Источник

Accepted Answer

Вы должны использовать черту LockableTrait

    use Symfony\Component\Console\Command\LockableTrait;
use Symfony\Component\Console\Command\Command

class FooCommand  extends Command
{
use LockableTrait;
.....
protected function execute(InputInterface $input, OutputInterface $output)
{
if (!$this->lock()) {
$output->writeln('The command is already running in another process.');

return 0;
}
// If you prefer to wait until the lock is released, use this:
// $this->lock(null, true);

// ...

// if not released explicitly, Symfony releases the lock
// automatically when the execution of the command ends
$this->release();

}

3