Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
C
cpython
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
Analytics
Analytics
Repository
Value Stream
Wiki
Wiki
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Commits
Issue Boards
Open sidebar
Kirill Smelkov
cpython
Commits
c89a2894
Commit
c89a2894
authored
Oct 16, 2012
by
Nick Coghlan
Browse files
Options
Browse Files
Download
Plain Diff
Merge concurrent.futures example changes from 3.3
parents
ff4b39f9
4af0c2b5
Changes
2
Show whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
18 additions
and
10 deletions
+18
-10
Doc/library/concurrent.futures.rst
Doc/library/concurrent.futures.rst
+15
-10
Misc/NEWS
Misc/NEWS
+3
-0
No files found.
Doc/library/concurrent.futures.rst
View file @
c89a2894
...
...
@@ -136,20 +136,25 @@ ThreadPoolExecutor Example
'http://www.bbc.co.uk/',
'http://some-made-up-domain.com/']
# Retrieve a single page and report the url and contents
def load_url(url, timeout):
return urllib.request.urlopen(url, timeout=timeout).read()
conn = urllib.request.urlopen(url, timeout=timeout)
return conn.readall()
# We can use a with statement to ensure threads are cleaned up promptly
with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor:
future_to_url = dict((executor.submit(load_url, url, 60), url)
for url in URLS)
for future in concurrent.futures.as_completed(future_to_url):
url = future_to_url[future]
if future.exception() is not None:
print('%r generated an exception: %s' % (url,
future.exception()))
# Start the load operations and mark each future with its URL
load_urls = [executor.submit(load_url, url, 60) for url in URLS]
for future, url in zip(load_urls, URLS):
future.url = url
for future in concurrent.futures.as_completed(load_urls):
url = future.url
try:
data = future.result()
except Exception as exc:
print('%r generated an exception: %s' % (url, exc))
else:
print('%r page is %d bytes' % (url, len(
future.result()
)))
print('%r page is %d bytes' % (url, len(
data
)))
ProcessPoolExecutor
...
...
Misc/NEWS
View file @
c89a2894
...
...
@@ -176,6 +176,9 @@ Build
Documentation
-------------
- Additional comments and some style changes in the concurrent.futures URL
retrieval example
- Issue #16115: Improve subprocess.Popen() documentation around args, shell,
and executable arguments.
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment