Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 120 for Finished (0.24 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. .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)
Back to top