Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 46 for Stopped (0.07 sec)

  1. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

          new ListenerCallQueue.Event<Listener>() {
            @Override
            public void call(Listener listener) {
              listener.stopped();
            }
    
            @Override
            public String toString() {
              return "stopped()";
            }
          };
    
      /**
       * A listener for the aggregate state changes of the services that are under management. Users
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/ServiceManager.java

          new ListenerCallQueue.Event<Listener>() {
            @Override
            public void call(Listener listener) {
              listener.stopped();
            }
    
            @Override
            public String toString() {
              return "stopped()";
            }
          };
    
      /**
       * A listener for the aggregate state changes of the services that are under management. Users
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/Service.java

       * this initiates service shutdown and returns immediately. If the service is {@linkplain
       * State#NEW new}, it is {@linkplain State#TERMINATED terminated} without having been started nor
       * stopped. If the service has already been stopped, this method returns immediately without
       * taking action.
       *
       * @return this
       * @since 15.0
       */
      @CanIgnoreReturnValue
      Service stopAsync();
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 10.7K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/Service.java

       * this initiates service shutdown and returns immediately. If the service is {@linkplain
       * State#NEW new}, it is {@linkplain State#TERMINATED terminated} without having been started nor
       * stopped. If the service has already been stopped, this method returns immediately without
       * taking action.
       *
       * @return this
       * @since 15.0
       */
      @CanIgnoreReturnValue
      Service stopAsync();
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 12.1K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/exec/SuggestCreator.java

            } catch (final ContainerNotAvailableException e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("SuggestCreator is stopped.", e);
                } else if (logger.isInfoEnabled()) {
                    logger.info("SuggestCreator is stopped.");
                }
                exitCode = Constants.EXIT_FAIL;
            } catch (final Throwable t) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 10K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

        manager.awaitStopped(5, SECONDS); // no exception thrown
      }
    
      /**
       * This covers a case where if the last service to stop failed then the stopped callback would
       * never be called.
       */
      public void testSingleFailedServiceCallsStopped() {
        Service a = new FailStartService();
        ServiceManager manager = new ServiceManager(asList(a));
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/AbstractService.java

        }
      }
    
      /**
       * Invoke this method to transition the service to the {@link State#FAILED}. The service will
       * <b>not be stopped</b> if it is running. Invoke this method when a service has failed critically
       * or otherwise cannot be started nor stopped.
       */
      protected final void notifyFailed(Throwable cause) {
        checkNotNull(cause);
    
        monitor.enter();
        try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.7K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/AbstractService.java

        }
      }
    
      /**
       * Invoke this method to transition the service to the {@link State#FAILED}. The service will
       * <b>not be stopped</b> if it is running. Invoke this method when a service has failed critically
       * or otherwise cannot be started nor stopped.
       */
      protected final void notifyFailed(Throwable cause) {
        checkNotNull(cause);
    
        monitor.enter();
        try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/exec/Crawler.java

            } catch (final ContainerNotAvailableException e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Crawler is stopped.", e);
                } else if (logger.isInfoEnabled()) {
                    logger.info("Crawler is stopped.");
                }
                exitCode = Constants.EXIT_FAIL;
            } catch (final Throwable t) {
                logger.error("Crawler does not work correctly.", t);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 24K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

                    } finally {
                        if (systemHelper.isForceStop()) {
                            finishCrawling = true;
                            if (logger.isDebugEnabled()) {
                                logger.debug("Stopped indexUpdater.");
                            }
                        }
                    }
    
                    if (emptyListCount >= maxEmptyListCount) {
                        if (logger.isInfoEnabled()) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 24.2K bytes
    - Viewed (0)
Back to top