Swoole 协程使用注意事项

近期公司的项目需要，用Swoole搭建TCP服务器，过程中使用了Coroutine\Redis，以及Coroutine\Mysql,在第一个版本中为了节省TCP及Redis的连接数，协程的理解的不够深入，多个协程使用了同一个Redis及Mysql客户端，导致不同的协程之间发生了数据错乱。
在此简要分析如下:

简单数据类型:
$number = 1;
go(function () use(&$number) {
  Co::sleep(1);
  $number++;
  echo "In First Coroutine Number is:".$number;
});

$number++;
echo "In Main ".$number."\n";

go(function () use(&$number) {
  $number++;
  echo "In Second Coroutine Number is:".$number;
});

本来想获得顺序为

In First Coroutine Number is:2
In Main 3
In Second Coroutine Number is:4

运行此代码获得如下结果:

In Main 2
In Second Coroutine Number is:3
In First Coroutine Number is:4

示例很简单，但是展示了协程的乱序可能会导致的程序错误。
在调试过程中因为使用了单一连接客户端导致过:

Uncaught Swoole\Error: Socket#8 has already been bound to another coroutine

因此在swoole中使用协程时，一般使用协程客户端连接池。
示例代码如下:

/**
 * Class RedisPool
 */
class RedisPool
{
  protected $mAvailable;
  protected $mPool;
  protected $mConfig;

  public function __construct($config)
  {
    $this->mAvailable = true;
    $this->mPool = new SplQueue();
    $this->mConfig = $config;
  }

  public function push($redisClient)
  {
    if ($this->mAvailable) {
      $this->mPool->enqueue($redisClient);
    }
  }

  public function pop()
  {
    $redisClient = null;
    if ($this->mAvailable) {
      try {
        $redisClient = $this->mPool->dequeue();
      } catch (\RuntimeException $exception) {
        //队列中为空
        $redisClient = new RedisClient($this->mConfig);
        if (empty($redisClient) || $redisClient->connect()) {
          $redisClient = null;
        }
      }
    }
    return $redisClient;
  }

  public function isAvailable()
  {
    return $this->mAvailable;
  }

  public function setAvailable($available)
  {
    $this->mAvailable = $available;
  }


  public function __destruct()
  {
    // 连接池销毁, 置不可用状态, 防止新的客户端进入常驻连接池, 导致服务器无法平滑退出
    $this->mAvailable = false;
    while (!$this->mPool->isEmpty()) {
      $this->mPool->dequeue();
    }
  }

  public function __call($name, $arguments)
  {
    // TODO: Implement __call() method.
    if (!is_callable(array($this->mPool, $name))) {
      throw new BadFunctionCallException("Function Name:" . $name . " Args:" . implode(",", $arguments));
    }
    return call_user_func_array([$this->mPool, $name], $arguments);
  }

在协程中，从连接池中获取连接客户端，保证每个协程使用不同的连接