Class: CountingSemaphore
- Inherits:
-
Object
- Object
- CountingSemaphore
- Defined in:
- lib/buzzcore/thread_utils.rb
Overview
BEGIN $Id: semaphore.rb,v 1.2 2003/03/15 20:10:10 fukumoto Exp $
Instance Method Summary collapse
- #exclusive ⇒ Object (also: #synchronize)
-
#initialize(initvalue = 0) ⇒ CountingSemaphore
constructor
A new instance of CountingSemaphore.
- #signal ⇒ Object (also: #up, #V)
- #wait ⇒ Object (also: #down, #P)
Constructor Details
#initialize(initvalue = 0) ⇒ CountingSemaphore
Returns a new instance of CountingSemaphore.
142 143 144 145 |
# File 'lib/buzzcore/thread_utils.rb', line 142 def initialize(initvalue = 0) @counter = initvalue @waiting_list = [] end |
Instance Method Details
#exclusive ⇒ Object Also known as: synchronize
178 179 180 181 182 183 |
# File 'lib/buzzcore/thread_utils.rb', line 178 def exclusive wait yield ensure signal end |
#signal ⇒ Object Also known as: up, V
158 159 160 161 162 163 164 165 166 167 168 169 170 171 |
# File 'lib/buzzcore/thread_utils.rb', line 158 def signal Thread.critical = true begin if (@counter += 1) <= 0 t = @waiting_list.shift t.wakeup if t end rescue ThreadError retry end self ensure Thread.critical = false end |
#wait ⇒ Object Also known as: down, P
147 148 149 150 151 152 153 154 155 156 |
# File 'lib/buzzcore/thread_utils.rb', line 147 def wait Thread.critical = true if (@counter -= 1) < 0 @waiting_list.push(Thread.current) Thread.stop end self ensure Thread.critical = false end |