- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 136 for clocks (0.16 sec)
-
src/sync/rwmutex.go
runtime_Semrelease(&rw.writerSem, false, 1) } } // Lock locks rw for writing. // If the lock is already locked for reading or writing, // Lock blocks until the lock is available. func (rw *RWMutex) Lock() { if race.Enabled { _ = rw.w.state race.Disable() } // First, resolve competition with other writers. rw.w.Lock() // Announce to readers there is a pending writer.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 7.2K bytes - Viewed (0) -
src/go/types/labels.go
} } } // A block tracks label declarations in a block and its enclosing blocks. type block struct { parent *block // enclosing block lstmt *ast.LabeledStmt // labeled statement to which this block belongs, or nil labels map[string]*ast.LabeledStmt // allocated lazily } // insert records a new label declaration for the current block.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 19:19:55 UTC 2024 - 7.2K bytes - Viewed (0) -
platforms/software/testing-base-infrastructure/src/main/java/org/gradle/api/internal/tasks/testing/SuiteTestClassProcessor.java
Clock clock) { this.suiteDescriptor = suiteDescriptor; this.processor = processor; this.clock = clock; } @Override public void startProcessing(TestResultProcessor testResultProcessor) { try {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 15:59:04 UTC 2024 - 3.3K bytes - Viewed (0) -
src/sync/mutex.go
// Starvation mode is important to prevent pathological cases of tail latency. starvationThresholdNs = 1e6 ) // Lock locks m. // If the lock is already in use, the calling goroutine // blocks until the mutex is available. func (m *Mutex) Lock() { // Fast path: grab unlocked mutex. if atomic.CompareAndSwapInt32(&m.state, 0, mutexLocked) { if race.Enabled { race.Acquire(unsafe.Pointer(m)) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 8.4K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/buildevents/BuildLoggerFactory.java
this.styledTextOutputFactory = styledTextOutputFactory; this.workValidationWarningReporter = workValidationWarningReporter; this.clock = clock; this.gradleEnterprisePluginManager = gradleEnterprisePluginManager; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 17 00:47:05 UTC 2024 - 2.3K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/console/ThrottlingOutputEventListener.java
} ThrottlingOutputEventListener(OutputEventListener listener, int throttleMs, ScheduledExecutorService executor, Clock clock) { this.throttleMs = throttleMs; this.listener = listener; this.executor = executor; this.clock = clock; scheduleUpdateNow(); } private void scheduleUpdateNow() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 3.9K bytes - Viewed (0) -
src/cmd/compile/internal/types2/labels.go
} } } // A block tracks label declarations in a block and its enclosing blocks. type block struct { parent *block // enclosing block lstmt *syntax.LabeledStmt // labeled statement to which this block belongs, or nil labels map[string]*syntax.LabeledStmt // allocated lazily } // insert records a new label declaration for the current block.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 19:19:55 UTC 2024 - 7.2K bytes - Viewed (0) -
platforms/core-runtime/build-profile/src/main/java/org/gradle/profile/ProfileEventAdapter.java
public ProfileEventAdapter(BuildProfile buildProfile, BuildStartedTime buildStartedTime, Clock clock) { this.buildProfile = buildProfile; this.buildStartedTime = buildStartedTime; this.clock = clock; } // BuildListener @Override public void beforeSettings(Settings settings) { long now = clock.getCurrentTime(); buildProfile.setBuildStarted(now);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:39 UTC 2024 - 5.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/healthz.go
// is intended for use primarily for livez health checks. func delayedHealthCheck(check healthz.HealthChecker, clock clock.Clock, delay time.Duration) healthz.HealthChecker { return delayedLivezCheck{ check, clock.Now().Add(delay), clock, } } type delayedLivezCheck struct { check healthz.HealthChecker startCheck time.Time clock clock.Clock } func (c delayedLivezCheck) Name() string {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 6K bytes - Viewed (0) -
src/internal/trace/parser.go
EvGoBlock = 20 // goroutine blocks [timestamp, stack] EvGoUnblock = 21 // goroutine is unblocked [timestamp, goroutine id, seq, stack] EvGoBlockSend = 22 // goroutine blocks on chan send [timestamp, stack] EvGoBlockRecv = 23 // goroutine blocks on chan recv [timestamp, stack] EvGoBlockSelect = 24 // goroutine blocks on select [timestamp, stack]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:31:04 UTC 2024 - 4.7K bytes - Viewed (0)