Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 502 for timerC (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top