<?php
date_default_timezone_set('PRC');

require './DelayTask.php';

$queue = Queue::instance('127.0.0.1', 6379, 'topnuomi');
for ($i = 0; $i < 10; $i++) {
    // 延迟任务
    $taskName = uniqid();
    $flag = $queue->addDelayTask('order', $taskName, 10);

    // 实时任务
    // $taskName = uniqid();
    // $flag     = $queue->addTask('order', json_encode([
    //     'name' => $taskName,
    // ], 256));
    if ($flag) {
        print '创建任务 ' . $i . ' [' . date('Y-m-d H:i:s') . ']' . PHP_EOL;
    }
}