| 264 | } |
| 265 | |
| 266 | bool Dequeue(T& value) { |
| 267 | size_t index = 0; |
| 268 | if (TEntry* entry = PrepareRead(index)) { |
| 269 | value = TTypeHelper::Read(&entry->Value); |
| 270 | Queues[index].CompleteRead(); |
| 271 | return true; |
| 272 | } |
| 273 | return false; |
| 274 | } |
| 275 | |
| 276 | bool IsEmpty() { |
| 277 | for (size_t i = 0; i < Concurrency; ++i) { |
nothing calls this directly
no test coverage detected