Module: Archipelago::Current::ThreadedCollection

Included in:
Disco::ServiceLocker
Defined in:
lib/archipelago/current.rb

Overview

Adds a few threaded methods to the normal ruby collections.

The only method your class has to implement to use this module is each(&block).

NB: Will work slightly different than the unthreaded ones in certain circumstances.

Instance Method Summary collapse

Instance Method Details

#t_collect(callable = nil, &block) ⇒ Object

Like collect, except calls block or callable within a new thread.



102
103
104
105
106
107
108
109
110
111
112
113
114
 
# File 'lib/archipelago/current.rb', line 102

def t_collect(callable = nil, &block)
  raise "You have to provide either callable or block" if callable.nil? && block.nil?

  result = []
  result.extend(Synchronized)
  self.t_each do |args|
    new_value = call_helper(callable, args, &block)
    result.synchronize do
      result << new_value
    end
  end
  return result
end

#t_each(callable = nil, &block) ⇒ Object

Like each, except calls block or callable within a new thread.



83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
 
# File 'lib/archipelago/current.rb', line 83

def t_each(callable = nil, &block)
  raise "You have to provide either callable or block" if callable.nil? && block.nil?

  threads = []

  self.each do |args|
    threads << Thread.new do
      call_helper(callable, args, &block)
    end
  end

  threads.each do |thread|
    thread.join
  end
end

#t_reject(callable = nil, &block) ⇒ Object

Like reject, except calls block or callable within a new thread.



136
137
138
139
140
141
142
143
144
145
146
147
148
 
# File 'lib/archipelago/current.rb', line 136

def t_reject(callable = nil, &block)
  raise "You have to provide either callable or block" if callable.nil? && block.nil?
  
  result = []
  result.extend(Synchronized)
  self.t_each do |args|
    matches = call_helper(callable, args, &block)
    result.synchronize do
      result << args
    end unless matches
  end
  return result
end

#t_select(callable = nil, &block) ⇒ Object

Like select, except calls block or callable within a new thread.



119
120
121
122
123
124
125
126
127
128
129
130
131
 
# File 'lib/archipelago/current.rb', line 119

def t_select(callable = nil, &block)
  raise "You have to provide either callable or block" if callable.nil? && block.nil?

  result = []
  result.extend(Synchronized)
  self.t_each do |args|
    matches = call_helper(callable, args, &block)
    result.synchronize do
      result << args
    end if matches
  end
  return result
end