<?php
date_default_timezone_set('PRC');
ini_set('default_socket_timeout', -1);

require './DelayTask.php';

$queue = Queue::instance('127.0.0.1', 6379, 'topnuomi');
$queue->handleDelayTask('order', function ($value) {
    print '取出任务 ' . $value . ' [' . date('Y-m-d H:i:s') . ']' . PHP_EOL;
});
// $queue->handleTask('order', function ($value) {
//     print '执行任务 ' . $value . ' [' . date('Y-m-d H:i:s') . ']' . PHP_EOL;
//     // TODO 执行具体逻辑
//     // sleep(2);
// });