easyswoole/job-queue

Coroutine version of Memcache client

1.0.1 2020-03-05 03:09 UTC

This package is auto-updated.

Last update: 2024-11-05 13:21:10 UTC


README

可以方便用户快速搭建多协程分布式任务处理队列

class Queue implements \EasySwoole\JobQueue\QueueDriverInterface{

    function pop(float $timeout = 3): ?\EasySwoole\JobQueue\AbstractJob
    {
        
        return null;
    }

    function push(\EasySwoole\JobQueue\AbstractJob $job): bool
    {
        return true;
    }
}

$queue = new \EasySwoole\JobQueue\JobQueue(new Queue());

$http = new swoole_http_server("127.0.0.1", 9501);
$queue->attachServer($http);

$http->on("request", function ($request, $response) {
    $response->header("Content-Type", "text/plain");
    $response->end("Hello World\n");
});

$http->start();