php workerman定时任务的实现代码

use \Workerman\Worker;
use \Workerman\Lib\Timer;
require_once './Workerman/Autoloader.php';

$task = new Worker();
// 开启多少个进程运行定时任务，注意多进程并发问题
$task->count = 1;
$task->onWorkerStart = function($task)
{
  // 每2.5秒执行一次
  $time_interval = 2.5;
  Timer::add($time_interval, function()
  {
    echo "task run\n";
  });
};

// 运行worker
Worker::runAll();

require_once './Workerman/Autoloader.php';
use \Workerman\Worker;
use \Workerman\Lib\Timer;

// 普通的函数
function send_mail($to, $content)
{
  echo "send mail ...\n";
}

$task = new Worker();
$task->onWorkerStart = function($task)
{
  $to = 'workerman@workerman.net';
  $content = 'hello workerman';
  // 10秒后执行发送邮件任务，最后一个参数传递false，表示只运行一次
  Timer::add(10, 'send_mail', array($to, $content), false);
};

// 运行worker
Worker::runAll();

require_once './Workerman/Autoloader.php';
use \Workerman\Worker;
use \Workerman\Lib\Timer;

class Mail
{
  // 注意，回调函数属性必须是public
  public function send($to, $content)
  {
    echo "send mail ...\n";
  }
}

$task = new Worker();
$task->onWorkerStart = function($task)
{
  // 10秒后发送一次邮件
  $mail = new Mail();
  $to = 'workerman@workerman.net';
  $content = 'hello workerman';
  Timer::add(10, array($mail, 'send'), array($to, $content), false);
};

// 运行worker
Worker::runAll();

require_once './Workerman/Autoloader.php';
use \Workerman\Worker;
use \Workerman\Lib\Timer;

class Mail
{
  // 注意，回调函数属性必须是public
  public function send($to, $content)
  {
    echo "send mail ...\n";
  }

  public function sendLater($to, $content)
  {
    // 回调的方法属于当前的类，则回调数组第一个元素为$this
    Timer::add(10, array($this, 'send'), array($to, $content), false);
  }
}

$task = new Worker();
$task->onWorkerStart = function($task)
{
  // 10秒后发送一次邮件
  $mail = new Mail();
  $to = 'workerman@workerman.net';
  $content = 'hello workerman';
  $mail->sendLater($to, $content);
};

// 运行worker
Worker::runAll();

require_once './Workerman/Autoloader.php';
use \Workerman\Worker;
use \Workerman\Lib\Timer;

class Mail
{
  // 注意这个是静态方法，回调函数属性也必须是public
  public static function send($to, $content)
  {
    echo "send mail ...\n";
  }
}

$task = new Worker();
$task->onWorkerStart = function($task)
{
  // 10秒后发送一次邮件
  $to = 'workerman@workerman.net';
  $content = 'hello workerman';
  // 定时调用类的静态方法
  Timer::add(10, array('Mail', 'send'), array($to, $content), false);
};

// 运行worker
Worker::runAll();