Skip to content

Latest commit

 

History

History
108 lines (78 loc) · 2.37 KB

README.md

File metadata and controls

108 lines (78 loc) · 2.37 KB

LongRunning

Tests

This is the LongRunning mono repository for the following packages:

Installation

⚠️ Instead of installing this mono repository we recommend you to install the sub packages instead. See above.

composer require long-running/long-running

Symfony

If you are using Symfony, make sure to enable the bundle:

<?php
// config/bundles.php

return [
    // ...
    LongRunning\Core\Bundle\LongRunningBundle::class => ['all' => true],
];

How to use?

<?php

final class MyCleaner implements \LongRunning\Core\Cleaner
{
    public function cleanUp() : void
    {
        echo "Cleaning up memory!";
    }
}

$cleaner = new \LongRunning\Core\DelegatingCleaner([
    new MyCleaner(),
]);

while (true) {
    // Do heavy work, like processing jobs from a queue
    echo "Doing heavy work";
    sleep(1);
    echo "Done with heavy work";

    // Cleanup things
    $cleaner->cleanUp();
}

If you are using Symfony, any service that implements the LongRunning\Core\Cleaner interface will be autoconfigured and added to the LongRunning\Core\DelegatingCleaner.

The LongRunning\Core\DelegatingCleaner is aliased to LongRunning\Core\Cleaner.

That means that you can inject the LongRunning\Core\Cleaner service in your worker and it will call all configured cleaners on cleanUp():

<?php

namespace App;

use LongRunning\Core\Cleaner;

final class Worker
{
    private Cleaner $cleaner;

    public function __construct(Cleaner $cleaner)
    {
        $this->cleaner = $cleaner;
    }

    public function doWork() : void
    {
        while (true) {
            // Do heavy work, like processing jobs from a queue
            echo "Doing heavy work";
            sleep(1);
            echo "Done with heavy work";

            // Cleanup things
            $this->cleaner->cleanUp();
        }
    }
}

Existing cleaners

LongRunning provides 2 packages that add additional cleaners:

Upgrading

If you are coming from LongRunning 0.5.0 please refer to UPGRADING.md.