| 268 | } |
| 269 | |
| 270 | void Coordinator::releaseWorker(Worker* w) |
| 271 | { |
| 272 | MutexLockGuard guard(m_mutex, FB_FUNCTION); |
| 273 | FB_SIZE_T pos; |
| 274 | if (m_activeWorkers.find(w, pos)) |
| 275 | { |
| 276 | m_activeWorkers.remove(pos); |
| 277 | m_idleWorkers.push(w); |
| 278 | } |
| 279 | fb_assert(m_idleWorkers.find(w, pos)); |
| 280 | } |
| 281 | |
| 282 | int Coordinator::setupWorkers(int count) |
| 283 | { |