- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 544 for atomics (0.27 sec)
-
src/internal/runtime/atomic/doc.go
// Copyright 2021 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. /* Package atomic provides atomic operations, independent of sync/atomic, to the runtime. On most platforms, the compiler is aware of the functions defined in this package, and they're replaced with platform-specific intrinsics. On other platforms, generic implementations are made available.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 771 bytes - Viewed (0) -
src/runtime/sigqueue.go
// as there is no connection between handling a signal and receiving one, // but atomic instructions should minimize it. var sig struct { note note mask [(_NSIG + 31) / 32]uint32 wanted [(_NSIG + 31) / 32]uint32 ignored [(_NSIG + 31) / 32]uint32 recv [(_NSIG + 31) / 32]uint32 state atomic.Uint32 delivering atomic.Uint32 inuse bool } const ( sigIdle = iota sigReceiving
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 7.6K bytes - Viewed (0) -
src/cmd/go/init_test.go
for pb.Next() { cmd := testenv.Command(b, gotool, "env", "GOARCH") if err := cmd.Run(); err != nil { b.Fatal(err) } atomic.AddInt64(&n, 1) atomic.AddInt64(&userTime, int64(cmd.ProcessState.UserTime())) atomic.AddInt64(&systemTime, int64(cmd.ProcessState.SystemTime())) } }) b.ReportMetric(float64(userTime)/float64(n), "user-ns/op")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 15 20:21:26 UTC 2022 - 1.1K bytes - Viewed (0) -
cmd/data-scanner-metric.go
duration := time.Since(startTime) atomic.AddUint64(&p.operations[s], 1) if s < scannerMetricLastRealtime { p.latency[s].addSize(duration, int64(sz)) } } } // incTime will increment time on metric s with a specific duration. // Use for s < scannerMetricLastRealtime func (p *scannerMetrics) incTime(s scannerMetric, d time.Duration) { atomic.AddUint64(&p.operations[s], 1)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 25 05:15:31 UTC 2023 - 9.1K bytes - Viewed (0) -
staging/src/k8s.io/api/rbac/v1/generated.proto
// +listType=atomic repeated string verbs = 1; // APIGroups is the name of the APIGroup that contains the resources. If multiple API groups are specified, any action requested against one of // the enumerated resources in any API group will be allowed. "" represents the core API group and "*" represents all API groups. // +optional // +listType=atomic repeated string apiGroups = 2;
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 28 15:34:11 UTC 2024 - 7.9K bytes - Viewed (0) -
src/runtime/vdso_freebsd.go
for { if timekeepSharedPage.enabled == 0 { return zeroBintime } curr := atomic.Load(&timekeepSharedPage.current) // atomic_load_acq_32 th := &timehands[curr] gen := atomic.Load(&th.gen) // atomic_load_acq_32 bt = th.offset if tc, ok := th.getTimecounter(); !ok { return zeroBintime } else {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 2.4K bytes - Viewed (0) -
src/cmd/cgo/internal/testcarchive/testdata/libgo8/a.go
package main import "C" import ( "os" "runtime" "sync/atomic" ) var started int32 // Start a goroutine that loops forever. func init() { runtime.GOMAXPROCS(1) go func() { for { atomic.StoreInt32(&started, 1) } }() } //export GoFunction8 func GoFunction8() { for atomic.LoadInt32(&started) == 0 { runtime.Gosched() } os.Exit(0) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 529 bytes - Viewed (0) -
platforms/software/testing-base/src/main/java/org/gradle/api/tasks/testing/logging/TestLogEvent.java
public enum TestLogEvent { /** * A test has started. This event gets fired both for atomic and composite tests. */ STARTED, /** * A test has completed successfully. This event gets fired both for atomic and composite tests. */ PASSED, /** * A test has been skipped. This event gets fired both for atomic and composite tests. */ SKIPPED, /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/events/test/JvmTestKind.java
*/ package org.gradle.tooling.events.test; /** * Enumerates the different kinds of JVM tests. This allows to differentiate between test suites, atomic tests, etc. * * @since 2.4 */ public enum JvmTestKind { SUITE("Test suite"), ATOMIC("Atomic test"), UNKNOWN("Unknown test kind"); private final String label; JvmTestKind(String label) { this.label = label; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 1.2K bytes - Viewed (0) -
pkg/controller/tainteviction/timed_workers_test.go
package tainteviction import ( "context" "sync" "sync/atomic" "testing" "time" "k8s.io/klog/v2/ktesting" testingclock "k8s.io/utils/clock/testing" ) func TestExecute(t *testing.T) { testVal := int32(0) wg := sync.WaitGroup{} wg.Add(5) queue := CreateWorkerQueue(func(ctx context.Context, fireAt time.Time, args *WorkArgs) error { atomic.AddInt32(&testVal, 1) wg.Done() return nil })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:23:56 UTC 2023 - 5.6K bytes - Viewed (0)