- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 320 for Dequeue (0.2 sec)
-
tensorflow/compiler/mlir/tensorflow/transforms/tpu_cluster_cleanup_attributes.cc
// device. Device attribute is used to infer the appropriate sharding // within TPUs for this op. // TODO(b/183598857): Use explicit sharding ops from the front-end. // For example, dequeue ops generated by // tensorflow/python/tpu/tpu_feed.py if (!tensorflow::IsTPUReplicatedCore(attr.getValue()) && !isa<tf_device::LaunchOp>(op)) { op->removeAttr(kDeviceAttr); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Oct 05 23:50:19 UTC 2022 - 3K bytes - Viewed (0) -
src/runtime/chan.go
// its item at the tail of the queue. Since the // queue is full, those are both the same slot. qp := chanbuf(c, c.recvx) if raceenabled { racenotify(c, c.recvx, nil) racenotify(c, c.recvx, sg) } // copy data from queue to receiver if ep != nil { typedmemmove(c.elemtype, ep, qp) } // copy data from sender to queue typedmemmove(c.elemtype, qp, sg.elem) c.recvx++
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0) -
src/runtime/select.go
x := sgp.prev y := sgp.next if x != nil { if y != nil { // middle of queue x.next = y y.prev = x sgp.next = nil sgp.prev = nil return } // end of queue x.next = nil q.last = x sgp.prev = nil return } if y != nil { // start of queue y.prev = nil q.first = y sgp.next = nil return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 13 21:36:04 UTC 2024 - 15K bytes - Viewed (0) -
pkg/queue/delay_test.go
} success <- struct{}{} }() select { case <-success: dq := dq.(*delayQueue) dq.mu.Lock() if dq.queue.Len() < queuedItems { t.Fatalf("expected 50 items in the queue, got %d", dq.queue.Len()) } dq.mu.Unlock() return case <-timeout: t.Fatal("timed out waiting for enqueues") } } func TestPriorityQueueShrinking(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 06:27:31 UTC 2023 - 4.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/cel/common/maplist.go
if !ok { return nil } if match, ok := a.keyedItems[key]; ok { return match } // keep keying items until we either find a match or run out of unkeyed items for len(a.unkeyedItems) > 0 { // dequeue an unkeyed item item := a.unkeyedItems[0] a.unkeyedItems = a.unkeyedItems[1:] // key the item mitem, ok := item.(map[string]interface{}) if !ok { continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 07 02:56:51 UTC 2023 - 4.5K bytes - Viewed (0) -
src/runtime/lock_sema.go
if v == locked { if atomic.Casuintptr(&l.key, locked, 0) { break } } else { // Other M's are waiting for the lock. // Dequeue an M. mp = muintptr(v &^ locked).ptr() if atomic.Casuintptr(&l.key, v, uintptr(mp.nextwaitm)) { // Dequeued an M. Wake it. semawakeup(mp) break } } } gp.m.mLockProfile.recordUnlock(l) gp.m.locks-- if gp.m.locks < 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 6.8K bytes - Viewed (0) -
tensorflow/c/c_api_experimental.cc
if (dequeue_op == nullptr) { status->status = tensorflow::errors::Internal( "Unable to find the dequeue node in the TF graph."); return nullptr; } VLOG(1) << "Running the dequeue op"; TF_Output output{dequeue_op, 0}; TF_Tensor* ret; TF_SessionRun(session, /*run_options*/ nullptr, // input related parameters
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Apr 15 03:35:10 UTC 2024 - 29.4K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/ResolveState.java
return selectorState; } @Nullable public NodeState peek() { return queue.isEmpty() ? null : queue.getFirst(); } public NodeState pop() { NodeState next = queue.removeFirst(); return next.dequeue(); } /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 14:19:34 UTC 2024 - 16.7K bytes - Viewed (0) -
tensorflow/c/c_api_experimental.h
// // `tensor` is still owned by the caller. This call will be blocked if the queue // has reached its capacity, and will be unblocked when the queued tensors again // drop below the capacity due to dequeuing. // // Tensors are dequeued via the corresponding TF dequeue op. // TODO(hongm): Add support for `timeout_ms`. TF_CAPI_EXPORT extern void TF_EnqueueNamedTensor(TF_Session* session,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 27 21:07:00 UTC 2023 - 15.1K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/NodeState.java
} // the enqueue and dequeue methods are used for performance reasons // in order to avoid tracking the set of enqueued nodes boolean enqueue() { if (queued) { return false; } queued = true; return true; } NodeState dequeue() { queued = false; return this; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 14:19:34 UTC 2024 - 58.9K bytes - Viewed (0)