SporkCacheWarmerAggregate.php

<?php
 
namespace App\Component\HttpKernel\CacheWarmer;
 
use Spork\Batch\Strategy\ChunkStrategy;
use Spork\ProcessManager;
use Symfony\Component\HttpKernel\CacheWarmer\CacheWarmerAggregate;
 
class SporkCacheWarmerAggregate extends CacheWarmerAggregate
{
    protected $chunks = 10;
 
    /**
     * Warms up the cache.
     *
     * @param string $cacheDir The cache directory
     */
    public function warmUp($cacheDir)
    {
        $spork = new ProcessManager();
 
        $warmers = array();
        foreach ($this->warmers as $warmer) {
            if (!$this->optionalsEnabled && $warmer->isOptional()) {
                continue;
            }
 
            $warmers[] = $warmer;
        }
 
        $batch = $spork->createBatchJob(
            $warmers,
            new ChunkStrategy($this->chunks)
        );
 
        $batch->execute(function ($warmer) use ($cacheDir) {
            $warmer->warmUp($cacheDir);
        });
    }
}