Class: Async::Barrier

Inherits:
Object
  • Object
show all
Defined in:
lib/async/barrier.rb

Overview

A barrier is used to synchronize multiple tasks, waiting for them all to complete before continuing.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(parent: nil) ⇒ Barrier

Returns a new instance of Barrier.


28
29
30
31
32
# File 'lib/async/barrier.rb', line 28

def initialize(parent: nil)
	@tasks = []
	
	@parent = parent
end

Instance Attribute Details

#tasksObject (readonly)

All tasks which have been invoked into the barrier.


35
36
37
# File 'lib/async/barrier.rb', line 35

def tasks
  @tasks
end

Instance Method Details

#async(*arguments, parent: (@parent or Task.current), **options, &block) ⇒ Object


41
42
43
44
45
46
47
# File 'lib/async/barrier.rb', line 41

def async(*arguments, parent: (@parent or Task.current), **options, &block)
	task = parent.async(*arguments, **options, &block)
	
	@tasks << task
	
	return task
end

#empty?Boolean

Returns:

  • (Boolean)

49
50
51
# File 'lib/async/barrier.rb', line 49

def empty?
	@tasks.empty?
end

#sizeObject


37
38
39
# File 'lib/async/barrier.rb', line 37

def size
	@tasks.size
end

#waitObject

Wait for tasks in FIFO order.


54
55
56
57
58
# File 'lib/async/barrier.rb', line 54

def wait
	while task = @tasks.shift
		task.wait
	end
end