Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 481 for Timers (0.13 sec)

  1. src/main/webapp/js/admin/jquery-3.7.1.min.map

    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Oct 26 01:07:52 UTC 2024
    - 131.6K bytes
    - Viewed (0)
  2. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8K bytes
    - Viewed (0)
  3. 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: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  4. cmd/data-scanner.go

    		}
    		if maxWait > 0 && wantSleep > maxWait {
    			wantSleep = maxWait
    		}
    		timer := time.NewTimer(wantSleep)
    		select {
    		case <-ctx.Done():
    			if !timer.Stop() {
    				<-timer.C
    				if d.isScanner {
    					globalScannerMetrics.incTime(scannerMetricYield, wantSleep)
    				}
    			}
    			return
    		case <-timer.C:
    			if d.isScanner {
    				globalScannerMetrics.incTime(scannerMetricYield, wantSleep)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  5. cmd/data-usage-cache.go

    // tiers.
    type allTierStats struct {
    	Tiers map[string]tierStats `msg:"ts"`
    }
    
    func newAllTierStats() *allTierStats {
    	return &allTierStats{
    		Tiers: make(map[string]tierStats),
    	}
    }
    
    func (ats *allTierStats) addSizes(tiers map[string]tierStats) {
    	for tier, st := range tiers {
    		ats.Tiers[tier] = ats.Tiers[tier].add(st)
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

       */
      @Override
      public ImmutableSetMultimap<State, Service> servicesByState() {
        return state.servicesByState();
      }
    
      /**
       * 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 in millis, the map entries will be
       *     ordered by startup time.
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 33.2K bytes
    - Viewed (1)
  7. doc/godebug.md

    the Go 1.23 behavior.
    
    ### Go 1.23
    
    Go 1.23 changed the channels created by package time to be unbuffered
    (synchronous), which makes correct use of the [`Timer.Stop`](/pkg/time/#Timer.Stop)
    and [`Timer.Reset`](/pkg/time/#Timer.Reset) method results much easier.
    The [`asynctimerchan` setting](/pkg/time/#NewTimer) disables this change.
    There are no runtime metrics for this change,
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Jul 08 18:30:38 UTC 2025
    - 22.9K bytes
    - Viewed (0)
  8. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 20:34:52 UTC 2025
    - 25.5K 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 {
    				for key := range z.Tiers {
    					delete(z.Tiers, key)
    				}
    			}
    			for zb0002 > 0 {
    				zb0002--
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Jun 20 00:53:08 UTC 2023
    - 4K bytes
    - Viewed (0)
  10. src/test/java/jcifs/NameServiceClientTest.java

    import static org.junit.jupiter.api.Assertions.assertNotNull;
    import static org.junit.jupiter.api.Assertions.assertThrows;
    import static org.mockito.Mockito.mock;
    import static org.mockito.Mockito.times;
    import static org.mockito.Mockito.verify;
    import static org.mockito.Mockito.when;
    
    import java.net.InetAddress;
    import java.net.UnknownHostException;
    
    import org.junit.jupiter.api.BeforeEach;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.4K bytes
    - Viewed (0)
Back to top