On Windows, max_workers must be less than or equal to 61. If max_workers is less than or equal to 0, then a ValueError Given, it will default to the number of processors on the machine. ProcessPoolExecutor ( max_workers = None, mp_context = None, initializer = None, initargs = (), max_tasks_per_child = None ) ¶Īn Executor subclass that executes calls asynchronously using a pool ProcessPoolExecutor 는 multiprocessing 모듈을 사용합니다. result () except Exception as exc : print ( ' %r generated an exception: %s ' % ( url, exc )) else : print ( ' %r page is %d bytes' % ( url, len ( data ))) ProcessPoolExecutor ¶ as_completed ( future_to_url ): url = future_to_url try : data = future. ThreadPoolExecutor ( max_workers = 5 ) as executor : # Start the load operations and mark each future with its URL future_to_url = for future in concurrent. read () # We can use a with statement to ensure threads are cleaned up promptly with concurrent. urlopen ( url, timeout = timeout ) as conn : return conn. Import concurrent.futures import urllib.request URLS = # Retrieve a single page and report the URL and contents def load_url ( url, timeout ): with urllib. That ThreadPoolExecutor not be used for long-running tasks. This meansĮxceptions in the main thread must be caught and handled in order to Note that the exit handler which does this isĮxecuted before any exit handlers added using atexit. 최대 max_workers 스레드의 풀을 사용하여 호출을 비동기적으로 실행하는 Executor 서브 클래스.Īll threads enqueued to ThreadPoolExecutor will be joined before the ThreadPoolExecutor ( max_workers = None, thread_name_prefix = '', initializer = None, initargs = () ) ¶ submit ( wait_on_future ) class concurrent.futures. result ()) executor = ThreadPoolExecutor ( max_workers = 1 ) executor. submit ( pow, 5, 2 ) # This will never complete because there is only one worker thread and # it is executing this function.
0 Comments
Leave a Reply. |