Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 49 for stopped (0.2 sec)

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

       * specific name, thread group or priority. The returned executor's {@link
       * Executor#execute(Runnable) execute()} method is called when this service is started and
       * stopped, and should return promptly.
       */
      protected Executor executor() {
        return command -> MoreExecutors.newThread(threadNameSupplier.get(), command).start();
      }
    
      @Override
      public String toString() {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 17 13:59:28 GMT 2023
    - 5.3K bytes
    - Viewed (0)
  2. 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();
    
      /**
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 10.7K bytes
    - Viewed (0)
  3. guava/src/com/google/common/base/Stopwatch.java

       */
      @CanIgnoreReturnValue
      public Stopwatch stop() {
        long tick = ticker.read();
        checkState(isRunning, "This stopwatch is already stopped.");
        isRunning = false;
        elapsedNanos += tick - startTick;
        return this;
      }
    
      /**
       * Sets the elapsed time for this stopwatch to zero, and places it in a stopped state.
       *
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 23 15:09:35 GMT 2023
    - 9.2K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

          finalizeReferentCalled = true;
        }
      }
    
      /**
       * Keeps a weak reference to the underlying reference queue. When this reference is cleared, we
       * know that the background thread has stopped and released its strong reference.
       */
      private WeakReference<ReferenceQueue<Object>> queueReference;
    
    
      public void testThatFinalizerStops() {
        weaklyReferenceQueue();
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Tue Oct 10 08:40:05 GMT 2023
    - 4.8K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

          finalizeReferentCalled = true;
        }
      }
    
      /**
       * Keeps a weak reference to the underlying reference queue. When this reference is cleared, we
       * know that the background thread has stopped and released its strong reference.
       */
      private WeakReference<ReferenceQueue<Object>> queueReference;
    
    
      public void testThatFinalizerStops() {
        weaklyReferenceQueue();
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Oct 10 08:40:05 GMT 2023
    - 4.8K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

            }
          };
      private static final ListenerCallQueue.Event<Listener> STOPPED_EVENT =
          new ListenerCallQueue.Event<Listener>() {
            @Override
            public void call(Listener listener) {
              listener.stopped();
            }
    
            @Override
            public String toString() {
              return "stopped()";
            }
          };
    
      /**
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 30.5K bytes
    - Viewed (0)
  7. 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));
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Oct 02 17:20:27 GMT 2023
    - 23.2K 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 {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri May 12 18:32:03 GMT 2023
    - 20.4K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/base/Stopwatch.java

       */
      @CanIgnoreReturnValue
      public Stopwatch stop() {
        long tick = ticker.read();
        checkState(isRunning, "This stopwatch is already stopped.");
        isRunning = false;
        elapsedNanos += tick - startTick;
        return this;
      }
    
      /**
       * Sets the elapsed time for this stopwatch to zero, and places it in a stopped state.
       *
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Nov 15 21:38:09 GMT 2022
    - 8.5K bytes
    - Viewed (0)
  10. 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));
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Mon Oct 02 17:20:27 GMT 2023
    - 23.9K bytes
    - Viewed (0)
Back to top