- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 2,460 for syncs (0.04 sec)
-
src/runtime/atomic_pointer.go
} // Like above, but implement in terms of sync/atomic's uintptr operations. // We cannot just call the runtime routines, because the race detector expects // to be able to intercept the sync/atomic forms but not the runtime forms. //go:linkname sync_atomic_StoreUintptr sync/atomic.StoreUintptr func sync_atomic_StoreUintptr(ptr *uintptr, new uintptr) //go:linkname sync_atomic_StorePointer sync/atomic.StorePointer //go:nosplit
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 4K bytes - Viewed (0) -
src/runtime/race/timer_test.go
// license that can be found in the LICENSE file. //go:build race package race_test import ( "sync" "testing" "time" ) func TestTimers(t *testing.T) { const goroutines = 8 var wg sync.WaitGroup wg.Add(goroutines) var mu sync.Mutex for i := 0; i < goroutines; i++ { go func() { defer wg.Done() ticker := time.NewTicker(1) defer ticker.Stop()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 28 18:17:57 UTC 2021 - 576 bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
return sync.get(); } @Override public boolean isDone() { return sync.isDone(); } @Override public boolean isCancelled() { return sync.isCancelled(); } @CanIgnoreReturnValue @Override public boolean cancel(boolean mayInterruptIfRunning) { if (!sync.cancel(mayInterruptIfRunning)) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Apr 06 12:56:11 UTC 2023 - 13.6K bytes - Viewed (0) -
src/internal/pkgbits/encoder.go
// marker. A negative value means sync markers are omitted. syncFrames int } // SyncMarkers reports whether pw uses sync markers. func (pw *PkgEncoder) SyncMarkers() bool { return pw.syncFrames >= 0 } // NewPkgEncoder returns an initialized PkgEncoder. // // syncFrames is the number of caller frames that should be serialized
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Aug 10 23:26:58 UTC 2022 - 9.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
return sync.get(); } @Override public boolean isDone() { return sync.isDone(); } @Override public boolean isCancelled() { return sync.isCancelled(); } @CanIgnoreReturnValue @Override public boolean cancel(boolean mayInterruptIfRunning) { if (!sync.cancel(mayInterruptIfRunning)) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 09 15:17:25 UTC 2018 - 13.6K bytes - Viewed (0) -
src/sync/atomic/value_test.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package atomic_test import ( "math/rand" "runtime" "strconv" "sync" "sync/atomic" . "sync/atomic" "testing" ) func TestValue(t *testing.T) { var v Value if v.Load() != nil { t.Fatal("initial Value is not nil") } v.Store(42) x := v.Load()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 6.1K bytes - Viewed (0) -
pkg/kubelet/lifecycle/interfaces.go
} // PodSyncLoopHandler is invoked during each sync loop iteration. type PodSyncLoopHandler interface { // ShouldSync returns true if the pod needs to be synced. // This operation must return immediately as its called for each pod. // The provided pod should never be modified. ShouldSync(pod *v1.Pod) bool } // PodSyncLoopTarget maintains a list of handlers to pod sync loop. type PodSyncLoopTarget interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 22 17:25:57 UTC 2017 - 4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/waitgroup/waitgroup.go
*/ package waitgroup import ( "fmt" "sync" ) // SafeWaitGroup must not be copied after first use. type SafeWaitGroup struct { wg sync.WaitGroup mu sync.RWMutex // wait indicate whether Wait is called, if true, // then any Add with positive delta will return error. wait bool } // Add adds delta, which may be negative, similar to sync.WaitGroup.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 11 03:04:14 UTC 2018 - 1.5K bytes - Viewed (0) -
platforms/documentation/docs/src/snippets/java-feature-variant/requiring-features-external/tests/runtimeClasspath.out
org.mongodb:bson:3.9.1 +--- org.mongodb:mongodb-driver-core:3.9.1 | \--- org.mongodb:mongodb-driver-sync:3.9.1 | \--- org.gradle.demo:producer:1.0 | \--- runtimeClasspath \--- org.mongodb:mongodb-driver-sync:3.9.1 (*) org.mongodb:mongodb-driver-core:3.9.1 Variant runtime: | Attribute Name | Provided | Requested |
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 2.8K bytes - Viewed (0) -
src/runtime/race/testdata/sync_test.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package race_test import ( "sync" "testing" "time" ) func TestNoRaceCond(t *testing.T) { x := 0 _ = x condition := 0 var mu sync.Mutex cond := sync.NewCond(&mu) go func() { x = 1 mu.Lock() condition = 1 cond.Signal() mu.Unlock() }() mu.Lock() for condition != 1 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 10 15:05:17 UTC 2020 - 3K bytes - Viewed (0)