Searched refs:ready_queue_ (Results 1 – 1 of 1) sorted by relevance
81 ready_queue_ = new PriorityQueue( in Barrier()86 Status Initialize() { return ready_queue_->Initialize(); } in Initialize()177 ready_queue_->TryEnqueueMany( in TryInsertMany()233 ready_queue_->TryDequeueMany( in TryTakeMany()275 int32 ready_size() { return ready_queue_->size(); } in ready_size()299 ready_queue_->Unref(); in ~Barrier()400 TF_RETURN_IF_ERROR(ready_queue_->ValidateTuple(ready_tuple)); in InsertOneLocked()420 if (!ready_queue_->is_closed()) { in CloseQueueLocked()421 ready_queue_->Close(ctx, cancel_pending_enqueues, callback); in CloseQueueLocked()437 PriorityQueue* ready_queue_; member in tensorflow::barrier::Barrier