php workerman定时任务的实现代码(2)

namespace Task;
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('\Task\Mail', 'send'), array($to, $content), false);
};

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

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

$task = new Worker();
$task->onWorkerStart = function($task)
{
  // 计数
  $count = 1;
  // 要想$timer_id能正确传递到回调函数内部，$timer_id前面必须加地址符 &
  $timer_id = Timer::add(1, function()use(&$timer_id, &$count)
  {
    echo "Timer run $count\n";
    // 运行10次后销毁当前定时器
    if($count++ >= 10)
    {
      echo "Timer::del($timer_id)\n";
      Timer::del($timer_id);
    }
  });
};

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

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

class Mail
{
  public function send($to, $content, $timer_id)
  {
    // 临时给当前对象添加一个count属性，记录定时器运行次数
    $this->count = empty($this->count) ? 1 : $this->count;
    // 运行10次后销毁当前定时器
    echo "send mail {$this->count}...\n";
    if($this->count++ >= 10)
    {
      echo "Timer::del($timer_id)\n";
      Timer::del($timer_id);
    }
  }
}

$task = new Worker();
$task->onWorkerStart = function($task)
{
  $mail = new Mail();
  // 要想$timer_id能正确传递到回调函数内部，$timer_id前面必须加地址符 &
  $timer_id = Timer::add(1, array($mail, 'send'), array('to', 'content', &$timer_id));
};

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

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

$worker = new Worker();
$worker->count = 4;
$worker->onWorkerStart = function($worker)
{
  // 只在id编号为0的进程上设置定时器，其它1、2、3号进程不设置定时器
  if($worker->id === 0)
  {
    Timer::add(1, function(){
      echo "4个worker进程，只在0号进程设置定时器\n";
    });
  }
};
// 运行worker
Worker::runAll();