Class: Thread::Queue

73
74
75

# File 'opal/stdlib/thread.rb', line 73
def initialize
 clear
end

77
78
79

# File 'opal/stdlib/thread.rb', line 77
def clear
 @storage = []
end

102
103
104

# File 'opal/stdlib/thread.rb', line 102
def each(&block)
 @storage.each(&block)
end

81
82
83

# File 'opal/stdlib/thread.rb', line 81
def empty?
 @storage.empty?
end

89
90
91
92
93
94
95
96

# File 'opal/stdlib/thread.rb', line 89
def pop(non_block = false)
 if empty?
 raise ThreadError , 'Queue empty' if non_block
 raise ThreadError , 'Deadlock'
 end
 @storage.shift
end

98
99
100

# File 'opal/stdlib/thread.rb', line 98
def push(value)
 @storage.push(value)
end

85
86
87

# File 'opal/stdlib/thread.rb', line 85
def size
 @storage.size
end