Rayã«ã‚ˆã‚‹Python分散並列処ç†å…¥é–€ - QiitaRayã¨ã¯ Rayã¯Pythonã«ãŠã‘る分散並列処ç†ã‚’高速ã‹ã¤ã‚·ãƒ³ãƒ—ルã«æ›¸ã‘るフレームワークã§, æ—¢å˜ã®ã‚³ãƒ¼ãƒ‰ã‚’並列化ã™ã‚‹ã“ã¨ã‚‚容易ãªè¨è¨ˆã¨ãªã£ã¦ã„ã¾ã™. Rayを使ã†ã“ã¨ã§multiprocessingãªã©ã«æ¯”ã¹ç°¡å˜ã«ãƒ—ãƒã‚»ã‚¹ãƒ¬ãƒ™ãƒ«ã®ä¸¦åˆ—処ç†ã‚’記述ã™ã‚‹ã“ã¨ãŒã§ãã¾ã™. 本記事ã¯Rayãƒãƒ¥ãƒ¼ãƒˆãƒªã‚¢ãƒ«ã®å†…容をもã¨ã«ã—ã¦ãŠã‚Š, コードã¯Python 3.8.2, Ray 0.8.4ã§ã®å‹•ä½œã‚’確èªã—ã¦ã„ã¾ã™. インストール ターミナルã§pipãªã©ã‹ã‚‰ã‚¤ãƒ³ã‚¹ãƒˆãƒ¼ãƒ«ã§ãã¾ã™. 使ã„æ–¹ 基本的ãªç”¨é€”ã¨ã—ã¦ã¯è¦šãˆã‚‹æ–‡æ³•ã¯ray.init ray.remote ray.get ã®3ã¤ã®ã¿ã§, ã“ã®è¨˜äº‹ã§ã¯åŠ ãˆã¦ray.wait ray.put も紹介ã—ã¾ã™. Rayã«ã‚ˆã‚‹ä¸¦åˆ—化ã®åŸºæœ¬ 実行ã«3秒ã‹ã‹ã‚‹é–¢æ•° func ãŒäºŒåº¦å‘¼ã³å‡ºã•ã‚Œå…¨ä½“ã®å®Ÿè¡Œã«6秒ã‹ã‹ã‚‹ä»¥ä¸‹ã®ã‚³ãƒ¼ãƒ‰ã«ã¤ã„ã¦, func ã®å®Ÿè¡Œã‚’並列化ã™ã‚‹
{{#tags}}- {{label}}
{{/tags}}