PHPにおけるI/O多重化とyield

一般的にI/Oは遅い L1 cache reference 0.5 ns L2 cache reference 5 ns Main Memory reference 100 ns Send 1K bytes over 1Gbps network 10,000 ns 0.01 ms Read 4K randomly from SSD 150,000 ns 0.15 ms Round trip within same datacenter 500,000 ns 0.5 ms Read 1 MB sequentially from SSD 1,000,000 ns 1 ms Disk seek 10,000,000 ns 10 ms Read 1 MB sequentially from disk 20,000,000 ns 20 ms Send Packet CA-‐>Netherlands-‐>CA 150,000,000 ns 150 ms 出典：Latency Numbers Every Programmer Should Know (抜粋) https://gist.github.com/jboner/2841832 Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止 8

9.

10.

11.

12.

13.

14.

15.

16.

17.

18.

19.

20.

21.

22.

23.

24.

25.

26.

27.

28.

29.

30.

31.

32.

33.

34.

35.

echoサーバー var net = require('net'); var server = net.createServer(function(socket){ socket.write('Echo server\r\n'); socket.pipe(socket); }); server.listen(1337, '127.0.0.1'); Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止 35

36.

37.

38.

39.

40.

41.

[beta]

reactphpの例
<?php
require	
  'vendor/autoload.php';	
  
	
  
$app	
  =	
  function	
  ($request,	
  $response)	
  {	
  
	
  	
  	
  	
  $response-‐>writeHead(200,	
  ['Content-‐Type'	
  =>	
  'text/plain']);	
  
	
  	
  	
  	
  $response-‐>end("Hello	
  World\n");	
  
};	
  
	
  
$loop	
  =	
  React\EventLoop\Factory::create();	
  
$socket	
  =	
  new	
  React\Socket\Server($loop);	
  
$http	
  =	
  new	
  React\Http\Server($socket,	
  $loop);	
  
	
  
$http-‐>on('request',	
  $app);	
  
echo	
  "Server	
  running	
  at	
  http://127.0.0.1:1337\n";	
  
	
  
$socket-‐>listen(1337);	
  
$loop-‐>run();
Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止

41

42.

43.

44.

課題1 クロージャの構文 • PHPのクロージャ構文はかなり冗長 – function ~ use ~ return ~ – これを毎回書くのか… CoﬀeeScript x -> x + offset JavaScript function(x) { return x + offset; } PHP function($x) use(&$offset){ return $x + $offset; } Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止 44

45.

46.

47.

48.

49.

50.

51.

52.

C#の同期メソッド private void Button_Click(object sender, RoutedEventArgs e) { this.button.IsEnabled = false; Thread.Sleep(3000); this.button.IsEnabled = true; } (出典) .NET開発における⾮非同期処理理の基礎と歴史－＠IT http://www.atmarkit.co.jp/fdotnet/chushin/masterasync_01/masterasync_01_01.html Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止 52

53.

[beta]

C#の非同期メソッド
private	
  async	
  void	
  	
  
Button_Click(object	
  sender,	
  RoutedEventArgs	
  e)	
  
{	
  
	
  	
  	
  	
  this.button.IsEnabled	
  =	
  false;	
  
	
  	
  	
  	
  await	
  Task.Run(()	
  =>	
  Thread.Sleep(3000));	
  
	
  	
  	
  	
  this.button.IsEnabled	
  =	
  true;	
  
}	
  

(出典) .NET開発における⾮非同期処理理の基礎と歴史  －  ＠IT

http://www.atmarkit.co.jp/fdotnet/chushin/masterasync_01/masterasync_01_01.html

Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止

53

54.

55.

56.

57.

58.

59.

60.

61.

62.

通常の関数 function getWebapi($url) { $req = new HttpClient\Request($url); $res = $req-‐>send(); if ($res-‐>getStatusCode() >= 400) { throw new \RuntimeException($url); } return json_decode($res-‐>getBody()); } Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止 62

63.

非同期版の関数 function getWebapiAsync($url) { $req = new HttpClient\Request($url); $res = (yield $req); if ($res-‐>getStatusCode() >= 400) { throw new \RuntimeException($url); } yield json_decode($res-‐>getBody()); } Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止 63

64.

65.

66.

67.

68.

69.

70.

71.

72.

yieldのおさらい • 関数の処理を一時停止・再開できる機能ジェネレータの例例ジェネレータを実⾏行行するコード例例 function gen() { echo (yield 1); echo (yield 2); echo (yield 3); } $g = gen(); echo $g->current(); echo $g->send(4); echo $g->send(5); $g->send(6); Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止 72

73.

function gen() { echo (yield 1); echo (yield 2); echo (yield 3); } $g = gen(); ← ここから起動 (ジェネレータの準備) echo $g->current(); echo $g->send(4); echo $g->send(5); $g->send(6); Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止 73

74.

function gen() { echo (yield 1); echo (yield 2); echo (yield 3); } $g = gen(); echo $g->current(); echo $g->send(4); echo $g->send(5); $g->send(6); Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止 74

75.

function gen() { echo (yield 1); echo (yield 2); echo (yield 3); } $g = gen(); echo $g->current(); echo $g->send(4); echo $g->send(5); $g->send(6); 実行開始！ Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止 75

76.

function gen() { yieldが見つかったので… echo (yield 1); echo (yield 2); echo (yield 3); } $g = gen(); echo $g->current(); echo $g->send(4); echo $g->send(5); $g->send(6); Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止 76

77.

function gen() { echo (yield 1); (一時停止中) echo (yield 2); echo (yield 3); } $g = gen(); echo 1; echo $g->send(4); echo $g->send(5); 1 $g->send(6); Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止 77

78.

function gen() { echo (yield 1); (一時停止中) echo (yield 2); echo (yield 3); } $g = gen(); echo 1; echo $g->send(4); echo $g->send(5); 1 $g->send(6); Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止 78

79.

function gen() { echo (4); echo (yield 2); echo (yield 3); } $g = gen(); echo 1; echo $g->send(4); echo $g->send(5); $g->send(6); 14 Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止 79

80.

function gen() { echo (4); echo (yield 2); echo (yield 3); } $g = gen(); echo 1; echo $g->send(4); echo $g->send(5); $g->send(6); 14 Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止 80

81.

function gen() { echo (4); echo (yield 2); (一時停止中) echo (yield 3); } $g = gen(); echo 1; echo 2; echo $g->send(5); 142 $g->send(6); Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止 81

82.

function gen() { echo (4); echo (yield 2); (一時停止中) echo (yield 3); } $g = gen(); echo 1; echo 2; echo $g->send(5); 142 $g->send(6); Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止 82

83.

84.

85.

86.

87.

88.

89.

90.

91.

92.

93.

94.

95.

96.

97.

98.

その他の工夫 • 非同期関数内で別の非同期関数を呼ぶ – SplStackを使って対処 • 例外の伝搬 – Generator::throw()を使用する非常に参考にしました↓ Cooperative multitasking using coroutines (in PHP!) http://nikic.github.io/2012/12/22/Cooperative-multitasking-using-coroutines-in-PHP.html Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止 98

http://nikic.github.io/2012/12/22/Cooperative-multitasking-using-coroutines-in-PHP.html

99.

関数内で別の関数を呼ぶ //通常の関数 function a() { return b() . c(); } //非同期の関数 function aAsync() { yield (yield bAsync()) . (yield cAsync()); } Copyright (C) 2014 Yahoo Japan Corporation. All Rights Reserved. 無断引用・転載禁止 99

100.

101.

102.

103.

104.

PHPにおけるI/O多重化とyield

Yahoo!デベロッパーネットワーク

関連スライド

深層学習による自然言語処理入門: word2vecからBERT, GPT-3まで

ゼロから始める転移学習

ヤフーにおける WebAuthn と Passkey の UX の紹介と考察 #idcon #fidcon

OpenID Connectとネイティブアプリを取り巻く仕様と動向 Yahoo! JAPANの取り組み #openid #openid_tokyo

運用業務とスクラムは本当に組み合わせにくいのか︖運用業務が大半を占めるプロダクト開発での試行錯誤

ヤフーのオンプレ機械学習基盤AIPFについて #ml_kubernetes

各ページのテキスト