- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 120 for Finished (0.24 sec)
-
guava/src/com/google/common/util/concurrent/ClosingFuture.java
* to be closed asynchronously <b>after</b> the returned {@code Future} is done: the future * completes before closing starts, rather than once it has finished. * * {@snippet : * FluentFuture<UserName> userName = * ClosingFuture.submit( * closer -> closer.eventuallyClose(database.newTransaction(), closingExecutor), * executor)
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 23 15:26:56 UTC 2025 - 98.1K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/MessageDeflaterInflaterTest.kt
} /** * We had a bug where self-finishing inflater streams would infinite loop! * https://github.com/square/okhttp/issues/8078 */ @Test fun `inflate returns finished before bytesRead reaches input length`() { val inflater = MessageInflater(false) val message = "53621260020000".decodeHex() assertThat(inflater.inflate(message)).isEqualTo("22021002".decodeHex()) }Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/joblog/EditForm.java
*/ @Required public String startTime; /** * The timestamp when the job completed execution. * This field indicates when the job finished, if it has completed. */ public String endTime; /** * Initializes the form with default null values. * This method resets all fields to their default state for creating a new entry.Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 3.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/JobLogService.java
jobLogBhv.queryDelete(cb -> { cb.query().setJobStatus_InScope(jobStatusList); }); } /** * Updates the status of expired jobs that haven't finished. * Jobs that have been running longer than the expired job interval * without an end time are marked as failed. */ public void updateStatus() {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 6.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java
EVALUATED, /** Indicates that a general exception occurred during processing. */ EXCEPTION, /** Indicates that processing of a URL has finished. */ FINISHED, /** Indicates that content was successfully parsed. */ PARSED, /** Indicates that a URL was prepared for crawling. */ PREPARED,Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 17.4K bytes - Viewed (0) -
docs/en/docs/advanced/events.md
The first part of the function, before the `yield`, will be executed **before** the application starts. And the part after the `yield` will be executed **after** the application has finished. ### Async Context Manager { #async-context-manager } If you check, the function is decorated with an `@asynccontextmanager`. That converts the function into something called an "**async context manager**".Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 7.9K 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) { String failureUrlId = "?";
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 8.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
// be a definite performance hit to those users. thrownReflectionFailure = reflectionFailure; helper = new SynchronizedAtomicHelper(); } ATOMIC_HELPER = helper; // Log after all static init is finished; if an installed logger uses any Futures methods, it // shouldn't break in cases where reflection is missing/broken. if (thrownReflectionFailure != null) {Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 8.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
@Override public void run() {} } // The thread executing the task publishes itself to the superclass' reference and the thread // interrupting sets DONE when it has finished interrupting. private static final Runnable DONE = new DoNothingRunnable(); private static final Runnable PARKED = new DoNothingRunnable(); // Why 1000? WHY NOT! private static final int MAX_BUSY_WAIT_SPINS = 1000;Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 10K bytes - Viewed (0) -
.teamcity/mvnw.cmd
"}"^ "[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12; $webclient.DownloadFile('%DOWNLOAD_URL%', '%WRAPPER_JAR%')"^ "}" if "%MVNW_VERBOSE%" == "true" ( echo Finished downloading %WRAPPER_JAR% ) ) @REM End of extension @REM Provide a "standardized" way to retrieve the CLI args that will @REM work with both Windows and non-Windows executions. set MAVEN_CMD_LINE_ARGS=%*
Registered: Wed Sep 10 11:36:15 UTC 2025 - Last Modified: Wed Feb 26 01:48:39 UTC 2020 - 6.5K bytes - Viewed (0)