- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 226 for pushBack (0.28 sec)
-
src/cmd/vendor/golang.org/x/sync/semaphore/semaphore.go
// Don't make other Acquire calls block on one that's doomed to fail. s.mu.Unlock() <-done return ctx.Err() } ready := make(chan struct{}) w := waiter{n: n, ready: ready} elem := s.waiters.PushBack(w) s.mu.Unlock() select { case <-done: s.mu.Lock() select { case <-ready: // Acquired the semaphore after we were canceled. // Pretend we didn't and put the tokens back. s.cur -= n
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 02:38:00 UTC 2024 - 4.3K bytes - Viewed (0) -
src/net/http/transport.go
tail []*wantConn } // len returns the number of items in the queue. func (q *wantConnQueue) len() int { return len(q.head) - q.headPos + len(q.tail) } // pushBack adds w to the back of the queue. func (q *wantConnQueue) pushBack(w *wantConn) { q.tail = append(q.tail, w) } // popFront removes and returns the wantConn at the front of the queue. func (q *wantConnQueue) popFront() *wantConn {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
src/runtime/mgcmark.go
// lock. if atomic.Load(&gcBlackenEnabled) == 0 { unlock(&work.assistQueue.lock) return true } gp := getg() oldList := work.assistQueue.q work.assistQueue.q.pushBack(gp) // Recheck for background credit now that this G is in // the queue, but can still back out. This avoids a // race in case background marking has flushed more // credit since we checked above.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 18 21:25:11 UTC 2024 - 52.5K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
} pInfo := obj.(*framework.QueuedPodInfo) pInfo.Attempts++ p.schedulingCycle++ // In flight, no concurrent events yet. if p.isSchedulingQueueHintEnabled { p.inFlightPods[pInfo.Pod.UID] = p.inFlightEvents.PushBack(pInfo.Pod) } // Update metrics and reset the set of unschedulable plugins for the next attempt. for plugin := range pInfo.UnschedulablePlugins.Union(pInfo.PendingPlugins) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
src/runtime/proc.go
} // push adds gp to the head of q. func (q *gQueue) push(gp *g) { gp.schedlink = q.head q.head.set(gp) if q.tail == 0 { q.tail.set(gp) } } // pushBack adds gp to the tail of q. func (q *gQueue) pushBack(gp *g) { gp.schedlink = 0 if q.tail != 0 { q.tail.ptr().schedlink.set(gp) } else { q.head.set(gp) } q.tail.set(gp) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/decompose_reduce_dataset.cc
SmallVector<Type, 4> while_input_types; while_input_values.push_back(const_true.getResult()); while_input_types.push_back(const_true.getResult().getType()); for (int i = 1; i < reduce_dataset.getNumOperands(); ++i) { while_input_values.push_back(reduce_dataset.getOperand(i)); while_input_types.push_back(reduce_dataset.getOperand(i).getType()); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 14K bytes - Viewed (0) -
tensorflow/c/experimental/ops/gen/cpp/views/op_view.cc
// Initialize function arguments all_arguments_.push_back(OpArgumentView("AbstractContext*", "ctx")); for (const auto& arg : op_.Inputs()) { all_arguments_.push_back(OpArgumentView(arg)); } for (const auto& arg : op_.Outputs()) { all_arguments_.push_back(OpArgumentView(arg)); } for (const auto& attr : op.Attributes()) { all_arguments_.push_back(OpArgumentView(attr)); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Jun 03 07:02:00 UTC 2024 - 3.2K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/utils/convert_attr.cc
for (const auto& item : value.list().i()) attrs.push_back(builder->getI64IntegerAttr(item)); for (const auto& item : value.list().s()) attrs.push_back(builder->getStringAttr(item)); for (const auto& item : value.list().f()) attrs.push_back(builder->getFloatAttr(builder->getF32Type(), item)); for (const auto& item : value.list().b()) attrs.push_back(builder->getBoolAttr(item));
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Apr 26 09:37:10 UTC 2024 - 4.8K bytes - Viewed (0) -
tensorflow/compiler/mlir/quantization/tensorflow/utils/tf_to_uniform_attribute_utils.cc
} } attrs.push_back(rewriter.getNamedAttr("lhs_quantization_axis", activation_quantization_axis)); attrs.push_back(rewriter.getNamedAttr("rhs_quantization_axis", activation_quantization_axis)); attrs.push_back(rewriter.getNamedAttr("output_quantization_axis",
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 18.7K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/translate/mlir_roundtrip_flags.cc
// Treats empty input shape as scalar if (dim_str.empty()) continue; if (dim_str == "?") { dims.push_back(-1); continue; } int size; TF_RET_CHECK(absl::SimpleAtoi(dim_str, &size)); dims.push_back(size); } return dims; } static Status HandleSubtype(absl::string_view subtype, ArrayInfo::SubTypeInfo* result) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 01 11:17:36 UTC 2024 - 10.4K bytes - Viewed (0)