- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,357 for atomics (0.29 sec)
-
cmd/dynamic-timeouts.go
// We are hitting the timeout too often, so increase the timeout by 25% timeout := atomic.LoadInt64(&dt.timeout) * 125 / 100 // Set upper cap. if timeout > int64(maxDynamicTimeout) { timeout = int64(maxDynamicTimeout) } // Safety, shouldn't happen if timeout < dt.minimum { timeout = dt.minimum } atomic.StoreInt64(&dt.timeout, timeout) } else if failPct < dynamicTimeoutDecreaseThresholdPct {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Aug 19 23:21:05 UTC 2022 - 4.5K bytes - Viewed (0) -
test/fixedbugs/issue16985.go
// issue 16985: intrinsified AMD64 atomic ops should clobber flags package main import "sync/atomic" var count uint32 func main() { buffer := []byte("T") for i := 0; i < len(buffer); { atomic.AddUint32(&count, 1) _ = buffer[i] i++ i++ } for i := 0; i < len(buffer); { atomic.CompareAndSwapUint32(&count, 0, 1) _ = buffer[i] i++ i++ }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 06 14:26:18 UTC 2016 - 625 bytes - Viewed (0) -
src/runtime/lock_sema.go
//go:nowritebarrier func unlock2(l *mutex) { gp := getg() var mp *m for { v := atomic.Loaduintptr(&l.key) 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)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 6.8K 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) -
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/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) -
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)