- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 61 for Timer (0.07 sec)
-
src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java
import org.apache.commons.lang3.SystemUtils; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.timer.TimeoutTask; import org.codelibs.fess.Constants; import org.codelibs.fess.exception.JobProcessingException; import org.codelibs.fess.exec.ThumbnailGenerator; import org.codelibs.fess.helper.ProcessHelper;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 10.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/SuggestJob.java
import org.apache.commons.lang3.SystemUtils; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.timer.TimeoutTask; import org.codelibs.fess.Constants; import org.codelibs.fess.exception.JobProcessingException; import org.codelibs.fess.exec.SuggestCreator; import org.codelibs.fess.helper.ProcessHelper;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sun Jun 23 04:13:47 UTC 2024 - 10K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
assertThat(startupTimes).hasSize(2); assertThat(startupTimes.get(a)).isAtLeast(150); // Service b startup takes at least 353 millis, but starting the timer is delayed by at least // 150 milliseconds. so in a perfect world the timing would be 353-150=203ms, but since either // of our sleep calls can be arbitrarily delayed we should just assert that there is a time
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 25.5K bytes - Viewed (0) -
cmd/erasure-multipart.go
if err == nil { modTime = time.Unix(0, t) } } } // Fallback for older uploads without time in the ID. if modTime.IsZero() { wait := deleteMultipartCleanupSleeper.Timer(ctx) fi, err := disk.ReadVersion(ctx, "", minioMetaMultipartBucket, uploadIDPath, "", ReadOptions{}) if err != nil { return nil } modTime = fi.ModTime wait() }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 44.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
setState(finalState); return true; } /** * Blocks until the task is complete or the timeout expires. Throws a {@link TimeoutException} * if the timer expires, otherwise behaves like {@link #get()}. */ V get(long nanos) throws TimeoutException, CancellationException, ExecutionException, InterruptedException {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 13.6K bytes - Viewed (0) -
src/main/java/org/codelibs/core/io/FileUtil.java
import java.nio.charset.Charset; import java.nio.file.Files; import org.codelibs.core.exception.IORuntimeException; import org.codelibs.core.net.URLUtil; import org.codelibs.core.nio.ChannelUtil; import org.codelibs.core.timer.TimeoutManager; /** * {@link File}を扱うユーティリティ・クラスです。 * * @author higa */ public abstract class FileUtil { /** UTF-8のエンコーディング名 */ private static final String UTF8 = "UTF-8";
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
*/ ServiceManagerState(ImmutableCollection<Service> services) { this.numberOfServices = services.size(); servicesByState.putAll(NEW, services); } /** * Attempts to start the timer immediately prior to the service being started via {@link * Service#startAsync()}. */ void tryStartTiming(Service service) { monitor.enter(); try {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 33.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ServiceManager.java
*/ ServiceManagerState(ImmutableCollection<Service> services) { this.numberOfServices = services.size(); servicesByState.putAll(NEW, services); } /** * Attempts to start the timer immediately prior to the service being started via {@link * Service#startAsync()}. */ void tryStartTiming(Service service) { monitor.enter(); try {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 33.2K bytes - Viewed (0) -
cmd/metrics-resource.go
collectLocalResourceMetrics() for { select { case <-GlobalContext.Done(): return case <-metricsTimer.C: collectLocalResourceMetrics() // Reset the timer for next cycle. metricsTimer.Reset(resourceMetricsCollectionInterval) } } } // minioResourceCollector is the Collector for resource metrics type minioResourceCollector struct {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 24 23:30:33 UTC 2024 - 17.2K bytes - Viewed (0) -
cmd/iam.go
randAmt := time.Duration(r.Float64() * float64(baseInterval)) return baseInterval/2 + randAmt } timer := time.NewTimer(waitInterval()) defer timer.Stop() lastPurgeHour := -1 for { select { case <-timer.C: // Load all IAM items (except STS creds) periodically. refreshStart := time.Now() if err := sys.Load(ctx, false); err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 29 16:01:48 UTC 2024 - 74.6K bytes - Viewed (0)