Giới thiệu

Thỉnh thoảng bạn có thể cần chạy nhiều task nặng mà không phụ thuộc vào bên khác. Trong nhiều trường hợp, hiệu suất có thể được cải thiện bằng cách chạy đồng thời các task đó. Facade Concurrency của Laravel sẽ cung cấp một API đơn giản, thuận tiện để chạy các task đó.

How it Works

Laravel đạt được tính năng chạy đồng thời này bằng cách chuyển hoá các closure đã cho và phân phối chúng đến một lệnh Artisan CLI ẩn, lệnh này sẽ dịch lại các closure và gọi nó trong process PHP của lệnh. Sau khi closure đã chạy xong, giá trị kết quả sẽ được chuyển trở lại process cha.

Facade Concurrency hỗ trợ ba driver: process (mặc định), fork và sync.

Driver fork mang lại hiệu suất tốt so với driver process mặc định, nhưng nó chỉ có thể được sử dụng trong CLI của PHP, vì PHP không hỗ trợ fork cho các request web. Trước khi sử dụng driver fork, bạn cần cài đặt package spatie/fork:

composer require spatie/fork

Driver sync chủ yếu được dùng trong quá trình testing khi bạn muốn disable tính năng chạy đồng thời và bạn chỉ cần đơn giản là chạy các closure trong process cha.

Chạy các task đồng thời

Để chạy các task đồng thời, bạn có thể gọi phương thức run của facade Concurrency. Phương thức run sẽ chấp nhận một mảng các closure cần được chạy trong các process PHP con:

use Illuminate\Support\Facades\Concurrency;
use Illuminate\Support\Facades\DB;

[$userCount, $orderCount] = Concurrency::run([
    fn () => DB::table('users')->count(),
    fn () => DB::table('orders')->count(),
]);

Để sử dụng một driver cụ thể, bạn có thể sử dụng phương thức driver:

$results = Concurrency::driver('fork')->run(...);

Hoặc, để thay đổi driver mặc định, bạn có thể export file cấu hình concurrency thông qua lệnh Artisan config:publish và cập nhật tùy chọn default trong file đó:

php artisan config:publish concurrency

Hoãn các task đồng thời

Nếu bạn muốn chạy một mảng các closure, nhưng không quan tâm đến kết quả trả về của các closure đó, bạn nên cân nhắc sử dụng phương thức defer. Khi sử dụng phương thức defer, các closure sẽ không được chạy ngay lập tức. Mà thay vào đó, Laravel sẽ chạy các closure này sau khi response HTTP được gửi về người dùng:

use App\Services\Metrics;
use Illuminate\Support\Facades\Concurrency;

Concurrency::defer([
    fn () => Metrics::report('users'),
    fn () => Metrics::report('orders'),
]);