- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 987 for deltas (0.23 sec)
-
pkg/queue/delay.go
func (d *delayQueue) Push(task Task) { d.pushInternal(&delayTask{do: task, runAt: time.Now()}) } // PushDelayed will execute the task after waiting for the delay func (d *delayQueue) PushDelayed(t Task, delay time.Duration) { task := &delayTask{do: t, runAt: time.Now().Add(delay)} d.pushInternal(task) } // pushInternal will enqueue the delayTask with retries. func (d *delayQueue) pushInternal(task *delayTask) { select {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 06:27:31 UTC 2023 - 6.7K bytes - Viewed (0) -
src/math/big/arith.go
// ⎣(B^2-1)/d⎦ = m+B // (B^2-1)/d = m+B+delta1 0 <= delta1 <= (d-1)/d // B^2/d = m+B+delta2 0 <= delta2 <= 1 // The quotient we're trying to compute is // quotient = ⎣(x1*B+x0)/d⎦ // = ⎣(x1*B*(B^2/d)+x0*(B^2/d))/B^2⎦ // = ⎣(x1*B*(m+B+delta2)+x0*(m+B+delta2))/B^2⎦ // = ⎣(x1*m+x1*B+x0)/B + x0*m/B^2 + delta2*(x1*B+x0)/B^2⎦
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 28 20:09:27 UTC 2022 - 8.3K bytes - Viewed (0) -
src/expvar/expvar.go
} func (v *Float) appendJSON(b []byte) []byte { return strconv.AppendFloat(b, math.Float64frombits(v.f.Load()), 'g', -1, 64) } // Add adds delta to v. func (v *Float) Add(delta float64) { for { cur := v.f.Load() curVal := math.Float64frombits(cur) nxtVal := curVal + delta nxt := math.Float64bits(nxtVal) if v.f.CompareAndSwap(cur, nxt) { return } } } // Set sets v to value.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 21:32:11 UTC 2024 - 9.1K bytes - Viewed (0) -
src/time/tick_test.go
t.Log(e) } } for _, test := range []struct { count int delta Duration }{{ count: baseCount, delta: baseDelta, }, { count: 8, delta: 1 * Second, }} { count, delta := test.count, test.delta ticker := NewTicker(delta) t0 := Now() for range count / 2 { <-ticker.C } ticker.Reset(delta * 2) for range count - count/2 { <-ticker.C } ticker.Stop()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
src/cmd/internal/obj/dwarf.go
func putpclcdelta(linkctxt *Link, dctxt dwCtxt, s *LSym, deltaPC uint64, deltaLC int64) { // Choose a special opcode that minimizes the number of bytes needed to // encode the remaining PC delta and LC delta. var opcode int64 if deltaLC < LINE_BASE { if deltaPC >= PC_RANGE { opcode = OPCODE_BASE + (LINE_RANGE * PC_RANGE) } else { opcode = OPCODE_BASE + (LINE_RANGE * int64(deltaPC)) } } else if deltaLC < LINE_BASE+LINE_RANGE {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 01 20:40:28 UTC 2023 - 22K bytes - Viewed (0) -
docs/en/docs/img/sponsors/deta.svg
deta.svg...
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat May 08 17:50:56 UTC 2021 - 55.2K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/ir/tf_generated_ops.td
`result[i] = range(starts[i], limits[i], deltas[i])`. ```python (rt_nested_splits, rt_dense_values) = ragged_range( starts=[2, 5, 8], limits=[3, 5, 12], deltas=1) result = tf.ragged.from_row_splits(rt_dense_values, rt_nested_splits) print(result) <tf.RaggedTensor [[2], [], [8, 9, 10, 11]] > ``` The input tensors `starts`, `limits`, and `deltas` may be scalars or vectors.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Jun 11 23:24:08 UTC 2024 - 793K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/loop_test.go
}, attemptsExpected: 1, expectedIntervals: func(t *testing.T, delays []time.Duration, delaysRequested []time.Duration) { if reflect.DeepEqual(delays, []time.Duration{time.Second}) { return } if !reflect.DeepEqual(delays, delaysRequested) { t.Fatalf("sliding non-immediate should have equal delays: %v", cmp.Diff(delays, delaysRequested)) } }, }, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 02:48:08 UTC 2023 - 15.8K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip.go
key, err := cache.MetaNamespaceKeyFunc(new) if err == nil { r.svcQueue.Add(key) } }, DeleteFunc: func(obj interface{}) { // IndexerInformer uses a delta queue, therefore for deletes we have to use this // key function. key, err := cache.DeletionHandlingMetaNamespaceKeyFunc(obj) if err == nil { r.svcQueue.Add(key) } }, }, interval)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0) -
test/fixedbugs/issue15281.go
f2(c, x) } } func f1(c chan []byte, start int64) { for x := range c { if delta := inuse() - start; delta < 9<<20 { println("BUG: f1: after alloc: expected delta at least 9MB, got: ", delta) println(x) } x = nil if delta := inuse() - start; delta > 1<<20 { println("BUG: f1: after alloc: expected delta below 1MB, got: ", delta) println(x) } } } func f2(c chan []byte, start int64) { for {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 17 09:45:44 UTC 2020 - 1.2K bytes - Viewed (0)