Class: PageByPage::MutexEnum

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

Instance Method Summary collapse

Constructor Details

#initialize(from: 1, step: 1) ⇒ MutexEnum

Returns a new instance of MutexEnum.



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

def initialize from: 1, step: 1
  super
  @q = SizedQueue.new 10
  Thread.new do
    loop do
      @q << @enum.next
      sleep 0.1
    end
  end
end

Instance Method Details

#next ⇒ Object 



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

def next
  @q.deq
end