Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for notifyStarted (0.14 sec)

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

              Executor executor = renamingDecorator(executor(), () -> serviceName());
              executor.execute(
                  () -> {
                    try {
                      startUp();
                      notifyStarted();
                      // If stopAsync() is called while starting we may be in the STOPPING state in
                      // which case we should skip right down to shutdown.
                      if (isRunning()) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

     * @author Chris Nokleberg
     */
    @NullUnmarked
    public class ServiceManagerTest extends TestCase {
    
      private static class NoOpService extends AbstractService {
        @Override
        protected void doStart() {
          notifyStarted();
        }
    
        @Override
        protected void doStop() {
          notifyStopped();
        }
      }
    
      /*
       * A NoOp service that will delay the startup and shutdown notification for a configurable amount
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 20:34:52 UTC 2025
    - 25.5K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

              Executor executor = renamingDecorator(executor(), () -> serviceName());
              executor.execute(
                  () -> {
                    try {
                      startUp();
                      notifyStarted();
                      // If stopAsync() is called while starting we may be in the STOPPING state in
                      // which case we should skip right down to shutdown.
                      if (isRunning()) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

                   * assignment above.
                   */
                  requireNonNull(executorService);
                  runningTask = scheduler().schedule(delegate, executorService, task);
                  notifyStarted();
                } catch (Throwable t) {
                  restoreInterruptIfIsInterruptedException(t);
                  notifyFailed(t);
                  if (runningTask != null) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

                   * assignment above.
                   */
                  requireNonNull(executorService);
                  runningTask = scheduler().schedule(delegate, executorService, task);
                  notifyStarted();
                } catch (Throwable t) {
                  restoreInterruptIfIsInterruptedException(t);
                  notifyFailed(t);
                  if (runningTask != null) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
Back to top