vine.synchronization¶
Synchronization primitives.
-
class
vine.synchronization.
barrier
(promises=None, args=None, kwargs=None, callback=None, size=None)[source]¶ Barrier.
Synchronization primitive to call a callback after a list of promises have been fulfilled.
Example:
# Request supports the .then() method. p1 = http.Request('http://a') p2 = http.Request('http://b') p3 = http.Request('http://c') requests = [p1, p2, p3] def all_done(): pass # all requests complete b = barrier(requests).then(all_done) # oops, we forgot we want another request b.add(http.Request('http://d'))
Note that you cannot add new promises to a barrier after the barrier is fulfilled.
-
throw1
(*args, **kwargs)¶
-