21 lines
523 B
PHP
21 lines
523 B
PHP
<?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;
|
|
}
|
|
}
|