use Workerman\Worker;
use Workerman\Timer;
 
require_once __DIR__ . '/vendor/autoload.php';
 
$worker = new Worker();
 
// Worker 進(jìn)程啟動(dòng)時(shí)注冊(cè)定時(shí)任務(wù)
$worker->onWorkerStart = function ($worker) {
    // 啟動(dòng)一個(gè)每秒執(zhí)行的定時(shí)任務(wù)
    $timerId = Timer::add(1, function () {
        echo "Running task at " . date('Y-m-d H:i:s') . "\n";
    });
    
    // 保存定時(shí)器 ID（用于后續(xù)操作）
    $worker->timerId = $timerId;
};
 
Worker::runAll();

// 停止單個(gè)定時(shí)任務(wù)
$timerId = Timer::add(2, function () { /* ... */ });
Timer::del($timerId);
 
// 停止所有定時(shí)任務(wù)
Timer::delAll(); // 慎用！會(huì)停止當(dāng)前進(jìn)程所有定時(shí)器
動(dòng)態(tài)停止示例
$worker->onMessage = function ($connection, $data) use ($worker) {
    // 收到特定指令時(shí)停止定時(shí)任務(wù)
    if ($data === 'stop') {
        Timer::del($worker->timerId);
        $connection->send("定時(shí)任務(wù)已停止");
    }
};

// 假設(shè) $oldTimerId 是已存在的定時(shí)器 ID
$newTimerId = Timer::add(5, function () { /* 新任務(wù)邏輯 */ });
Timer::del($oldTimerId); // 停止舊任務(wù)
 
// 或通過(guò)閉包動(dòng)態(tài)更新
$worker->onWorkerStart = function ($worker) {
    $worker->timerId = Timer::add(1, function () use ($worker) {
        static $count = 0;
        $count++;
        echo "執(zhí)行次數(shù): $count\n";
        
        // 達(dá)到條件后重啟任務(wù)（例如修改間隔時(shí)間）
        if ($count >= 5) {
            Timer::del($worker->timerId);
            $worker->timerId = Timer::add(2, function () { 
                echo "重啟后的任務(wù)\n"; 
            });
        }
    });
};

$worker->onWorkerStart = function ($worker) {
    if ($worker->id === 0) { // 僅第一個(gè)進(jìn)程執(zhí)行
        Timer::add(1, function () { /* ... */ });
    }
};

$httpWorker = new Worker('http://0.0.0.0:8080');
$httpWorker->onMessage = function ($connection, $request) {
    $action = $request->get('action');
    
    switch ($action) {
        case 'start':
            $timerId = Timer::add(1, function () { /* ... */ });
            $connection->send("定時(shí)任務(wù) ID: $timerId");
            break;
        case 'stop':
            $timerId = $request->get('timer_id');
            Timer::del($timerId);
            $connection->send("已停止任務(wù)");
            break;
    }
};

// 注冊(cè)自定義信號(hào)
Worker::$onMasterReload = function () {
    // 收到 SIGUSR1 信號(hào)時(shí)重啟某個(gè)任務(wù)
    Timer::del($oldTimerId);
    $newTimerId = Timer::add(3, function () { /* ... */ });
};

Timer::add(1, function () {
    try {
        // 業(yè)務(wù)邏輯
    } catch (Throwable $e) {
        echo "定時(shí)任務(wù)異常: " . $e->getMessage();
    }
});