亚洲av成人无遮挡网站在线观看,少妇性bbb搡bbb爽爽爽,亚洲av日韩精品久久久久久,兔费看少妇性l交大片免费,无码少妇一区二区三区

Chinaunix

標(biāo)題: PHP yield 異步操作結(jié)合同步業(yè)務(wù)代碼例子 [打印本頁]
作者: songnuan    時間: 2015-07-14 09:58
標(biāo)題: PHP yield 異步操作結(jié)合同步業(yè)務(wù)代碼例子
看了 PHPCon 2015 上海站  司超的協(xié)程pdf有感而寫的一小片段代碼練練手，希望對大家了解yield有所幫助

[PHP]代碼
  1. <?php
  2. /*
  3. * yield 異步操作結(jié)合同步業(yè)務(wù)代碼例子
  4. * @author Corz<combo_k@126.com>
  5. */
  6. //業(yè)務(wù)同步代碼
  7. function syncCode()
  8. {
  9.     var_dump((yield ['dns', 'www.baidu.com']));
  10.     var_dump((yield ['lag', 200]));
  11.     var_dump((yield ['dns', 'www.taobao.com']));
  12.     var_dump((yield ['sql', 'show tables']));
  13. }
  14. //異步調(diào)用器
  15. function asyncCaller(Generator $gen)
  16. {
  17.     $r = $gen->current();
  18.     if (isset($r)) {
  19.         switch ($r[0]) {
  20.             case 'sql':
  21.                 AsyncMysql::getInstance()->query($r[1],
  22.                     function ($retval) use($gen) {
  23.                         $gen->send($retval);
  24.                         asyncCaller($gen);
  25.                     });
  26.                 break;
  27.             case 'dns':
  28.                 swoole_async_dns_lookup($r[1],
  29.                     function ($host, $ip) use($gen) {
  30.                         $gen->send([$host, $ip]);
  31.                         asyncCaller($gen);
  32.                     });
  33.                 break;
  34.             case 'lag':
  35.                 swoole_timer_after($r[1],
  36.                     function () use($gen, $r) {
  37.                         $gen->send('lag ' . $r[1] . 'ms');
  38.                         asyncCaller($gen);
  39.                     });
  40.                 break;
  41.             default:
  42.                 $gen->send('no method');
  43.                 asyncCaller($gen);
  44.                 break;
  45.         }
  46.     }
  47. }

  49. asyncCaller(syncCode());

  51. /**
  52. * 異步mysql類
  53. */
  54. class AsyncMysql
  55. {

  57.     /**
  58.      * @var mysqli
  59.      */
  60.     protected $db = null;

  62.     /**
  63.      * @var callable
  64.      */
  65.     protected $callable = null;

  67.     public static function getInstance()
  68.     {
  69.         static $instance = null;
  70.         return isset($instance) ? $instance : ($instance = new self());
  71.     }

  73.     public function __construct()
  74.     {
  75.         $this->db = new mysqli('127.0.0.1', 'root', '123456', 'mysql');
  76.         swoole_event_add(swoole_get_mysqli_sock($this->db), [$this, 'onQuery']);
  77.     }

  79.     public function onQuery($db_sock)
  80.     {
  81.         $res = $this->db->reap_async_query();
  82.         call_user_func($this->callable, $res->fetch_all(MYSQLI_ASSOC));
  83.     }

  85.     /**
  86.      * @param string    $sql
  87.      * @param callable  $callable
  88.      */
  89.     public function query($sql, callable $callable)
  90.     {
  91.         $this->callable = $callable;
  92.         $this->db->query($sql, MYSQLI_ASYNC);
  93.     }
  94. }
復(fù)制代碼




歡迎光臨 Chinaunix (http://72891.cn/) Powered by Discuz! X3.2