composer require cathy/thinkphp6-async-task

<?php
namespace app\tasks;

use cathy\AsyncTask\main\AsyncTaskSynchronizer;

class DemoAsyncTasks
{
    public function demo($data, AsyncTaskSynchronizer $taskSynchronizer) {
        for($i = 1;$i <= 100; $i++) {
            $taskSynchronizer->update($i);
            sleep(1);
        }
        $taskSynchronizer->done(['message'=>'Hi!'.$data['name']]);
    }
}

$asyncTaskProducer = new AsyncTaskProducer();
try {
    $taskKey = $asyncTaskProducer->execute(
        new AsyncTask(DemoAsyncTasks::class, 'demo', ['name'=>'cathy'])
    );
    echo $taskKey;
} catch (ExecAsyncTaskException|InvalidAsyncTaskException $e) {
    echo $e->getMessage();
}

try {
    $taskKey = ''; // 执行异步任务得到的taskKey
    echo json_encode(AsyncTaskAcquirer::get($taskKey));
} catch (Exception $e) {
    echo $e->getMessage();
}