16.4. concurrent.futures — Launching parallel tasks — Python v3.2.3 documentation
Source code: Lib/concurrent/futures/thread.py, Lib/concurrent/futures/process.py, and Lib/concurrent/futures/interpreter.py The concurrent.futures module provides a high-level interface for asynchronously executing callables. The asynchronous execution can be performed with threads, using ThreadPoolExecutor or InterpreterPoolExecutor, or separate processes, using ProcessPoolExecutor. Each implemen
Pythonã§concurrent.futuresを使ã£ãŸä¸¦åˆ—タスク実行 - Qiita
concurrent.futuresモジュールã®æ¦‚è¦ Python3.2ã§è¿½åŠ ã•ã‚ŒãŸconcurrent.futuresモジュールã¯ã€è¤‡æ•°ã®å‡¦ç†ã‚’並列実行ã™ã‚‹ãŸã‚ã®æ©Ÿèƒ½ã‚’æä¾›ã—ã¾ã™ã€‚ Pythonã«ã¯ä»–ã«threadingã¨multiprocessingã¨ã„ã†ãƒ¢ã‚¸ãƒ¥ãƒ¼ãƒ«ãŒã‚ã‚Šã¾ã™ãŒã€ã“れらãŒï¼‘ã¤ã®ã‚¹ãƒ¬ãƒƒãƒ‰ãƒ»ãƒ—ãƒã‚»ã‚¹ã‚’扱ã†ã®ã«å¯¾ã—ã¦ã€concurrent.futuresモジュールã¯è¤‡æ•°ã®ã‚¹ãƒ¬ãƒƒãƒ‰ãƒ»ãƒ—ãƒã‚»ã‚¹ã‚’扱ã†ã“ã¨ã‚’目的ã¨ã—ã¦ã„ã¾ã™ã€‚ Executor concurrent.futuresモジュールã«ã¯æŠ½è±¡ã‚¯ãƒ©ã‚¹ã¨ã—ã¦ExecutorクラスãŒã‚ã‚Šã€å®Ÿè£…クラスã¨ã—ã¦2ã¤ã®ã‚¯ãƒ©ã‚¹ãŒæä¾›ã•ã‚Œã¦ã„ã¾ã™ã€‚ 並列タスクを実行ã™ã‚‹ã«ã¯ã“ã®ï¼’ã¤ã®ã†ã¡ã©ã¡ã‚‰ã‹ã‚’使用ã—ã¾ã™ã€‚ ThreadPoolExecutor スレッドを使ã£ã¦ä¸¦åˆ—タスクを実行ã—ã¾ã™ã€‚ ãƒãƒƒãƒˆãƒ¯ãƒ¼ã‚¯ã‚¢ã‚¯ã‚»ã‚¹ãªã©CPUã«è² è·ãŒã‹ã‹ã‚‰ãªã„処ç†ã®ä¸¦
concurrent.futures: ä¸¦è¡Œå‡¦ç† in Python
æ¦‚è¦ Global Interpreter Lock (GIL) ã®åˆ¶ç´„ã«ã‚ˆã‚Šã€ 1ã¤ã®Pythonインタープリタã§ã¯åŒæ™‚ã«1ã¤ã®ã‚¹ãƒ¬ãƒƒãƒ‰ã—ã‹ã‚³ãƒ¼ãƒ‰ã‚’実行ã§ããªã„。 ã—ãŸãŒã£ã¦CPUãƒã‚¦ãƒ³ãƒ‰ãªãƒ”ュアPythonコードを threading ã§ãƒžãƒ«ãƒã‚¹ãƒ¬ãƒƒãƒ‰åŒ–ã—ã¦ã‚‚速ããªã‚‰ãªã„。 subprocess ã«ã‚ˆã‚‹å¤–部プãƒã‚°ãƒ©ãƒ 実行やI/Oãªã©GIL外ã®å‡¦ç†ã‚’å¾…ã¤å ´åˆã«ã¯æœ‰åŠ¹ã€‚ 一方 multiprocessing ã¯æ–°ã—ã„インタプリタを os.fork() ã§ç«‹ã¡ä¸Šã’ã‚‹ã®ã§ã€ CPUãƒã‚¦ãƒ³ãƒ‰ãªPythonコードもGILã«é‚ªé”ã•ã‚Œãšä¸¦åˆ—処ç†ã§ãる。 ãŸã ã—通信ã®ãŸã‚関数や返り値ãŒpicklableã§ãªã‘ã‚Œã°ãªã‚‰ãªã„。 コストも高ã„。 ãれらã®ä½Žç´šãƒ©ã‚¤ãƒ–ラリを使ã„ã‚„ã™ãã¾ã¨ã‚ãŸã®ãŒ concurrent.futures (since 3.2) ãªã®ã§ã€ã¨ã‚Šã‚ãˆãšã“れを使ãˆã°ã‚ˆã„。 I/Oãƒã‚¦ãƒ³ãƒ‰ãªå‡¦
Pythonã‚’ã¨ã‚Šã¾ã並行/éžåŒæœŸã®è©±
Use the left and right arrow keys or click the left and right edges of the page to navigate between slides. (Press 'H' or navigate to hide this message.)
1
ランã‚ング
ランã‚ング
ãŠçŸ¥ã‚‰ã›
リリースã€éšœå®³æƒ…å ±ãªã©ã®ã‚µãƒ¼ãƒ“スã®ãŠçŸ¥ã‚‰ã›
最新ã®äººæ°—エントリーã®é…ä¿¡
j次ã®ãƒ–ックマーク
kå‰ã®ãƒ–ックマーク
lã‚ã¨ã§èªã‚€
eコメント一覧を開ã
oページを開ã
{{#tags}}- {{label}}
{{/tags}}