m6w6/atick

该包已被放弃且不再维护。未建议替代包。

异步资源处理，可选地使用（或滥用）tick

维护者

详细信息

github.com/m6w6/atick

主页

源代码

问题

安装: 6

依赖: 0

建议者: 0

安全: 0

星星: 1

关注者: 1

分支: 0

开放问题: 0

dev-master 2013-11-25 10:51 UTC

BSD-2-Clause cfdc2a4f455430fd2f74f8d27bc45d702995fd7d

  • Michael Wallner <mike.woop@php.net>

asyncresourcetick

This package is auto-updated.

Last update: 2020-02-10 15:41:40 UTC

README

Build Status

异步资源处理，可选地（滥用）使用tick。

使用tick的示例

declare(ticks=1);

$conn = new \pq\Connection;
$conn->execAsync("SELECT * FROM foo", function ($rs) {
    var_dump($rs);
});

$ticker = new \atick\Ticker;
$ticker->register();
$ticker->read($conn->socket, function($fd) use ($conn) {
    $conn->poll();
    if ($conn->busy) {
        return false;
    }
    $conn->getResult();
    return true;
});

while (count($ticker));

不使用tick的示例

$conn = new \pq\Connection;
$conn->execAsync("SELECT * FROM foo", function ($r) {
    var_dump($r);
});

$ticker = new \atick\Ticker;
$ticker->read($conn->socket, function($fd) use ($conn) {
    $conn->poll();
    if ($conn->busy) {
        return false;
    }
    $conn->getResult();
    return true;
});

while($ticker());