Многопоточная работа с блокировками¶

Установка¶

В приложениях с Symfony Flex, запустите эту команду для установки компонента Lock:

1

$ composer require symfony/lock

Настройка Lock с FrameworkBundle¶

По умолчанию Symfony предоставляет Semaphore, когда возможно, или Flock в других случаях. Вы можете настроить это поведение используя ключ lock так:

Блокировка ресурса¶

Для блокировки ресурса по умолчанию, автоподключите Lock используя LockInterface (id сервиса lock):

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

// src/Controller/PdfController.php
namespace App\Controller;

use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
use Symfony\Component\Lock\LockInterface;

class PdfController extends AbstractController
{
    /**
     * @Route("/download/terms-of-use.pdf")
     */
    public function downloadPdf(LockInterface $lock, MyPdfGeneratorService $pdf)
    {
        $lock->acquire(true);

        // сложные расчёты
        $myPdf = $pdf->getOrCreatePdf();

        $lock->release();

        // ...
    }
}

Блокирование динамического ресурса¶

Иногда приложение может разделить ресурс на небольшие части, чтобы блокировать только часть и позволять остальным обрабатываться. В предудущем примере где блокировалось $pdf->getOrCreatePdf('terms-of-use') для всех, давайте посмотрим как заблокировать $pdf->getOrCreatePdf($version) только для процессов, которым нужен доступ к той же $version:

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

// src/Controller/PdfController.php
namespace App\Controller;

use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
use Symfony\Component\Lock\LockInterface;

class PdfController extends AbstractController
{
    /**
     * @Route("/download/{version}/terms-of-use.pdf")
     */
    public function downloadPdf($version, LockFactory $lockFactory, MyPdfGeneratorService $pdf)
    {
        $lock = $lockFactory->createLock($version);
        $lock->acquire(true);

        // сложные расчёты
        $myPdf = $pdf->getOrCreatePdf($version);

        $lock->release();

        // ...
    }
}

Именованая блокировка¶

Если приложению нужен другой тип хранилища для разных блокировок, Symfony предоставляет именованную блокировку:

1

.. configuration-block::

1 2 3 4 5

# config/packages/lock.yaml framework: lock: invoice: ['semaphore', 'redis://r2.docker'] report: 'semaphore'

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17

<!-- config/packages/lock.xml --> <?xml version="1.0" encoding="UTF-8" ?> <container xmlns="http://symfony.com/schema/dic/services" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:framework="http://symfony.com/schema/dic/symfony" xsi:schemaLocation="http://symfony.com/schema/dic/services https://symfony.com/schema/dic/services/services-1.0.xsd http://symfony.com/schema/dic/symfony https://symfony.com/schema/dic/symfony/symfony-1.0.xsd"> <framework:config> <framework:lock> <framework:resource name="invoice">semaphore</framework:resource> <framework:resource name="invoice">redis://r2.docker</framework:resource> <framework:resource name="report">semaphore</framework:resource> </framework:lock> </framework:config> </container>

1 2 3 4 5 6 7

// config/packages/lock.php $container->loadFromExtension('framework', [ 'lock' => [ 'invoice' => ['semaphore', 'redis://r2.docker'], 'report' => 'semaphore', ], ]);

Каждое название становится сервисом, где к id сервиса добавляется суффикс в виде имени блокировщика (например, lock.invoice). Также создаётся алиас для автоподключения каждого блокировщика используя camel case версию его имени с добавлением Lock - например, invoice может быть автовнедрён с помощью названия аргумента $invoiceLock и с добавлением типа к нему LockInterface.

Symfony также предоставляет соответствующую фабрику и хранилице с аналогичными правилами (например invoice генерирует фабрику lock.invoice.factory и хранилище lock.invoice.store, оба могут быть автовнедрены с названиями соответственно $invoiceLockFactory и $invoiceLockStore с указанием типов LockFactory и PersistingStoreInterface)

Блокирующее хранилище¶

Если вы хотите использовать RetryTillSaveStore для неблокирующих блокировщиков, вы можете сделать это декорировав сервис хранилища:

1
2
3
4

lock.default.retry_till_save.store:
    class: Symfony\Component\Lock\Store\RetryTillSaveStore
    decorates: lock.default.store
    arguments: ['@lock.default.retry_till_save.store.inner', 100, 50]