Sha256: 44fd4a054c3b8a24fdbdde2009cc8bc5bd93357e0a8c687680ecfa0a7e005a0b
Contents?: true
Size: 681 Bytes
Versions: 7
Compression:
Stored size: 681 Bytes
Contents
A synchronization primitive, which allows one task to wait for a number of other tasks to complete. It can be used in conjunction with {Semaphore}.
## Example
~~~ ruby
require 'async'
require 'async/barrier'
Sync do
barrier = Async::Barrier.new
# Generate an array of 10 numbers:
numbers = 10.times.map{rand(10)}
sorted = []
# Sleep sort the numbers:
numbers.each do |number|
barrier.async do |task|
task.sleep(number)
sorted << number
end
end
# Wait for all the numbers to be sorted:
barrier.wait
Console.logger.info("Sorted", sorted)
end
~~~
### Output
~~~
0.0s info: Sorted [ec=0x104] [pid=50291]
| [0, 0, 0, 0, 1, 2, 2, 3, 6, 6]
~~~
Version data entries
7 entries across 7 versions & 1 rubygems