Class: Bricolage::MemoryTaskQueue

Inherits:
Object
  • Object
show all
Defined in:
lib/bricolage/taskqueue.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ MemoryTaskQueue

Returns a new instance of MemoryTaskQueue.



15
16
17
 
# File 'lib/bricolage/taskqueue.rb', line 15

def initialize
  @queue = []
end

Instance Method Details

#cancel_jobnet(jobnet, message) ⇒ Object 



56
57
58
 
# File 'lib/bricolage/taskqueue.rb', line 56

def cancel_jobnet(jobnet, message)
  @queue.clear
end

#consume_each ⇒ Object 



31
32
33
34
35
36
37
 
# File 'lib/bricolage/taskqueue.rb', line 31

def consume_each
  while job = @queue.first
    result = yield job
    break unless result.success?
    @queue.shift
  end
end

#each(&block) ⇒ Object 



27
28
29
 
# File 'lib/bricolage/taskqueue.rb', line 27

def each(&block)
  @queue.each(&block)
end

#empty? ⇒ Boolean

Returns:

  • (Boolean) 


19
20
21
 
# File 'lib/bricolage/taskqueue.rb', line 19

def empty?
  @queue.empty?
end

#enqueue_jobnet(jobnet) ⇒ Object 



42
43
44
45
46
 
# File 'lib/bricolage/taskqueue.rb', line 42

def enqueue_jobnet(jobnet)
  jobnet.sequential_jobs.each do |job|
    @queue.push job
  end
end

#locked?(jobnet) ⇒ Boolean

Returns:

  • (Boolean) 


48
49
50
 
# File 'lib/bricolage/taskqueue.rb', line 48

def locked?(jobnet)
  false
end

#restore_jobnet(jobnet) ⇒ Object 



39
40
 
# File 'lib/bricolage/taskqueue.rb', line 39

def restore_jobnet(jobnet)
end

#size ⇒ Object 



23
24
25
 
# File 'lib/bricolage/taskqueue.rb', line 23

def size
  @queue.size
end

#unlock_help(jobnet) ⇒ Object 



52
53
54
 
# File 'lib/bricolage/taskqueue.rb', line 52

def unlock_help(jobnet)
  raise "[BUG] this message must not be shown"
end