Class: PageByPage::MutexEnum

Inherits:
Enum
  • Object
show all
Defined in:
lib/page_by_page/mutex_enum.rb

Instance Method Summary collapse

Constructor Details

#initialize(enum) ⇒ MutexEnum

Returns a new instance of MutexEnum.



7
8
9
10
11
12
13
14
15
# File 'lib/page_by_page/mutex_enum.rb', line 7

def initialize enum
  @q = SizedQueue.new 10
  @enum = enum
  Thread.new do
    loop do
      @q << @enum.next
    end
  end
end

Instance Method Details

#nextObject



17
18
19
# File 'lib/page_by_page/mutex_enum.rb', line 17

def next
  @q.deq
end