- Sort Score
- Result 10 results
- Languages All
Results 271 - 280 of 370 for Runnable (0.33 sec)
-
guava/src/com/google/common/escape/Escaper.java
* implementing new escapers. It is strongly recommended that when implementing a new escaper you * extend one of these classes. If you find that you are unable to achieve the desired behavior * using either of these classes, please contact the Java libraries team for advice. * * <p>Popular escapers are defined as constants in classes like {@link
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Feb 13 15:45:16 UTC 2025 - 4.7K bytes - Viewed (0) -
android/guava/src/com/google/common/io/Files.java
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 32.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
RateLimiter r = RateLimiter.create(1); assertTrue("Unable to acquire initial permit", r.tryAcquire()); assertFalse("Capable of acquiring secondary permit", r.tryAcquire()); } public void testDoubleMinValueCanAcquireExactlyOnce() { RateLimiter r = RateLimiter.create(Double.MIN_VALUE, stopwatch); assertTrue("Unable to acquire initial permit", r.tryAcquire());
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 21.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
RateLimiter r = RateLimiter.create(1); assertTrue("Unable to acquire initial permit", r.tryAcquire()); assertFalse("Capable of acquiring secondary permit", r.tryAcquire()); } public void testDoubleMinValueCanAcquireExactlyOnce() { RateLimiter r = RateLimiter.create(Double.MIN_VALUE, stopwatch); assertTrue("Unable to acquire initial permit", r.tryAcquire());
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 21.9K bytes - Viewed (0) -
cmd/metacache-stream.go
} if len(objs) == 0 { return nil } if w.creator != nil { err := w.creator() w.creator = nil if err != nil { return fmt.Errorf("metacacheWriter: unable to create writer: %w", err) } if w.mw == nil { return errors.New("metacacheWriter: writer not initialized") } } for _, o := range objs { if len(o.name) == 0 {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed May 07 15:37:12 UTC 2025 - 19.5K bytes - Viewed (0) -
cmd/metrics-v3-cluster-usage.go
for bucket, usage := range dataUsageInfo.BucketsUsage { quota, err := globalBucketQuotaSys.Get(ctx, bucket) if err != nil { // Log and continue if we are unable to retrieve metrics for this // bucket. metricsLogIf(ctx, err) continue } m.Set(usageBucketTotalBytes, float64(usage.Size), "bucket", bucket)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 6.5K bytes - Viewed (0) -
cmd/consolelogger.go
func (sys *HTTPConsoleLoggerSys) SetNodeName(nodeName string) { if !globalIsDistErasure { sys.nodeName = "" return } host, err := xnet.ParseHost(globalLocalNodeName) if err != nil { logger.FatalIf(err, "Unable to start console logging subsystem") } sys.nodeName = host.Name } // HasLogListeners returns true if console log listeners are registered // for this node or peers
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.4K bytes - Viewed (0) -
docs/debugging/s3-check-md5/main.go
} var minModTime time.Time if minModTimeStr != "" { var e error minModTime, e = time.Parse(time.RFC3339, minModTimeStr) if e != nil { log.Fatalln("Unable to parse --modified-since:", e) } } u, err := url.Parse(endpoint) if err != nil { log.Fatalln(err) } secure := strings.EqualFold(u.Scheme, "https")
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sat Feb 17 01:15:57 UTC 2024 - 6.3K bytes - Viewed (0) -
guava/src/com/google/common/io/Files.java
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 32.9K bytes - Viewed (0) -
docs/id/docs/tutorial/path-params.md
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 10:29:01 UTC 2025 - 8.8K bytes - Viewed (0)