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

110
111
112

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

81
82
83

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

91
92
93
94
95
96
97
98

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

103
104
105

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

85
86
87

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