Atomic

基于 Swoole 提供的 Swoole\Atomic，直接在配置文件中设置，就可以在worker进程中使用，数据互通。

使用时无需加锁！

配置方式

在项目配置文件中加入以下节

  1. 'atomics'    =>    [
  2.     // 定义名为name1的，初始值为0
  3.     'name1',
  4.     // 定义名为name2的，初始值为10
  5.     'name2'    =>    10,
  6. ],

使用方式

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