Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for toStart (0.19 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

      }
    
      private static class FailStartService extends NoOpService {
        @Override
        protected void doStart() {
          notifyFailed(new IllegalStateException("start failure"));
        }
      }
    
      private static class FailRunService extends NoOpService {
        @Override
        protected void doStart() {
          super.doStart();
          notifyFailed(new IllegalStateException("run failure"));
        }
      }
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Oct 02 17:20:27 GMT 2023
    - 23.2K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

        @Override
        protected void doStart() {
          notifyFailed(EXCEPTION);
        }
    
        @Override
        protected void doStop() {
          fail();
        }
      }
    
      private static class RunFailingService extends AbstractService {
        @Override
        protected void doStart() {
          notifyStarted();
          notifyFailed(EXCEPTION);
        }
    
        @Override
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 29.3K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

      }
    
      private static class FailStartService extends NoOpService {
        @Override
        protected void doStart() {
          notifyFailed(new IllegalStateException("start failure"));
        }
      }
    
      private static class FailRunService extends NoOpService {
        @Override
        protected void doStart() {
          super.doStart();
          notifyFailed(new IllegalStateException("run failure"));
        }
      }
    
    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)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

        @Override
        protected void doStart() {
          notifyFailed(EXCEPTION);
        }
    
        @Override
        protected void doStop() {
          fail();
        }
      }
    
      private static class RunFailingService extends AbstractService {
        @Override
        protected void doStart() {
          notifyStarted();
          notifyFailed(EXCEPTION);
        }
    
        @Override
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 29.3K bytes
    - Viewed (0)
  5. src/archive/tar/format.go

    		// Do nothing.
    	case format.has(FormatGNU):
    		copy(b.toGNU().magic(), magicGNU)
    		copy(b.toGNU().version(), versionGNU)
    	case format.has(formatSTAR):
    		copy(b.toSTAR().magic(), magicUSTAR)
    		copy(b.toSTAR().version(), versionUSTAR)
    		copy(b.toSTAR().trailer(), trailerSTAR)
    	case format.has(FormatUSTAR | FormatPAX):
    		copy(b.toUSTAR().magic(), magicUSTAR)
    		copy(b.toUSTAR().version(), versionUSTAR)
    	default:
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 11.3K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/AbstractService.java

    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import javax.annotation.CheckForNull;
    
    /**
     * Base class for implementing services that can handle {@link #doStart} and {@link #doStop}
     * requests, responding to them with {@link #notifyStarted()} and {@link #notifyStopped()}
     * callbacks. Its subclasses must manage threads manually; consider {@link
    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)
  7. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

            } finally {
              lock.unlock();
            }
          }
        }
    
        private final Runnable task = new Task();
    
        @Override
        protected final void doStart() {
          executorService =
              MoreExecutors.renamingDecorator(executor(), () -> serviceName() + " " + state());
          executorService.execute(
              () -> {
                lock.lock();
                try {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 25.8K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

      /* use AbstractService for state management */
      private final Service delegate =
          new AbstractService() {
            @Override
            protected final void doStart() {
              Executor executor = MoreExecutors.renamingDecorator(executor(), () -> serviceName());
              executor.execute(
                  () -> {
                    try {
                      startUp();
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 7.6K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

        assertEquals(1, service.startupCalled);
        assertEquals(0, service.runCalled);
        assertEquals(1, service.shutdownCalled);
      }
    
      public void testStop_noStart() {
        FakeService service = new FakeService();
        service.stopAsync().awaitTerminated();
        assertEquals(Service.State.TERMINATED, service.state());
        assertEquals(0, service.startupCalled);
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 12.7K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

        assertEquals(1, service.startupCalled);
        assertEquals(0, service.runCalled);
        assertEquals(1, service.shutdownCalled);
      }
    
      public void testStop_noStart() {
        FakeService service = new FakeService();
        service.stopAsync().awaitTerminated();
        assertEquals(Service.State.TERMINATED, service.state());
        assertEquals(0, service.startupCalled);
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 12.7K bytes
    - Viewed (0)
Back to top