- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 502 for timerC (0.21 sec)
-
src/runtime/chan.go
// It reports whether any elements were removed. // Because it is only intended for timers, it does not // handle waiting senders at all (all timer channels // use non-blocking sends to fill the buffer). func timerchandrain(c *hchan) bool { // Note: Cannot use empty(c) because we are called // while holding c.timer.sendLock, and empty(c) will // call c.timer.maybeRunChan, which will deadlock. // We are emptying the channel, so we only care about
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0) -
pkg/util/async/bounded_frequency_runner_test.go
// Do the deferred run timer.advance(1 * time.Millisecond) // rel=1000ms waitForRun("second run", t, timer, obj) // Try again immediately runner.Run() waitForDefer("too soon after second", t, timer, obj, 1*time.Second) // Run again, before minInterval expires. timer.advance(1 * time.Millisecond) // rel=1ms runner.Run()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 15 09:36:26 UTC 2022 - 12.5K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/zsysnum_netbsd_arm64.go
SYS_TIMER_CREATE = 235 // { int|sys||timer_create(clockid_t clock_id, struct sigevent *evp, timer_t *timerid); } SYS_TIMER_DELETE = 236 // { int|sys||timer_delete(timer_t timerid); } SYS_TIMER_GETOVERRUN = 239 // { int|sys||timer_getoverrun(timer_t timerid); } SYS_FDATASYNC = 241 // { int|sys||fdatasync(int fd); } SYS_MLOCKALL = 242 // { int|sys||mlockall(int flags); }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 25.7K bytes - Viewed (0) -
pkg/util/async/bounded_frequency_runner.go
// See time.Sleep. Sleep(d time.Duration) } // implement our timer in terms of std time.Timer. type realTimer struct { timer *time.Timer next time.Time } func (rt *realTimer) C() <-chan time.Time { return rt.timer.C } func (rt *realTimer) Reset(d time.Duration) bool { rt.next = time.Now().Add(d) return rt.timer.Reset(d) } func (rt *realTimer) Stop() bool { return rt.timer.Stop() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 15 09:36:26 UTC 2022 - 9.4K bytes - Viewed (0) -
platforms/core-runtime/time/src/test/groovy/org/gradle/internal/time/DefaultTimerTest.groovy
then: timer.getElapsed() == "51.243 secs" } def testOnlySecondsEvenMs() { when: setTime(4000) then: timer.getElapsed() == "4.0 secs" } def testMinutesAndSeconds() { when: setTime(0, 32, 40, 322) then: timer.getElapsed() == "32 mins 40.322 secs" } def testHoursMinutesAndSeconds() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 20:20:17 UTC 2024 - 2.2K bytes - Viewed (0) -
build-logic/lifecycle/src/main/kotlin/PrintStackTracesOnTimeoutBuildService.kt
interface Params : BuildServiceParameters { val timeoutMillis: Property<Long> val projectDirectory: DirectoryProperty } private val timer: Timer = Timer(true).apply { schedule( timerTask { execOperations.exec { commandLine( "${System.getProperty("java.home")}/bin/java",
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 22 07:59:48 UTC 2024 - 1.9K bytes - Viewed (0) -
src/context/context.go
} // A timerCtx carries a timer and a deadline. It embeds a cancelCtx to // implement Done and Err. It implements cancel by stopping its timer then // delegating to cancelCtx.cancel. type timerCtx struct { cancelCtx timer *time.Timer // Under cancelCtx.mu. deadline time.Time } func (c *timerCtx) Deadline() (deadline time.Time, ok bool) { return c.deadline, true }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 23.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
Future<?> localTimer = timer; // Try to cancel the timer as an optimization. // timer may be null if this call to run was by the timer task since there is no happens-before // edge between the assignment to timer and an execution of the timer task. if (localTimer != null) { localTimer.cancel(false); } delegateRef = null; timer = null; }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 7.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/TimeoutFuture.java
Future<?> localTimer = timer; // Try to cancel the timer as an optimization. // timer may be null if this call to run was by the timer task since there is no happens-before // edge between the assignment to timer and an execution of the timer task. if (localTimer != null) { localTimer.cancel(false); } delegateRef = null; timer = null; }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 7.7K bytes - Viewed (0) -
src/runtime/proc.go
continue } // Steal timers from p2. This call to checkTimers is the only place // where we might hold a lock on a different P's timers. We do this // once on the last pass before checking runnext because stealing // from the other P's runnext should be the last resort, so if there // are timers to steal do that first. // // We only check timers on one of the stealing iterations because
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0)