- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 61 for Timer (0.04 sec)
-
src/main/java/org/codelibs/fess/helper/JobHelper.java
import java.util.Map; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.timer.TimeoutManager; import org.codelibs.core.timer.TimeoutTarget; import org.codelibs.core.timer.TimeoutTask; import org.codelibs.fess.Constants; import org.codelibs.fess.es.config.exbhv.JobLogBhv; import org.codelibs.fess.es.config.exbhv.ScheduledJobBhv;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 8.1K bytes - Viewed (0) -
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 Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 8.1K bytes - Viewed (0) -
cmd/benchmark-utils_test.go
sha256hex := "" // benchmark utility which helps obtain number of allocations and bytes allocated per ops. b.ReportAllocs() // the actual benchmark for PutObject starts here. Reset the benchmark timer. b.ResetTimer() for i := 0; i < b.N; i++ { // insert the object. objInfo, err := obj.PutObject(context.Background(), bucket, "object"+strconv.Itoa(i),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Dec 23 15:46:00 UTC 2022 - 8.2K bytes - Viewed (0) -
cmd/url_test.go
b.ReportAllocs() // the actual benchmark for PutObject starts here. Reset the benchmark timer. b.ResetTimer() if err := req.ParseForm(); err != nil { b.Fatal(err) } b.RunParallel(func(pb *testing.PB) { for pb.Next() { req.Form.Get("uploadId") } }) // Benchmark ends here. Stop timer. b.StopTimer() } // BenchmarkURLQuery - benchmark URL memory allocations
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Nov 16 17:28:29 UTC 2021 - 2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java
import org.codelibs.core.misc.DynamicProperties; import org.codelibs.core.timer.TimeoutManager; import org.codelibs.core.timer.TimeoutTask; import org.codelibs.fess.Constants; import org.codelibs.fess.crawler.client.FesenClient; import org.codelibs.fess.es.client.SearchEngineClient; import org.codelibs.fess.exception.ContainerNotAvailableException; import org.codelibs.fess.timer.SystemMonitorTarget; import org.codelibs.fess.util.ComponentUtil;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 8.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/timer/MonitorTarget.java
* governing permissions and limitations under the License. */ package org.codelibs.fess.timer; import java.io.IOException; import java.io.PrintWriter; import java.util.Arrays; import java.util.function.Supplier; import org.apache.commons.io.output.ByteArrayOutputStream; import org.apache.commons.text.StringEscapeUtils; import org.codelibs.core.timer.TimeoutTarget; import org.codelibs.fess.Constants;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java
protected File baseDir; private Timer destoryTimer; @PostConstruct public void init() { if (logger.isDebugEnabled()) { logger.debug("Initialize {}", this.getClass().getSimpleName()); } if (baseDir == null) { baseDir = new File(System.getProperty("java.io.tmpdir")); }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 9.6K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutTask.java
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, * either express or implied. See the License for the specific language * governing permissions and limitations under the License. */ package org.codelibs.core.timer; import org.codelibs.core.exception.ClIllegalStateException; /** * タイムアウトを管理するクラスです。 * * @author higa * */ public class TimeoutTask { private static final int ACTIVE = 0;
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 2.7K bytes - Viewed (0) -
internal/dsync/dsync_test.go
dm.GetLock(ctx, nil, id, source, Options{Timeout: 5 * time.Minute}) unlockReturned <- struct{}{} }() timer := time.NewTimer(2 * testDrwMutexUnlockCallTimeout) defer timer.Stop() select { case <-unlockReturned: t.Fatal("Unlock timed out, which should not happen") case <-timer.C: } } // Borrowed from mutex_test.go func HammerMutex(m *DRWMutex, loops int, cdone chan bool) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 19 14:35:19 UTC 2024 - 11.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/Crawler.java
import org.codelibs.core.lang.StringUtil; import org.codelibs.core.lang.ThreadUtil; import org.codelibs.core.misc.DynamicProperties; import org.codelibs.core.timer.TimeoutManager; import org.codelibs.core.timer.TimeoutTask; import org.codelibs.fess.Constants; import org.codelibs.fess.app.service.CrawlingInfoService; import org.codelibs.fess.app.service.PathMappingService;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 24K bytes - Viewed (0)