| 39 | : TypedQueue(capacity, component_dtypes, component_shapes, name) {} |
| 40 | |
| 41 | void FIFOQueue::DequeueLocked(OpKernelContext* ctx, Tuple* tuple) { |
| 42 | DCHECK_GT(queues_[0].size(), size_t{0}); |
| 43 | (*tuple).reserve(num_components()); |
| 44 | for (int i = 0; i < num_components(); ++i) { |
| 45 | (*tuple).push_back(*queues_[i][0].AccessTensor(ctx)); |
| 46 | queues_[i].pop_front(); |
| 47 | } |
| 48 | } |
| 49 | |
| 50 | void FIFOQueue::TryEnqueue(const Tuple& tuple, OpKernelContext* ctx, |
| 51 | DoneCallback callback) { |
nothing calls this directly
no test coverage detected