1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
|
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'
barrier = Async::Barrier.new
Sync do
Console.info("Barrier Example: sleep sort.")
# 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|
sleep(number)
sorted << number
end
end
# Wait for all the numbers to be sorted:
barrier.wait
Console.info("Sorted", sorted)
ensure
# Ensure all the tasks are stopped when we exit:
barrier.stop
end
~~~
### Output
~~~
0.0s info: Barrier Example: sleep sort.
9.0s info: Sorted
| [3, 3, 3, 4, 4, 5, 5, 5, 8, 9]
~~~
|
