Clean-up threading.Barrier example.

This commit is contained in:
Raymond Hettinger 2011-01-11 20:51:45 +00:00
parent 5cee47f321
commit 3a8ae5f9f4
1 changed files with 7 additions and 4 deletions

View File

@ -846,7 +846,7 @@ Example of using barriers::
summarize(ballots) summarize(ballots)
all_polls_closed = Barrier(len(sites)) all_polls_closed = Barrier(len(sites))
for site in sites(get_votes(site)): for site in sites:
Thread(target=get_votes, args=(site,)).start() Thread(target=get_votes, args=(site,)).start()
In this example, the barrier enforces a rule that votes cannot be counted at any In this example, the barrier enforces a rule that votes cannot be counted at any
@ -856,10 +856,13 @@ and continue to do work (summarizing ballots) after the barrier point is
crossed. crossed.
See `Barrier Synchronization Patterns See `Barrier Synchronization Patterns
<http://parlab.eecs.berkeley.edu/wiki/_media/patterns/paraplop_g1_3.pdf>`_ <http://parlab.eecs.berkeley.edu/wiki/_media/patterns/paraplop_g1_3.pdf>`_ for
for more examples of how barriers can be used in parallel computing. more examples of how barriers can be used in parallel computing. Also, there is
a simple but thorough explanation of barriers in `The Little Book of Semaphores
<http://greenteapress.com/semaphores/downey08semaphores.pdf>`_, *section 3.6*.
(Contributed by Kristján Valur Jónsson in :issue:`8777`.) (Contributed by Kristján Valur Jónsson with an API review by Jeffrey Yasskin in
:issue:`8777`.)
datetime datetime
-------- --------