- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 506 for timers (0.05 seconds)
-
android/guava/src/com/google/common/collect/MapMaker.java
* in {@linkplain WeakReference weak} references. * * <p>Usage example: * * {@snippet : * ConcurrentMap<Request, Stopwatch> timers = new MapMaker() * .concurrencyLevel(4) * .weakKeys() * .makeMap(); * } * * <p>These features are all optional; {@code new MapMaker().makeMap()} returns a valid concurrentCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 12.8K bytes - Click Count (0) -
guava/src/com/google/common/collect/MapMaker.java
* in {@linkplain WeakReference weak} references. * * <p>Usage example: * * {@snippet : * ConcurrentMap<Request, Stopwatch> timers = new MapMaker() * .concurrencyLevel(4) * .weakKeys() * .makeMap(); * } * * <p>These features are all optional; {@code new MapMaker().makeMap()} returns a valid concurrentCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 12.8K bytes - Click Count (0) -
src/cmd/asm/internal/asm/testdata/riscv64.s
CSRRC X0, CYCLE, X0 // 733000c0 CSRRC X10, CYCLE, X5 // f33205c0 CSRRC $2, TIME, X5 // f37211c0 CSRRCI $2, TIME, X5 // f37211c0 CSRRS X0, CYCLE, X5 // f32200c0 CSRRS X0, CYCLE, X0 // 732000c0 CSRRS X10, CYCLE, X5 // f32205c0 CSRRS $2, TIME, X5 // f36211c0 CSRRS X0, VLENB, X5 // f32220c2 CSRRSI $2, TIME, X5 // f36211c0 CSRRW X0, CYCLE, X5 // f31200c0 CSRRW X0, CYCLE, X0 // 731000c0
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Sat Apr 04 05:25:40 GMT 2026 - 74.2K bytes - Click Count (0) -
cmd/tier.go
Name: "tier_ttlb_seconds", Help: "Time taken by requests served by warm tier", Buckets: []float64{0.01, 0.1, 1, 2, 5, 10, 60, 5 * 60, 15 * 60, 30 * 60}, }, []string{"tier"}), } func (t *tierMetrics) Observe(tier string, dur time.Duration) { t.histogram.With(prometheus.Labels{"tier": tier}).Observe(dur.Seconds()) } func (t *tierMetrics) logSuccess(tier string) { t.Lock() defer t.Unlock()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 15.6K bytes - Click Count (0) -
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.
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Sun Jul 06 02:13:03 GMT 2025 - 2.8K bytes - Click Count (0) -
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 {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 45.5K bytes - Click Count (0) -
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
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 33.2K bytes - Click Count (1) -
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) {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 34.7K bytes - Click Count (0) -
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
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 25.6K bytes - Click Count (0) -
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
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 3.9K bytes - Click Count (0)