- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 91 for finished (0.21 sec)
-
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* * <p>This method waits 120 seconds before continuing with JVM termination, even if the executor * has not finished its work. * * <p>This is mainly for fixed thread pools. See {@link Executors#newFixedThreadPool(int)}. * * @param executor the executor to modify to make sure it exits when the application is finished * @return an unmodifiable version of the input which will not hang the JVM */ @J2ktIncompatible
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
assertThat(stopwatch.elapsed(MILLISECONDS)).isIn(Range.closed(NOT_ENOUGH_MS, DELAY_MS * 2)); // Is it still computing away anyway? assertThat(target.finished).isFalse(); MILLISECONDS.sleep(ENOUGH_MS); assertThat(target.finished).isFalse(); } public void testNewProxy_badMethodWithEnoughTime() throws Exception { SampleImpl target = new SampleImpl(DELAY_MS);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 9.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/DataIndexHelper.java
} catch (final Exception e) { logger.error("Could not delete old docs at {}", dataConfig, e); } } public boolean isFinished() { return finished; } public void stopCrawling() { if (dataStore != null) { dataStore.stop(); } }
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 12K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/auth/chain/CommandChain.java
} } /** * @param finished * The finished to set. */ public void setFinished(final boolean finished) { this.finished = finished; } /** * @return Returns the teminated. */ public boolean isTeminated() { return teminated; } }
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.3K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/Crc32cHashFunction.java
protected void processRemaining(ByteBuffer bb) { if (finished) { return; } crc0 = combine(0, crc0); crc0 = combine(crc0, crc1); crc0 = combine(crc0, crc2); crc0 = combine(crc0, crc3); while (bb.hasRemaining()) { crc0 = (crc0 >>> 8) ^ BYTE_TABLE[(bb.get() ^ crc0) & 0xFF]; } finished = true; } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 20 18:43:59 GMT 2021 - 21.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/job/ScriptExecutorJob.java
if (scheduledJob.isLoggingEnabled() && logger.isInfoEnabled()) { logger.info("Finished Job {}.", id); } } else { if (scheduledJob.isLoggingEnabled() && logger.isInfoEnabled()) { logger.info("Finished Job {}. The return value is:\n{}", id, ret); } jobLog.setScriptResult(ret.toString());
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 5.3K bytes - Viewed (0) -
build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java
if (executionMode == ExecutionMode.KILL_PROCESSES_STARTED_BY_GRADLE && !Boolean.parseBoolean(System.getenv("GRADLE_RUNNER_FINISHED"))) { // https://github.com/gradle/gradle-private/issues/3991 System.out.println("Gradle runner not finished correctly (the build may be canceled). Fall back to KILL_ALL_GRADLE_PROCESSES."); executionMode = ExecutionMode.KILL_ALL_GRADLE_PROCESSES; }
Java - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Fri Apr 26 09:46:00 GMT 2024 - 11.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
assertThat(stopwatch.elapsed(MILLISECONDS)).isIn(Range.closed(NOT_ENOUGH_MS, DELAY_MS * 2)); // Is it still computing away anyway? assertThat(target.finished).isFalse(); MILLISECONDS.sleep(ENOUGH_MS); assertThat(target.finished).isFalse(); } public void testNewProxy_badMethodWithEnoughTime() throws Exception { SampleImpl target = new SampleImpl(DELAY_MS);
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 9.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/CrawlerLogHelper.java
super.processFinishedCrawling(objs); if (objs.length > 1 && objs[1] instanceof final UrlQueue<?> urlQueue) { ComponentUtil.getCrawlerStatsHelper().record(urlQueue, StatsAction.FINISHED); } } @Override protected void processCrawlingAccessException(final Object... objs) { try { final CrawlerContext crawlerContext = (CrawlerContext) objs[0];
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 6.6K bytes - Viewed (0) -
src/main/java/jcifs/SmbResource.java
* @throws CIFSException * */ SmbRandomAccess openRandomAccess ( String mode, int sharing ) throws CIFSException; /** * Opens the file for random access * * @param mode * access mode (r|rw) * @return random access file, needs to be closed when finished * @throws CIFSException */
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sun Dec 20 14:09:34 GMT 2020 - 26K bytes - Viewed (0)