Process queue jobs in background (#57648)

Author: barryvdh

src/Illuminate/Queue/BackgroundQueue.php

@@ -0,0 +1,26 @@
+<?php
+
+namespace Illuminate\Queue;
+
+use Illuminate\Contracts\Queue\Job;
+use Illuminate\Support\Facades\Concurrency;
+
+class BackgroundQueue extends SyncQueue
+{
+    /**
+     * Push a new job onto the queue.
+     *
+     * @param  string  $job
+     * @param  mixed  $data
+     * @param  string|null  $queue
+     * @return mixed
+     *
+     * @throws \Throwable
+     */
+    public function push($job, $data = '', $queue = null)
+    {
+        Concurrency::driver('process')->defer(
+            fn () => \Illuminate\Support\Facades\Queue::connection('sync')->push($job, $data, $queue)
+        );
+    }
+}

src/Illuminate/Queue/Connectors/BackgroundConnector.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace Illuminate\Queue\Connectors;
+
+use Illuminate\Queue\BackgroundQueue;
+
+class BackgroundConnector implements ConnectorInterface
+{
+    /**
+     * Establish a queue connection.
+     *
+     * @return \Illuminate\Contracts\Queue\Queue
+     */
+    public function connect(array $config)
+    {
+        return new BackgroundQueue($config['after_commit'] ?? null);
+    }
+}

src/Illuminate/Queue/QueueServiceProvider.php

@@ -6,6 +6,7 @@
 use Illuminate\Contracts\Debug\ExceptionHandler;
 use Illuminate\Contracts\Events\Dispatcher as EventDispatcher;
 use Illuminate\Contracts\Support\DeferrableProvider;
+use Illuminate\Queue\Connectors\BackgroundConnector;
 use Illuminate\Queue\Connectors\BeanstalkdConnector;
 use Illuminate\Queue\Connectors\DatabaseConnector;
 use Illuminate\Queue\Connectors\DeferredConnector;
@@ -105,7 +106,7 @@ protected function registerConnection()
      */
     public function registerConnectors($manager)
     {
-        foreach (['Null', 'Sync', 'Deferred', 'Failover', 'Database', 'Redis', 'Beanstalkd', 'Sqs'] as $connector) {
+        foreach (['Null', 'Sync', 'Deferred', 'Background', 'Failover', 'Database', 'Redis', 'Beanstalkd', 'Sqs'] as $connector) {
             $this->{"register{$connector}Connector"}($manager);
         }
     }
@@ -149,6 +150,19 @@ protected function registerDeferredConnector($manager)
         });
     }
 
+    /**
+     * Register the Background queue connector.
+     *
+     * @param  \Illuminate\Queue\QueueManager  $manager
+     * @return void
+     */
+    protected function registerBackgroundConnector($manager)
+    {
+        $manager->addConnector('background', function () {
+            return new BackgroundConnector;
+        });
+    }
+
     /**
      * Register the Failover queue connector.
      *