ruziyi/easy-task

a library for async task

EasyTask

基于swoole的任务队列, _(*1)

可多进程并发执行, 主进程监听多个任务进程, 任务进程挂掉会被主进程自动拉起, _(*2)

install

使用composer: composer require ruziyi/easy-task:dev-master, _(*3)

手动引入: include include 'Loader.php', _(*4)

example

创建task, 把要实现的业务逻辑放到run方法里, _(*5)

class EchoTask extends EasyTask\Task
{
    private $msg;

    public function __construct($msg)
    {
        parent::__construct();
        $this->msg = $msg;
    }

    public function run()
    {
        echo $this->msg;
    }
}

触发任务, _(*6)

$task = (new EasyTask\EchoTask("hehe\n"))->after(1000);
(new EasyTask\queue\RedisQueue)->putTask($task);

创建任务消费进程文件server.php, _(*7)

$taskProcess = new EasyTask\TaskProcess();
$taskProcess->run();

启动任务消费进程, _(*8)

php server.php

例子

//立即执行
$task = (new EasyTask\EchoTask("hehe\n"));
//3分钟后执行
$task = (new EasyTask\EchoTask("hehe\n"))->at(strtotime('+3 minute'));
//延迟1000ms立即执行
$task = (new EasyTask\EchoTask("hehe\n"))->after(1000);
//每1000ms执行一次, 共执行5次。不设置次数, 则一直重复执行
$task = (new EasyTask\EchoTask("hehe\n"))->every(1000, 5);
//1000ms后, 每1000ms执行一次, 共执行5次。不设置次数, 则一直重复执行
$task = (new EasyTask\EchoTask("hehe\n"))->after(1000)->every(1000, 5);

(new EasyTask\queue\RedisQueue)->putTask($task);