Swoole定时器怎么用？定时任务如何设置？

<?php
// 周期性定时器
$timer_id = swoole_timer_tick(1000, function ($timer_id) {
    echo "每隔1秒执行一次\n";
});

// 延时定时器
swoole_timer_after(3000, function () use ($timer_id) {
    echo "3秒后执行一次\n";
    swoole_timer_clear($timer_id); // 清除周期性定时器
});

echo "程序开始执行\n";

// 为了让定时器运行，需要一个事件循环。这里使用 swoole_event_wait() 来模拟事件循环
swoole_event_wait();
?>

<?php
$server = new Swoole\Server("0.0.0.0", 9501);

$server->set([
    'task_worker_num' => 4, // 启动4个task进程
]);

$server->on('Receive', function ($server, $fd, $reactor_id, $data) {
    // 投递一个异步任务
    $task_id = $server->task(['data' => $data, 'fd' => $fd]);
    echo "Dispath AsyncTask: id=$task_id\n";
});

$server->on('Task', function ($server, $task_id, $reactor_id, $data) {
    echo "New AsyncTask[id=$task_id]".PHP_EOL;
    // 模拟耗时操作
    sleep(2);
    // 处理任务...
    $result = 'task '.$task_id.' -> '. strlen($data['data']);
    // 返回任务执行的结果
    return $result;
});

$server->on('Finish', function ($server, $task_id, $data) {
    echo "AsyncTask[$task_id] Finish: result={$data}".PHP_EOL;
});

$server->on('Start', function ($server) {
    swoole_timer_tick(5000, function ($timer_id) use ($server) {
        $server->task(['data' => '定时任务']);
    });
});

$server->start();
?>

swoole_timer_clear()

<?php
$running = true;
$timer_id = swoole_timer_tick(1000, function ($timer_id) use (&$running) {
    if (!$running) {
        swoole_timer_clear($timer_id);
        echo "定时器已停止\n";
        return;
    }
    echo "每隔1秒执行一次\n";
});

// 模拟一段时间后停止定时器
swoole_timer_after(5000, function () use (&$running) {
    $running = false;
});

swoole_event_wait();
?>

<?php
$channel = new Swoole\Coroutine\Channel(1);

$timer_id = swoole_timer_tick(1000, function () use ($channel) {
    $channel->push(1);
});

go(function () use ($channel, $timer_id) {
    while ($channel->pop()) {
        echo "每隔1秒执行一次\n";
    }
    swoole_timer_clear($timer_id);
    echo "定时器已停止\n";
});

// 模拟一段时间后停止定时器
swoole_timer_after(5000, function () use ($channel) {
    $channel->close();
});

swoole_event_wait();
?>