| 20 | |
| 21 | template <typename U = T> |
| 22 | void enqueue(U &&item) { |
| 23 | enqueueSemaphore_.wait(); |
| 24 | queue_.writeIfNotFull(std::forward<U>(item)); |
| 25 | dequeueSemaphore_.signal(); |
| 26 | } |
| 27 | |
| 28 | template <typename U = T> |
| 29 | folly::coro::Task<void> co_enqueue(U &&item) { |
no test coverage detected