- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 1,309 for ATOMIC (0.22 sec)
-
src/cmd/vendor/golang.org/x/mod/sumdb/cache.go
entryIface, ok := c.m.Load(key) if !ok { entryIface, _ = c.m.LoadOrStore(key, new(cacheEntry)) } e := entryIface.(*cacheEntry) if atomic.LoadUint32(&e.done) == 0 { e.mu.Lock() if atomic.LoadUint32(&e.done) == 0 { e.result = f() atomic.StoreUint32(&e.done, 1) } e.mu.Unlock() } return e.result } // Get returns the cached result associated with key.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 29 20:10:15 UTC 2019 - 1.5K bytes - Viewed (0) -
platforms/core-runtime/functional/src/test/groovy/org/gradle/internal/lazy/LazyTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:22:02 UTC 2023 - 5.2K bytes - Viewed (0) -
api/go1.23.txt
pkg sync/atomic, func OrUint32(*uint32, uint32) uint32 #61395 pkg sync/atomic, func OrUint64(*uint64, uint64) uint64 #61395 pkg sync/atomic, func OrUintptr(*uintptr, uintptr) uintptr #61395 pkg sync/atomic, method (*Int32) And(int32) int32 #61395 pkg sync/atomic, method (*Int32) Or(int32) int32 #61395 pkg sync/atomic, method (*Int64) And(int64) int64 #61395 pkg sync/atomic, method (*Int64) Or(int64) int64 #61395
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 05 20:48:49 UTC 2024 - 8.4K bytes - Viewed (0) -
src/cmd/go/testdata/script/build_output.txt
exists -exec mygofmt ! exists mygofmt.exe ! exists gofmt ! exists gofmt.exe go build sync/atomic ! exists atomic ! exists atomic.exe go build -o myatomic.a sync/atomic exists myatomic.a exec $GOBIN/isarchive myatomic.a ! exists atomic ! exists atomic.a ! exists atomic.exe ! go build -o whatever cmd/gofmt sync/atomic stderr 'multiple packages' -- go.mod -- module m go 1.16 -- x.go --
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 24 21:26:10 UTC 2022 - 1.8K bytes - Viewed (0) -
src/runtime/race.go
func abigen_sync_atomic_LoadUint64(addr *uint64) (val uint64) //go:linkname abigen_sync_atomic_LoadUintptr sync/atomic.LoadUintptr func abigen_sync_atomic_LoadUintptr(addr *uintptr) (val uintptr) //go:linkname abigen_sync_atomic_LoadPointer sync/atomic.LoadPointer func abigen_sync_atomic_LoadPointer(addr *unsafe.Pointer) (val unsafe.Pointer) //go:linkname abigen_sync_atomic_StoreInt32 sync/atomic.StoreInt32
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:37:29 UTC 2024 - 20.4K bytes - Viewed (0) -
test/codegen/atomics.go
// These tests check that atomic instructions without dynamic checks are // generated for architectures that support them package codegen import "sync/atomic" type Counter struct { count int32 } func (c *Counter) Increment() { // Check that ARm64 v8.0 has both atomic instruction (LDADDALW) and a dynamic check // (for arm64HasATOMICS), while ARM64 v8.1 has only atomic and no dynamic check.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 20:08:06 UTC 2024 - 728 bytes - Viewed (0) -
pkg/test/echo/server/forwarder/executor.go
"github.com/hashicorp/go-multierror" "go.uber.org/atomic" "golang.org/x/sync/semaphore" ) const ( maxConcurrencyPerForward = 20 ) type executor struct { totalRequests *atomic.Uint64 activeRequests *atomic.Uint64 stopCh chan struct{} } func newExecutor() *executor { e := &executor{ totalRequests: atomic.NewUint64(0), activeRequests: atomic.NewUint64(0), stopCh: make(chan struct{}),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 10 18:09:08 UTC 2022 - 2K bytes - Viewed (0) -
src/runtime/runtime_unix_test.go
package runtime_test import ( "runtime" "sync" "sync/atomic" "syscall" "testing" ) func TestGoroutineProfile(t *testing.T) { // GoroutineProfile used to use the wrong starting sp for // goroutines coming out of system calls, causing possible // crashes. defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(100)) var stop uint32 defer atomic.StoreUint32(&stop, 1) // in case of panic var wg sync.WaitGroup
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 28 18:17:57 UTC 2021 - 1.2K bytes - Viewed (0) -
src/runtime/lfstack.go
throw("lfstack.push") } for { old := atomic.Load64((*uint64)(head)) node.next = old if atomic.Cas64((*uint64)(head), old, new) { break } } } func (head *lfstack) pop() unsafe.Pointer { for { old := atomic.Load64((*uint64)(head)) if old == 0 { return nil } node := lfstackUnpack(old) next := atomic.Load64(&node.next) if atomic.Cas64((*uint64)(head), old, next) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 2K bytes - Viewed (0) -
test/escape_runtime_atomic.go
// Test escape analysis for internal/runtime/atomic. package escape import ( "internal/runtime/atomic" "unsafe" ) // BAD: should always be "leaking param: addr to result ~r0 level=1$". func Loadp(addr unsafe.Pointer) unsafe.Pointer { // ERROR "leaking param: addr( to result ~r0 level=1)?$" return atomic.Loadp(addr) } var ptr unsafe.Pointer func Storep() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 874 bytes - Viewed (0)