Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 543 for timers (0.03 sec)

  1. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

        @RetainedLocalRef 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: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8K bytes
    - Viewed (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/AccessTimeoutTarget.java

    import java.util.concurrent.atomic.AtomicBoolean;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.ThreadUtil;
    import org.codelibs.core.timer.TimeoutTarget;
    
    /**
     * AccessTimeoutTarget is a class that implements the TimeoutTarget interface.
     * It is used to interrupt a running thread when a timeout occurs.
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  3. cmd/data-scanner.go

    		d.mu.RUnlock()
    		// Don't sleep for really small amount of time
    		wantSleep := time.Duration(float64(base) * factor)
    		if wantSleep <= minWait {
    			return
    		}
    		if maxWait > 0 && wantSleep > maxWait {
    			wantSleep = maxWait
    		}
    		timer := time.NewTimer(wantSleep)
    		select {
    		case <-ctx.Done():
    			if !timer.Stop() {
    				<-timer.C
    				if d.isScanner {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  4. cmd/data-usage-cache.go

    	for tier, st := range other.Tiers {
    		ats.Tiers[tier] = ats.Tiers[tier].add(st)
    	}
    }
    
    func (ats *allTierStats) clone() *allTierStats {
    	if ats == nil {
    		return nil
    	}
    	dst := *ats
    	dst.Tiers = make(map[string]tierStats, len(ats.Tiers))
    	maps.Copy(dst.Tiers, ats.Tiers)
    	return &dst
    }
    
    func (ats *allTierStats) populateStats(stats map[string]madmin.TierStats) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

       *     ordered by startup time.
       */
      public ImmutableMap<Service, Long> startupTimes() {
        return state.startupTimes();
      }
    
      /**
       * Returns the service load times. This value will only return startup times for services that
       * have finished starting.
       *
       * @return Map of services and their corresponding startup time, the map entries will be ordered
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 17:49:12 UTC 2025
    - 33.2K bytes
    - Viewed (1)
  6. guava/src/com/google/common/util/concurrent/ServiceManager.java

       *     ordered by startup time.
       */
      public ImmutableMap<Service, Long> startupTimes() {
        return state.startupTimes();
      }
    
      /**
       * Returns the service load times. This value will only return startup times for services that
       * have finished starting.
       *
       * @return Map of services and their corresponding startup time, the map entries will be ordered
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 17:49:12 UTC 2025
    - 32.9K bytes
    - Viewed (0)
  7. src/archive/zip/testdata/time-22738.zip

    Russ Cox <******@****.***> 1511973652 -0500
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Fri Dec 01 00:22:21 UTC 2017
    - 140 bytes
    - Viewed (0)
  8. src/archive/zip/testdata/time-winrar.zip

    Joe Tsai <******@****.***> 1503947278 -0700
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Mon Nov 06 19:50:28 UTC 2017
    - 150 bytes
    - Viewed (0)
  9. cmd/tier_gen.go

    			return
    		}
    		switch msgp.UnsafeString(field) {
    		case "Tiers":
    			var zb0002 uint32
    			zb0002, err = dc.ReadMapHeader()
    			if err != nil {
    				err = msgp.WrapError(err, "Tiers")
    				return
    			}
    			if z.Tiers == nil {
    				z.Tiers = make(map[string]madmin.TierConfig, zb0002)
    			} else if len(z.Tiers) > 0 {
    				clear(z.Tiers)
    			}
    			for zb0002 > 0 {
    				zb0002--
    				var za0001 string
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 3.9K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

      }
    
      public void testServiceStartupTimes_selfStartingServices() {
        // This tests to ensure that:
        // 1. service times are accurate when the service is started by the manager
        // 2. service times are recorded when the service is not started by the manager (but they may
        // not be accurate).
        Service b =
            new NoOpDelayedService(353) {
              @Override
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 17:49:12 UTC 2025
    - 25.5K bytes
    - Viewed (0)
Back to top