Coro+Furl - gfx's gist: 665488 — GistYou signed in with another tab or window. Reload to refresh your session. You signed out in another tab or window. Reload to refresh your session. You switched accounts on another tab or window. Reload to refresh your session. Dismiss alert
Coroã§ã‚¹ãƒ¬ãƒƒãƒ‰ãƒ—ールを使ㆠ- Pixel Pedals of Tomakomai
Coroã§ã‚¹ãƒ¬ãƒƒãƒ‰ãƒ—ールを使ã†ã«ã¯async_poolを使ãˆã°ã„ã„ã¯ãšãªã®ã§ã™ãŒã€ä½•ã‚‚考ãˆãšã«ä½¿ã†ã¨ã†ã¾ãã„ã‹ãªã„å ´åˆãŒã‚ã‚Šã¾ã™ã€‚ 最åˆã«ã¾ã¨ã‚ é•·ã„ã®ã§ã¾ãšã¾ã¨ã‚ã¨ãã¾ã™ã€‚ã¾ã¨ã‚ã‚‹ã¨å˜ç´”ãªè©±ã§ã€ã€Œasync_poolを使ã†æ™‚ã«ã¯ã€åŒæ™‚ã«ãŸãã•ã‚“ã®ã‚¹ãƒ¬ãƒƒãƒ‰ã‚’利用ã—éŽãŽãªã„よã†ã«æ°—ã‚’ã¤ã‘ã‚‹ã€ã®ä¸€ç‚¹ã«å°½ãã¾ã™ã€‚ ベンãƒãƒžãƒ¼ã‚¯ã‚’ã¨ã£ã¦ã¿ã‚‹ asyncã¨async_pool ã§ãƒ™ãƒ³ãƒãƒžãƒ¼ã‚¯ã‚’ã¨ã£ã¦ã¿ã‚‹ã¨ã€ä»¥ä¸‹ã®ã‚ˆã†ã«ãªã‚Šã¾ã™ã€‚ my $tasks = 100; Benchmark::cmpthese 1000, { async => sub { my $sem = Coro::Semaphore->new( 1 - $tasks ); for(1 .. $tasks){ async { $sem->up }; } $sem->down; }, async_pool => sub { my $sem
Coroã¨AnyEventを一緒ã«ä½¿ã†ãªã‚‰unblock_subを覚ãˆã¦ãŠãã¹ã - Pixel Pedals of Tomakomai
以å‰ã«ã€ ãªãŠã€(2)ã§ãƒ•ãƒãƒ³ãƒˆã‚¨ãƒ³ãƒ‰ã®å‡¦ç†ã‚’書ã時ã¯(0)ã®ãƒãƒƒã‚¯ã‚¨ãƒ³ãƒ‰ã¨ã¯é€†ã«ã€AnyEventã¯ç›´æŽ¥ä½¿ã‚ãªã„æ–¹ãŒç„¡é›£ã ã¨æ€ã„ã¾ã™ã€‚ç†ç”±ã¯ã€AnyEventã®ã‚¤ãƒ™ãƒ³ãƒˆãƒ«ãƒ¼ãƒ—ã‹ã‚‰ã¯Coroã®å±¤ã®é–¢æ•°ãŒä½¿ãˆãªã„ã‹ã‚‰ã§ã™ã€‚ Coro::AnyEventã§ãƒ•ãƒãƒ³ãƒˆã‚¨ãƒ³ãƒ‰ã‚’コールãƒãƒƒã‚¯ã‚’使ã‚ãšã«æ›¸ã ãªã‚“ã¦æ›¸ã„ã¦ãŸã®ã§ã€å¤šå°‘追記を。 Coroã¨AnyEventã®ç›¸æ€§ ã“ã‚Œã¯ã€éžå¸¸ã«ã‚ˆã„ã§ã™ã€‚ Coro㯠use Coro::AnyEvent ã¨ã‹æ˜Žç¤ºçš„ã«ã—ãªãã¦ã‚‚ã€å†…部ã§AnyEventを使ã£ã¦ã„ã¾ã™ã€‚例ãˆã°ã€Coro::Timer::sleepã¯åˆ¶å¾¡ã‚’他スレッドã«æ¸¡ã—ã¦ãã®å¾Œè‡ªåˆ†ã®ã‚¹ãƒ¬ãƒƒãƒ‰ã«æˆ»ã£ã¦ãã‚‹ã¨ã„ã†å‹•ãã‚’ã—ã¾ã™ãŒã€ã“ã®ã€Œè‡ªåˆ†ã®ã‚¹ãƒ¬ãƒƒãƒ‰ã«æˆ»ã£ã¦ãã‚‹ã€ã¨ã„ã†å‹•ä½œã‚’ã€AnyEventã®ã‚¤ãƒ™ãƒ³ãƒˆãƒ«ãƒ¼ãƒ—ã«é ã‘ãŸã‚³ãƒ¼ãƒ«ãƒãƒƒã‚¯ã‹ã‚‰è‡ªã‚¹ãƒ¬ãƒƒãƒ‰ã®readyを呼んã§èµ·ã“ã—ã¦ã‚‚らã†ã“ã¨ã§å®Ÿç¾ã—ã¦ã„ã¾ã™ã€‚ C
Coro 㨠Go ã§ä¸¦åˆ—実行数ã®åˆ¶å¾¡ - 酒日記 ã¯ã¦ãªæ”¯åº—
http://d.hatena.ne.jp/tokuhirom/20090710/1247196134 ã“ã® Coro ã®ä¾‹ã‚’ Go ã§ã‚„ã£ã¦ã¿ã¾ã™ã€‚ ã¾ãšç‰¹å®šæ•° (ã“ã“ã§ã¯ 3) ã® worker thread ã‚’ç«‹ã¡ä¸Šã’ã¦ãŠã„ã¦ã€ãã“ã«ãƒ¡ãƒƒã‚»ãƒ¼ã‚¸ã‚’é€ã£ã¦ä»•äº‹ã•ã›ã‚‹ãƒ¢ãƒ‡ãƒ«ã€‚メッセージã®ã‚„ã‚Šã¨ã‚Šã« Coro::Channel を使ã„ã¾ã™ã€‚ use Coro; use Coro::Channel; use Coro::Timer; my $ch = Coro::Channel->new; sub worker { while (1) { my $url = $ch->get; printf("worker(%d): %s\n", $_[0], $url); Coro::Timer::sleep(1); } } my @coros = ( async { worker(1) }, async
ãŠã•ã‹ãªãƒ©ãƒœ - Coroã§ã‚ˆã‚Šè³¢ã„éžåŒæœŸã‚¯ãƒãƒ¼ãƒ©ã‚’作る
å‰å›žã®ã‚¨ãƒ³ãƒˆãƒªã§ã¯ç°¡å˜ãªã‚¯ãƒãƒ¼ãƒ©ã®ä½œã‚Šæ–¹ã‚’説明ã—ãŸã€‚ã—ã‹ã—ã“ã®ã‚¯ãƒãƒ¼ãƒ©ã«ã¯æ¬ 点ãŒã‚ã‚Šã€å–å¾—ã—ãŸã„URLãŒä½•åƒä½•ä¸‡ã¨ã‚ã‚‹å ´åˆã€ä¸€åº¦ã«http_getãŒèµ°ã£ã¦ã—ã¾ã„ã€ãƒªã‚½ãƒ¼ã‚¹ã‚’使ã„切ã£ãŸã‚ŠåŒã˜ã‚µãƒ¼ãƒãƒ¼ã¸ã®ã‚¢ã‚¯ã‚»ã‚¹ã‚’å¾…ã¤é–“ã«ã‚¿ã‚¤ãƒ アウトã—ãŸã‚Šã¨éƒ½åˆãŒæ‚ªã‹ã£ãŸã€‚ãã“ã§ä»Šå›žã¯AnyEventã«åŠ ãˆCoroを使ã†ã“ã¨ã«ã‚ˆã‚Šã€ä¸¦åˆ—を使ã£ã¦ãƒªã‚½ãƒ¼ã‚¹ã¸ã®åŒæ™‚アクセス制é™ã‚’è¡Œã†ã‚¯ãƒãƒ¼ãƒ©ã®æ›¸ã方を解説ã™ã‚‹ã€‚ ã“ã‚Œã¯å‰å›žã®ã‚¨ãƒ³ãƒˆãƒªã®æ”¹è‰¯ç‰ˆã«ãªã‚‹ã®ã§ã€åˆã‚ã¦ã“れをèªã‚€æ–¹ã¯å½“該エントリを先ã«èªã‚“ã§é ‚ããŸã„。 ã¾ãšã€å‰å›žã¯AnyEventを使ã„ã€condvarã¨send-recvを使ã£ã¦ã‚¤ãƒ™ãƒ³ãƒˆã®ç›£è¦–ã‚’ã—ã¦ã„ãŸãŒã€Coroã¨åŒæ™‚ã«ä½¿ã†å ´åˆã“ã‚Œã§ã¯éƒ½åˆãŒæ‚ªã„。イベントループを回ã™å ´åˆã€ä¸€èˆ¬çš„ã«AnyEventã¯recvã‚’ã€Coroã¯joinを使ã†ãŒã€ã“れらã¯ã©ã¡ã‚‰ã‚‚イベントループãŒçµ‚ã‚ã‚‹ã¾ã§ãƒ–ãƒãƒƒã‚¯ã™ã‚‹ã®ã§ã©ã¡ã‚‰ã‹ã—
Coro::AnyEventã§ãƒ•ãƒãƒ³ãƒˆã‚¨ãƒ³ãƒ‰ã‚’コールãƒãƒƒã‚¯ã‚’使ã‚ãšã«æ›¸ã - Pixel Pedals of Tomakomai
Coro::AnyEventを使ã†ã¨ã€ç¶™ç¶šæ¸¡ã—スタイルを使ã‚ãšã«éžåŒæœŸã‚’書ãã“ã¨ãŒã§ãã¾ã™*1。 ã¨ã„ã†ã“ã¨ã§ã€è©¦ã—ã«ã‚„ã£ã¦ã¿ã¾ã—ãŸã€‚ 最åˆã«ã¾ã¨ã‚ AnyEventã®å±¤ã‚’作りã€ãã®ä¸Šã«Coroã®å±¤ã‚’é‡ãã¦ã€ãƒ•ãƒãƒ³ãƒˆã‚¨ãƒ³ãƒ‰ã‹ã‚‰ã¯Coroã®å±¤ã ã‘使ã†ã¨ã‚ã‹ã‚Šã‚„ã™ã„アプリãŒã§ãã‚‹ã‚“ã˜ã‚ƒãªã„ã‹ãªã‚ã¨æ€ã„ã¾ã™ã€‚ (0) AnyEventã®APIを作る ã¾ãšã€AnyEventã§ãƒ•ãƒãƒ³ãƒˆã‚¨ãƒ³ãƒ‰ã®ãŸã‚ã®æ料を作りã¾ã™ã€‚é ‘å¼µã£ã¦ã‚³ãƒ¼ãƒ«ãƒãƒƒã‚¯ã‚’使ã£ã¦éžåŒæœŸå‡¦ç†ã‚’書ã„ã¦ä¸‹ã•ã„。åå‰ç©ºé–“ã¯AnyEvent::çš„ãªä½•ã‹ã«ã™ã‚‹ã¨ã„ã„ã¨æ€ã„ã¾ã™ã€‚ã¾ãŸã€ãŸã¶ã‚“ã“ã®æ®µéšŽã§ã¯ã¾ã Coro::AnyEventã¯ä½¿ã‚ãªã„æ–¹ãŒç„¡é›£ã§ã™ã€‚ピュアAnyEventã®æ–¹ãŒä½¿ã„回ã—ãŒåŠ¹ãã¾ã™ã—。 ã“ã“ã§ã¯ã€AnyEvent::HTTPã‚’é¡Œæã«ã—ã¾ã™ã€‚ãƒãƒƒã‚¯ã‚¨ãƒ³ãƒ‰ã¨ã—ã¦ã™ã§ã«AnyEvent::HTTPã¯ä½¿ãˆã‚‹ã‚‚ã®ã¨ã—ã¾ã™ã€‚ (1) Cor
Coro 㧠Executor/CompletionService - ã¯ã“ã¹ã«ã£ã ♨
Java並行処ç†ãƒ—ãƒã‚°ãƒ©ãƒŸãƒ³ã‚° ―ãã®ã€ŒåŸºç›¤ã€ã¨ã€Œæœ€æ–°APIã€ã‚’究ã‚る― ã‚’ã±ã‚‰ã±ã‚‰ã‚ãã£ã¦ã„ã¦å‡ºã¦ããŸã€ä»¥ä¸‹äºŒã¤ã‚’Coroã§å®Ÿè£…ã—ã¦ã¿ãŸã€‚ 並行処ç†ã‚¿ã‚¹ã‚¯ã®å®Ÿè¡Œæ–¹æ³•ã‚’抽象化ã—㟠Executor タスクã®ç”Ÿæˆã¨ãã®æ¶ˆè²»ã‚’分離ã™ã‚‹ CompletionService 実装ã¨ã‹ä¾‹ã¨ã‹ãºãŸãºãŸè²¼ã£ã¦ãŸã‚‰ã™ã”ã„é•·ããªã£ã¡ã£ãŸã€‚ gistã«ã‚‚ã‚ã‚Šã¾ã™ > http://gist.github.com/191924 。 ã¾ã¨ã‚ (é•·ã„ã®ã§å…ˆã«çµè«–) Executorã‚„CompletionServiceã®ã‚ˆã†ãªãƒ‘ターンã«ãã£ã¦ãƒ—ãƒã‚°ãƒ©ãƒ ã‚’ã‹ãã¨ã€ã™ã£ãã‚Šã¨ä¸¦è¡Œå‡¦ç†ãƒ—ãƒã‚°ãƒ©ãƒ を構æˆã§ãã¦è‰¯ã„æ„Ÿã˜ã€‚Coroã§ã‚‚ç°¡å˜ã«å®Ÿè£…ã§ãる。 ã“ã‚Œã¾ã§ã‚„られãŸã“ã¨ã«åå‰ã‚’付ã‘ãŸã ã‘ã¨ã„ã†è©±ã‚‚ã‚ã‚‹ã‘ã©ã€åå‰ã‚’ã¤ã‘ã¦åŒºåˆ¥ã—ã¦ç†è§£ã—ã¦ãŠãã¨ã€ã‚³ãƒ¼ãƒ‰èªã‚€ã¨ãã®æ€è€ƒãŒæ•´ç†ã•ã‚Œã¦è‰¯ã„ã¨ãŠã‚‚ã†ã€‚ Executor Executorã¨
ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—ã®çµ‚了日を2020å¹´1月31æ—¥(金)ã«æ±ºå®šã—ã¾ã—㟠- ã¯ã¦ãªã®å‘ŠçŸ¥
ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—ã®çµ‚了日を2020å¹´1月31æ—¥(金)ã«æ±ºå®šã—ã¾ã—㟠以下ã®ã‚¨ãƒ³ãƒˆãƒªã®é€šã‚Šã€ä»Šå¹´æœ«ã‚’目処ã«ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—を終了予定ã§ã‚る旨をãŠçŸ¥ã‚‰ã›ã—ã¦ãŠã‚Šã¾ã—ãŸã€‚ 2019年末を目処ã«ã€ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—ã®æ供を終了ã™ã‚‹äºˆå®šã§ã™ - ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—日記 ã“ã®ãŸã³ã€æ£å¼ã«çµ‚了日を決定ã„ãŸã—ã¾ã—ãŸã®ã§ã€ä»¥ä¸‹ã®é€šã‚Šã”確èªãã ã•ã„。 終了日: 2020å¹´1月31æ—¥(金) エクスãƒãƒ¼ãƒˆå¸Œæœ›ç”³è«‹æœŸé™:2020å¹´1月31æ—¥(金) 終了日以é™ã¯ã€ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—ã®é–²è¦§ãŠã‚ˆã³æŠ•ç¨¿ã¯è¡Œãˆã¾ã›ã‚“。日記ã®ã‚¨ã‚¯ã‚¹ãƒãƒ¼ãƒˆãŒå¿…è¦ãªæ–¹ã¯ä»¥ä¸‹ã®è¨˜äº‹ã«ã—ãŸãŒã£ã¦æ‰‹ç¶šãã‚’ã—ã¦ãã ã•ã„。 ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—ã«æŠ•ç¨¿ã•ã‚ŒãŸæ—¥è¨˜ãƒ‡ãƒ¼ã‚¿ã®ã‚¨ã‚¯ã‚¹ãƒãƒ¼ãƒˆã«ã¤ã„㦠- ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—日記 ã”利用ã®ã¿ãªã•ã¾ã«ã¯ã”迷惑をãŠã‹ã‘ã„ãŸã—ã¾ã™ãŒã€ã©ã†ãžã‚ˆã‚ã—ããŠé¡˜ã„ã„ãŸã—ã¾ã™ã€‚ 2020-06-25 追記 ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—日記ã®ã‚¨ã‚¯ã‚¹ãƒãƒ¼ãƒˆãƒ‡ãƒ¼ã‚¿ã¯2020å¹´2月28
ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—ã®çµ‚了日を2020å¹´1月31æ—¥(金)ã«æ±ºå®šã—ã¾ã—㟠- ã¯ã¦ãªã®å‘ŠçŸ¥
ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—ã®çµ‚了日を2020å¹´1月31æ—¥(金)ã«æ±ºå®šã—ã¾ã—㟠以下ã®ã‚¨ãƒ³ãƒˆãƒªã®é€šã‚Šã€ä»Šå¹´æœ«ã‚’目処ã«ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—を終了予定ã§ã‚る旨をãŠçŸ¥ã‚‰ã›ã—ã¦ãŠã‚Šã¾ã—ãŸã€‚ 2019年末を目処ã«ã€ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—ã®æ供を終了ã™ã‚‹äºˆå®šã§ã™ - ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—日記 ã“ã®ãŸã³ã€æ£å¼ã«çµ‚了日を決定ã„ãŸã—ã¾ã—ãŸã®ã§ã€ä»¥ä¸‹ã®é€šã‚Šã”確èªãã ã•ã„。 終了日: 2020å¹´1月31æ—¥(金) エクスãƒãƒ¼ãƒˆå¸Œæœ›ç”³è«‹æœŸé™:2020å¹´1月31æ—¥(金) 終了日以é™ã¯ã€ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—ã®é–²è¦§ãŠã‚ˆã³æŠ•ç¨¿ã¯è¡Œãˆã¾ã›ã‚“。日記ã®ã‚¨ã‚¯ã‚¹ãƒãƒ¼ãƒˆãŒå¿…è¦ãªæ–¹ã¯ä»¥ä¸‹ã®è¨˜äº‹ã«ã—ãŸãŒã£ã¦æ‰‹ç¶šãã‚’ã—ã¦ãã ã•ã„。 ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—ã«æŠ•ç¨¿ã•ã‚ŒãŸæ—¥è¨˜ãƒ‡ãƒ¼ã‚¿ã®ã‚¨ã‚¯ã‚¹ãƒãƒ¼ãƒˆã«ã¤ã„㦠- ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—日記 ã”利用ã®ã¿ãªã•ã¾ã«ã¯ã”迷惑をãŠã‹ã‘ã„ãŸã—ã¾ã™ãŒã€ã©ã†ãžã‚ˆã‚ã—ããŠé¡˜ã„ã„ãŸã—ã¾ã™ã€‚ 2020-06-25 追記 ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—日記ã®ã‚¨ã‚¯ã‚¹ãƒãƒ¼ãƒˆãƒ‡ãƒ¼ã‚¿ã¯2020å¹´2月28
Coro::State - ç¾åœ¨ã®å®Ÿè¡ŒçŠ¶æ…‹ã‚’ä¿å˜ã—ã¦ãŠã‘ã‚‹ç®± - Rintaro日記
Coroã£ã¦ã„ã†ãƒ¢ã‚¸ãƒ¥ãƒ¼ãƒ«ãŒã‚ã‚Šã¾ã™ã€‚Coroutine ã£ã¦ã„ã†æ¦‚念をç†è§£ã—ã¦ãªã„ã®ã‚‚ã‚り〠dmakiã•ã‚“ã®è¨˜äº‹ã§ã€ãªã‚“ã¨ãªã〠éžåŒæœŸã§ã„ã‚ã„ã‚出æ¥ã‚‹ã‚ˆã†ã«ãªã‚‹ãƒ¢ã‚¸ãƒ¥ãƒ¼ãƒ«ãªã‚“ã ã‚ã†ãªã€ã£ã¦ã„ã†ãらã„ã«ã—ã‹è€ƒãˆã¦ ç„¡ã‹ã£ãŸã‚“ã§ã™ãŒã€æœ¬è³ªçš„ã«ã¯ã¡ã‚‡ã£ã¨ã‚¤ãƒ¡ãƒ¼ã‚¸ãŒé•ã£ãŸã£ã½ã„ã£ã™ã€‚ 全然間é•ã£ã¦ã„ã‚‹ã‹ã‚‚ã ã‘ã©ã€ç¾åœ¨ã®åƒ•ã®ç†è§£ã‚’書ã„ã¦ã¿ã¾ã™ã€‚ Coro.pm ã®ã‚½ãƒ¼ã‚¹ã‚’見ã¦ã‚‹ã¨ã€Coro::Stateをベースクラスã«ã—ã¦ã¾ã™ã€‚ ã“ã®Coro::Stateã€ãƒ‰ã‚ュメントèªã‚“ã§ã¦ã‚‚英語ãŒä¸å¾—æ„ãªã›ã„ã‚‚ã‚ã‚Šã€ã‚ˆã分ã‹ã‚‰ãªã‹ã£ãŸã‚“ã§ã™ãŒã€ ã„ã‚ã„ã‚ã„ã˜ã£ã¦ã‚‹ã†ã¡ã«ã€ãªã‚“ã¨ãªãã€ã€Œç¾åœ¨ã®å®Ÿè¡ŒçŠ¶æ…‹ï¼ˆãƒ¬ã‚シカル変数やã€é–¢æ•°ã‚¹ã‚¿ãƒƒã‚¯ï¼‰ã‚’ä¿å˜ ã—ã¦ãŠã‘ã‚‹ç®±ã€ã£ã¦ã„ã†ã®ãŒè¦‹ãˆã¦ãã¾ã—ãŸã€‚ ã¨ã„ã£ã¦ã‚‚æ„味分ã‹ã‚‰ãªã„ã£ã™ã。 ã¨ã‚Šã‚ãˆãšã‚µãƒ³ãƒ—ルコード use Coro::State; $::main = Coro:
Coro ã¨ã¯çµå±€ãªã‚“ã ã£ãŸã®ã‹ - tokuhirom's blog
Coro 㯠first class ã® co-routine を実装ã—よã†ã¨ãŠã‚‚ã£ã¦é–‹ç™ºã—ã¦ãŸã‚‰ã€ã€Œã‚ã‚Œã€ã“ã‚Œ co-operative thread ã«ã§ãã‚‹ã®ã§ã¯?ã€ã¨ãŠã‚‚ã„ã¯ã˜ã‚ãŸã‚ã‘ãªã®ã§ã‚ã‚Šã€ãã†ã—ã¦ã¿ãŸã¨ã„ã†ã“ã¨ãªã®ã§ã‚ã£ãŸã€‚ Coro 㯠co-operative thread ãªã‚ã‘ã§ã‚ã‚‹ãŒã€ä»¥ä¸‹ã®ã‚ˆã†ã«ã™ã‚‹ã¨ã€æ™‚é–“ã”ã¨ã«ã‚¹ãƒ¬ãƒƒãƒ‰ã‚’スイッãƒã§ãã‚‹ã‚ã‘ãªã®ã§ã‚り。一定時間ã”ã¨ã« cede; ã—ã¦ã‚‹ã¨ã„ã†ã“ã¨ãªã®ã§ã‚る。CPU インテンシブãªå‡¦ç†ã®æœ€ä¸ã§ cede 書ãã®ãŒé¢å€’ãªå ´åˆã«ã¯ã“ã‚ŒãŒæœ‰ç”¨ãªã®ã ã‚ã†ã¨ãŠã‚‚ã†ã®ã§ã‚ã‚‹(see Coro.pm)。 # "timeslice" the given block sub timeslice(&) { use Time::HiRes (); Coro::on_enter { # on entering the thread, we
Coro and AnyEvent as good friend - tokuhirom's blog
Coro → AnyEventCoro 㯠AnyEvent ã«ä¾å˜ã—ã¦ã„ã‚‹(requires 扱ã„)。 Coro 㯠ファイル/ソケット/etc ã® èªã¿ã“ã¿/書ãè¾¼ã¿å¾…ã¡ ã®ã¨ãタイマを稼åƒã•ã›ã‚‹ã¨ããªã©ã« AnyEvent を内部的ã«ã¤ã‹ã£ã¦ã„る。 ãŸã ã—ã€Coro を純粋㫠co-routine ã¨ã—ã¦ã¤ã‹ã†å ´åˆã«ã¯ Coro::AnyEvent ã¯å¿…è¦ãªã„ã§ã™ã€‚async { }->join() ã™ã‚‹ã ã‘ãªã‚‰å¿…è¦ãªã„。 ãŸã ã€Coro::* ç³»ã®ãƒ¢ã‚¸ãƒ¥ãƒ¼ãƒ«ã¯ãŸã„ãŒã„㌠Coro::AnyEvent ã¤ã‹ã£ã¦ã‚‹ã®ã§ã€co-routine ã¨ã—ã¦ã¤ã‹ã†å ´åˆã«ã¯ AnyEvent ãŒã»ã¨ã‚“ã©å¿…é ˆã ã¨ãŠã‚‚ã£ã¦ã¾ã¡ãŒã„ãªã„ã§ã™ã¾ã™ã€‚ AnyEvent → CoroAnyEvent をイベントフレームワークã¨ã—ã¦ã¤ã‹ã†ã ã‘ãªã‚‰ã°ã€Coro ã‚’ã¤ã‹ã†å¿…è¦ã¯ãªãã€å˜ä½“ã§åˆ©ç”¨å¯èƒ½ã€‚å˜ä½“ãªã‚‰ã°ä¾å˜ãƒ¢
ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—ã®çµ‚了日を2020å¹´1月31æ—¥(金)ã«æ±ºå®šã—ã¾ã—㟠- ã¯ã¦ãªã®å‘ŠçŸ¥
ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—ã®çµ‚了日を2020å¹´1月31æ—¥(金)ã«æ±ºå®šã—ã¾ã—㟠以下ã®ã‚¨ãƒ³ãƒˆãƒªã®é€šã‚Šã€ä»Šå¹´æœ«ã‚’目処ã«ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—を終了予定ã§ã‚る旨をãŠçŸ¥ã‚‰ã›ã—ã¦ãŠã‚Šã¾ã—ãŸã€‚ 2019年末を目処ã«ã€ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—ã®æ供を終了ã™ã‚‹äºˆå®šã§ã™ - ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—日記 ã“ã®ãŸã³ã€æ£å¼ã«çµ‚了日を決定ã„ãŸã—ã¾ã—ãŸã®ã§ã€ä»¥ä¸‹ã®é€šã‚Šã”確èªãã ã•ã„。 終了日: 2020å¹´1月31æ—¥(金) エクスãƒãƒ¼ãƒˆå¸Œæœ›ç”³è«‹æœŸé™:2020å¹´1月31æ—¥(金) 終了日以é™ã¯ã€ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—ã®é–²è¦§ãŠã‚ˆã³æŠ•ç¨¿ã¯è¡Œãˆã¾ã›ã‚“。日記ã®ã‚¨ã‚¯ã‚¹ãƒãƒ¼ãƒˆãŒå¿…è¦ãªæ–¹ã¯ä»¥ä¸‹ã®è¨˜äº‹ã«ã—ãŸãŒã£ã¦æ‰‹ç¶šãã‚’ã—ã¦ãã ã•ã„。 ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—ã«æŠ•ç¨¿ã•ã‚ŒãŸæ—¥è¨˜ãƒ‡ãƒ¼ã‚¿ã®ã‚¨ã‚¯ã‚¹ãƒãƒ¼ãƒˆã«ã¤ã„㦠- ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—日記 ã”利用ã®ã¿ãªã•ã¾ã«ã¯ã”迷惑をãŠã‹ã‘ã„ãŸã—ã¾ã™ãŒã€ã©ã†ãžã‚ˆã‚ã—ããŠé¡˜ã„ã„ãŸã—ã¾ã™ã€‚ 2020-06-25 追記 ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—日記ã®ã‚¨ã‚¯ã‚¹ãƒãƒ¼ãƒˆãƒ‡ãƒ¼ã‚¿ã¯2020å¹´2月28
ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—ã®çµ‚了日を2020å¹´1月31æ—¥(金)ã«æ±ºå®šã—ã¾ã—㟠- ã¯ã¦ãªã®å‘ŠçŸ¥
ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—ã®çµ‚了日を2020å¹´1月31æ—¥(金)ã«æ±ºå®šã—ã¾ã—㟠以下ã®ã‚¨ãƒ³ãƒˆãƒªã®é€šã‚Šã€ä»Šå¹´æœ«ã‚’目処ã«ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—を終了予定ã§ã‚る旨をãŠçŸ¥ã‚‰ã›ã—ã¦ãŠã‚Šã¾ã—ãŸã€‚ 2019年末を目処ã«ã€ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—ã®æ供を終了ã™ã‚‹äºˆå®šã§ã™ - ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—日記 ã“ã®ãŸã³ã€æ£å¼ã«çµ‚了日を決定ã„ãŸã—ã¾ã—ãŸã®ã§ã€ä»¥ä¸‹ã®é€šã‚Šã”確èªãã ã•ã„。 終了日: 2020å¹´1月31æ—¥(金) エクスãƒãƒ¼ãƒˆå¸Œæœ›ç”³è«‹æœŸé™:2020å¹´1月31æ—¥(金) 終了日以é™ã¯ã€ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—ã®é–²è¦§ãŠã‚ˆã³æŠ•ç¨¿ã¯è¡Œãˆã¾ã›ã‚“。日記ã®ã‚¨ã‚¯ã‚¹ãƒãƒ¼ãƒˆãŒå¿…è¦ãªæ–¹ã¯ä»¥ä¸‹ã®è¨˜äº‹ã«ã—ãŸãŒã£ã¦æ‰‹ç¶šãã‚’ã—ã¦ãã ã•ã„。 ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—ã«æŠ•ç¨¿ã•ã‚ŒãŸæ—¥è¨˜ãƒ‡ãƒ¼ã‚¿ã®ã‚¨ã‚¯ã‚¹ãƒãƒ¼ãƒˆã«ã¤ã„㦠- ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—日記 ã”利用ã®ã¿ãªã•ã¾ã«ã¯ã”迷惑をãŠã‹ã‘ã„ãŸã—ã¾ã™ãŒã€ã©ã†ãžã‚ˆã‚ã—ããŠé¡˜ã„ã„ãŸã—ã¾ã™ã€‚ 2020-06-25 追記 ã¯ã¦ãªã‚°ãƒ«ãƒ¼ãƒ—日記ã®ã‚¨ã‚¯ã‚¹ãƒãƒ¼ãƒˆãƒ‡ãƒ¼ã‚¿ã¯2020å¹´2月28
Perlã§å¦ã¶ã‚³ãƒ«ãƒ¼ãƒãƒ³
8. say quot;startquot;; sub say_hello { say_hello(10); my $n = shift; for (1..$n) { say 'hello'; } return; } say quot;endquot;; 10. my $c = Fiber>new( $câ€>resume; sub{ say 'hello!'; Fiberâ€>yield; say 'happy'; $câ€>resume; say 'perl'; Fiberâ€>yield; say 'coding'; $câ€>resume; say 'world!'; } ); 11. my $c = Fiber>new( $câ€>resume; sub{ say 'hello!'; Fiberâ€>yield; say 'happy'; hello happy $câ€>resume; say
tokuhirom blog
Blog Search when-present<#else>when-missing. (These only cover the last step of the expression; to cover the whole expression, use parenthesis: (myOptionalVar.foo)!myDefault, (myOptionalVar.foo)?? ---- ---- FTL stack trace ("~" means nesting-related): - Failed at: ${entry.path} [in template "__entry.ftlh" at line 3, column 25] - Reached through: #include "__entry.ftlh" [in template "entry.ftlh" at
tokuhirom blog
Blog Search when-present<#else>when-missing. (These only cover the last step of the expression; to cover the whole expression, use parenthesis: (myOptionalVar.foo)!myDefault, (myOptionalVar.foo)?? ---- ---- FTL stack trace ("~" means nesting-related): - Failed at: ${entry.path} [in template "__entry.ftlh" at line 3, column 25] - Reached through: #include "__entry.ftlh" [in template "entry.ftlh" at
tokuhirom blog
Blog Search when-present<#else>when-missing. (These only cover the last step of the expression; to cover the whole expression, use parenthesis: (myOptionalVar.foo)!myDefault, (myOptionalVar.foo)?? ---- ---- FTL stack trace ("~" means nesting-related): - Failed at: ${entry.path} [in template "__entry.ftlh" at line 3, column 25] - Reached through: #include "__entry.ftlh" [in template "entry.ftlh" at
リリースã€éšœå®³æƒ…å ±ãªã©ã®ã‚µãƒ¼ãƒ“スã®ãŠçŸ¥ã‚‰ã›
最新ã®äººæ°—エントリーã®é…ä¿¡
j次ã®ãƒ–ックマーク
kå‰ã®ãƒ–ックマーク
lã‚ã¨ã§èªã‚€
eコメント一覧を開ã
oページを開ã
YAPC::Asia 2009 / Asynchronous Programming for (A)synchronous Communication
http://www.google.co.jp/codesearch/p?hl=ja&sa=N&cd=8&ct=rc
{{#tags}}- {{label}}
{{/tags}}