Class: Andromeda::Sync::Sync
- Inherits:
-
Plan
- Object
- Impl::ConnectorBase
- Impl::ProtoPlan
- Plan
- Andromeda::Sync::Sync
- Defined in:
- lib/andromeda/sync.rb
Overview
Comparable to a join in join calculus, called Sync here to reserve the name Join for map_reduce.rb
Instance Attribute Summary
Attributes inherited from Plan
#error_level, #log, #marker, #nick, #trace_enter, #trace_exit
Attributes inherited from Impl::ProtoPlan
Instance Method Summary collapse
-
#initialize(config = {}) ⇒ Sync
constructor
A new instance of Sync.
Methods inherited from Plan
#initialize_copy, #on_enter, #pool, #tap, #to_short_s
Methods inherited from Impl::ProtoPlan
#>>, #current_name, #current_scope, #data_key, #data_tag, #data_val, #dest, #entry, #init_guide, #initialize_copy, #key_label, #key_spot, #map_data, #mute, name_spot, #post_data, #post_to, #public_spot, #selects?, #signal_name?, signal_names, #signal_names, signal_spot, spot_attr, #spot_attr_name?, spot_attr_names, #spot_attr_names, spot_meth, #spot_meth_name?, #spot_meth_names, spot_meth_names, #spot_name?, spot_names, #spot_names, #tags, #to_short_s, #via
Methods included from Impl::To_S
Methods inherited from Impl::ConnectorBase
Constructor Details
#initialize(config = {}) ⇒ Sync
Returns a new instance of Sync.
10 11 12 13 14 15 16 |
# File 'lib/andromeda/sync.rb', line 10 def initialize(config = {}) super config @mutex = Mutex.new @cv = ConditionVariable.new # box value to keep ref after clone @state = [ state_init ] end |