Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 262 for shutdowned (0.06 seconds)

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

        ExecutorService service = mock(ExecutorService.class);
        application.addDelayedShutdownHook(service, 2, SECONDS);
        verify(service, Mockito.never()).shutdown();
        application.shutdown();
        InOrder shutdownFirst = Mockito.inOrder(service);
        shutdownFirst.verify(service).shutdown();
        shutdownFirst.verify(service).awaitTermination(2, SECONDS);
      }
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Dec 12 00:25:21 GMT 2025
    - 26.5K bytes
    - Click Count (0)
  2. guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

                      // which case we should skip right down to shutdown.
                      if (isRunning()) {
                        try {
                          AbstractExecutionThreadService.this.run();
                        } catch (Throwable t) {
                          restoreInterruptIfIsInterruptedException(t);
                          try {
                            shutDown();
                          } catch (Exception ignored) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 7.5K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

        task: Task,
        delayNanos: Long = 0L,
      ) {
        taskRunner.withLock {
          if (shutdown) {
            if (task.cancelable) {
              taskRunner.logger.taskLog(task, this) { "schedule canceled (queue is shutdown)" }
              return
            }
            taskRunner.logger.taskLog(task, this) { "schedule failed (queue is shutdown)" }
            throw RejectedExecutionException()
          }
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed May 28 23:28:25 GMT 2025
    - 7.3K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        ExecutorService service = mock(ExecutorService.class);
        application.addDelayedShutdownHook(service, 2, SECONDS);
        verify(service, Mockito.never()).shutdown();
        application.shutdown();
        InOrder shutdownFirst = Mockito.inOrder(service);
        shutdownFirst.verify(service).shutdown();
        shutdownFirst.verify(service).awaitTermination(2, SECONDS);
      }
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Dec 12 00:25:21 GMT 2025
    - 26.5K bytes
    - Click Count (0)
  5. docs/en/docs/advanced/testing-events.md

    # Testing Events: lifespan and startup - shutdown { #testing-events-lifespan-and-startup-shutdown }
    
    When you need `lifespan` to run in your tests, you can use the `TestClient` with a `with` statement:
    
    {* ../../docs_src/app_testing/tutorial004_py39.py hl[9:15,18,27:28,30:32,41:43] *}
    
    
    You can read more details about the ["Running lifespan in tests in the official Starlette documentation site."](https://www.starlette.dev/lifespan/#running-lifespan-in-tests)
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 626 bytes
    - Click Count (0)
  6. docs/pt/docs/advanced/events.md

    ### Evento `shutdown` { #shutdown-event }
    
    Para adicionar uma função que deve ser executada quando a aplicação estiver encerrando, declare-a com o evento `"shutdown"`:
    
    {* ../../docs_src/events/tutorial002_py39.py hl[6] *}
    
    Aqui, a função de manipulador do evento `shutdown` escreverá uma linha de texto `"Application shutdown"` no arquivo `log.txt`.
    
    /// info | Informação
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  7. docs_src/events/tutorial002_py39.py

    from fastapi import FastAPI
    
    app = FastAPI()
    
    
    @app.on_event("shutdown")
    def shutdown_event():
        with open("log.txt", mode="a") as log:
            log.write("Application shutdown")
    
    
    @app.get("/items/")
    async def read_items():
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 255 bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java

      public void testStop_failed() {
        Exception exception = new Exception("deliberate");
        TestService service =
            new TestService() {
              @Override
              protected void shutDown() throws Exception {
                super.shutDown();
                throw exception;
              }
            };
        service.startAsync().awaitRunning();
        assertEquals(1, service.startUpCalled);
        assertEquals(0, service.shutDownCalled);
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 7.5K bytes
    - Click Count (0)
  9. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt

      @Test
      fun shutdownWithoutStart() {
        val server = MockWebServer()
        server.shutdown()
      }
    
      @Test
      fun closeViaClosable() {
        val server: Closeable = MockWebServer()
        server.close()
      }
    
      @Test
      fun shutdownWithoutEnqueue() {
        val server = MockWebServer()
        server.start()
        server.shutdown()
      }
    
      @Test
      fun portImplicitlyStarts() {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jul 03 13:16:34 GMT 2025
    - 22.3K bytes
    - Click Count (0)
  10. docs/zh/docs/advanced/events.md

    本例中,`startup` 事件处理器函数为项目数据库(只是**字典**)提供了一些初始值。
    
    **FastAPI** 支持多个事件处理器函数。
    
    只有所有 `startup` 事件处理器运行完毕,**FastAPI** 应用才开始接收请求。
    
    ### `shutdown` 事件
    
    使用 `shutdown` 事件声明 `app` 关闭时运行的函数:
    
    {* ../../docs_src/events/tutorial002.py hl[6] *}
    
    此处,`shutdown` 事件处理器函数在 `log.txt` 中写入一行文本 `Application shutdown`。
    
    /// info | 说明
    
    `open()` 函数中,`mode="a"` 指的是**追加**。因此这行文本会添加在文件已有内容之后,不会覆盖之前的内容。
    
    ///
    
    /// tip | 提示
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Oct 11 17:48:49 GMT 2025
    - 7K bytes
    - Click Count (0)
Back to Top