Atomic

    使用方式

    1. use \Imi\Util\AtomicManager;
    3. // 获取 Swoole\Atomic 对象
    4. $atomic = AtomicManager::getInstance('name1');
    6. // 加1，返回结果
    7. $number = AtomicManager::::add('name1');
    9. // 加10，返回结果
    10. $number = AtomicManager::::add('name1', 10);
    12. // 减1，返回结果
    13. $number = AtomicManager::::sub('name1');
    15. // 减10，返回结果
    16. $number = AtomicManager::::sub('name1', 10);
    17. // 获取当前值
    18. $number = AtomicManager::get('name1');
    20. // 设置当前值为100
    21. AtomicManager::get('name1', 100);
    23. // -----------------------------------------------
    25. // 如果当前数值等于100返回true，并将当前数值设置为1
    26. // 如果当前数值不等于100返回false
    27. $number = AtomicManager::cmpset('name1', 100, 1);
    29. /**
    30.  * 当原子计数的值为0时程序进入等待状态。另外一个进程调用wakeup可以再次唤醒程序。底层基于Linux Futex实现，使用此特性，可以仅用4字节内存实现一个等待、通知、锁的功能。
    31.  * 超时返回false，错误码为EAGAIN，可使用swoole_errno函数获取
    32.  * 成功返回true，表示有其他进程通过wakeup成功唤醒了当前的锁
    33.  * 使用wait/wakeup特性时，原子计数的值只能为0或1，否则会导致无法正常使用
    34.  * 当然原子计数的值为1时，表示不需要进入等待状态，资源当前就是可用。wait函数会立即返回true
    35.  * @param float $timeout 指定超时时间，默认为-1，表示永不超时，会持续等待直到有其他进程唤醒
    36.  * @return bool
    37.  */
    38. $result = AtomicManager::wait('name1');
    39. // 超时时间100毫秒
    40. $result = AtomicManager::wait('name1', 0.1);
    42. /**
    43.  * 唤醒处于wait状态的其他进程。
    44.  * 当前原子计数如果为0时，表示没有进程正在wait，wakeup会立即返回true
    45.  * 当前原子计数如果为1时，表示当前有进程正在wait，wakeup会唤醒等待的进程，并返回true
    46.  * 如果同时有多个进程处于wait状态，$n参数可以控制唤醒的进程数量
    47.  * 被唤醒的进程返回后，会将原子计数设置为0，这时可以再次调用wakeup唤醒其他正在wait的进程
    48.  * @param string $name 原子计数对象名称
    49.  * @param integer $n
    50.  * @return void
    51.  */
    52. AtomicManager::wakeup('name1'); // 第二个参数我也不知道干嘛的，swoole文档没写