Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 136 for clocks (0.16 sec)

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