Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 89 for _shutdown (0.08 seconds)

  1. fastapi/routing.py

        async def _shutdown(self) -> None:
            """
            Run any `.on_shutdown` event handlers.
    
            This method is kept for backward compatibility after Starlette removed
            support for on_startup/on_shutdown handlers.
    
            Ref: https://github.com/Kludex/starlette/pull/3117
            """
            for handler in self.on_shutdown:
                if is_async_callable(handler):
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sun Mar 15 11:44:39 GMT 2026
    - 193K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        ExecutorService service = mock(ExecutorService.class);
        application.addDelayedShutdownHook(service, 2, SECONDS);
        verify(service, never()).shutdown();
        application.shutdown();
        InOrder shutdownFirst = inOrder(service);
        shutdownFirst.verify(service).shutdown();
        shutdownFirst.verify(service).awaitTermination(2, SECONDS);
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.1K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        ExecutorService service = mock(ExecutorService.class);
        application.addDelayedShutdownHook(service, 2, SECONDS);
        verify(service, never()).shutdown();
        application.shutdown();
        InOrder shutdownFirst = inOrder(service);
        shutdownFirst.verify(service).shutdown();
        shutdownFirst.verify(service).awaitTermination(2, SECONDS);
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.1K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

        assertFalse(testExecutor.isTerminated());
        mock.assertLastMethodCalled("isTerminated");
        assertFalse(testExecutor.isShutdown());
        mock.assertLastMethodCalled("isShutdown");
        testExecutor.shutdown();
        mock.assertLastMethodCalled("shutdown");
        List<Runnable> list = testExecutor.shutdownNow();
        mock.assertLastMethodCalled("shutdownNow");
        assertEquals(ImmutableList.of(), list);
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 10.1K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

        assertFalse(testExecutor.isTerminated());
        mock.assertLastMethodCalled("isTerminated");
        assertFalse(testExecutor.isShutdown());
        mock.assertLastMethodCalled("isShutdown");
        testExecutor.shutdown();
        mock.assertLastMethodCalled("shutdown");
        List<Runnable> list = testExecutor.shutdownNow();
        mock.assertLastMethodCalled("shutdownNow");
        assertEquals(ImmutableList.of(), list);
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 10.1K bytes
    - Click Count (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java

      /** Simple same thread listening executor service that doesn't handle shutdown. */
      private static class TestListeningExecutorService extends AbstractListeningExecutorService {
    
        @Override
        public void execute(Runnable runnable) {
          assertThat(runnable).isInstanceOf(TrustedListenableFutureTask.class);
          runnable.run();
        }
    
        @Override
        public void shutdown() {}
    
        @Override
        public List<Runnable> shutdownNow() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 3.4K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java

      /** Simple same thread listening executor service that doesn't handle shutdown. */
      private static class TestListeningExecutorService extends AbstractListeningExecutorService {
    
        @Override
        public void execute(Runnable runnable) {
          assertThat(runnable).isInstanceOf(TrustedListenableFutureTask.class);
          runnable.run();
        }
    
        @Override
        public void shutdown() {}
    
        @Override
        public List<Runnable> shutdownNow() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 3.4K bytes
    - Click Count (0)
  8. android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java

      public void testNoOpScheduledExecutorShutdown() {
        ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor();
        assertFalse(executor.isShutdown());
        assertFalse(executor.isTerminated());
        executor.shutdown();
        assertTrue(executor.isShutdown());
        assertTrue(executor.isTerminated());
      }
    
      public void testNoOpScheduledExecutorInvokeAll() throws ExecutionException, InterruptedException {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 3.3K bytes
    - Click Count (0)
  9. guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java

      public void testNoOpScheduledExecutorShutdown() {
        ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor();
        assertFalse(executor.isShutdown());
        assertFalse(executor.isTerminated());
        executor.shutdown();
        assertTrue(executor.isShutdown());
        assertTrue(executor.isTerminated());
      }
    
      public void testNoOpScheduledExecutorInvokeAll() throws ExecutionException, InterruptedException {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 3.3K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

          throw new UnsupportedOperationException();
        }
    
        @Override
        public boolean isShutdown() {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public boolean isTerminated() {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public void shutdown() {
          throw new UnsupportedOperationException();
        }
    
        @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.5K bytes
    - Click Count (0)
Back to Top