Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 241 for shutdown (0.06 sec)

  1. guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

        private volatile boolean shutdown;
    
        @Override
        public void shutdown() {
          shutdown = true;
        }
    
        @Override
        public List<Runnable> shutdownNow() {
          shutdown();
          return ImmutableList.of();
        }
    
        @Override
        public boolean isShutdown() {
          return shutdown;
        }
    
        @Override
        public boolean isTerminated() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  2. src/test/java/org/codelibs/fess/job/impl/ScriptExecutorTest.java

        }
    
        public void test_shutdown_withListener() {
            // Add shutdown listener
            TestShutdownListener listener = new TestShutdownListener();
            scriptExecutor.addShutdownListener(listener);
    
            // Verify listener not called yet
            assertFalse(listener.wasShutdownCalled());
    
            // Call shutdown
            scriptExecutor.shutdown();
    
            // Verify listener was called
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  3. docs/ko/docs/advanced/events.md

    여러 개의 이벤트 핸들러 함수를 추가할 수 있습니다.
    
    애플리케이션은 모든 `startup` 이벤트 핸들러가 완료될 때까지 요청을 받기 시작하지 않습니다.
    
    ### `shutdown` 이벤트
    
    애플리케이션이 종료될 때 실행되어야 하는 함수를 추가하려면, `"shutdown"` 이벤트로 선언합니다:
    
    {* ../../docs_src/events/tutorial002.py hl[6] *}
    
    여기서, `shutdown` 이벤트 핸들러 함수는 `"Application shutdown"`이라는 텍스트를 `log.txt` 파일에 기록합니다.
    
    /// info | 정보
    
    `open()` 함수에서 `mode="a"`는 "추가"를 의미하므로, 파일에 있는 기존 내용은 덮어쓰지 않고 새로운 줄이 추가됩니다.
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Fri May 30 13:33:53 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  4. guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

                  while (!shutdown.get()) {
                    interruptee.interrupt();
                    Thread.yield();
                  }
                }
              });
          this.shutdown = shutdown;
          start();
        }
    
        @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
        void shutdown() {
          shutdown.set(true);
          while (this.isAlive()) {
            Thread.yield();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  5. docs/en/docs/advanced/events.md

    ### `shutdown` event { #shutdown-event }
    
    To add a function that should be run when the application is shutting down, declare it with the event `"shutdown"`:
    
    {* ../../docs_src/events/tutorial002.py hl[6] *}
    
    Here, the `shutdown` event handler function will write a text line `"Application shutdown"` to a file `log.txt`.
    
    /// info
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

     * the "running" state need to perform a periodic task. Subclasses can implement {@link #startUp},
     * {@link #shutDown} and also a {@link #runOneIteration} method that will be executed periodically.
     *
     * <p>This class uses the {@link ScheduledExecutorService} returned from {@link #executor} to run
     * the {@link #startUp} and {@link #shutDown} methods and also uses that service to schedule the
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  7. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockWebServer.kt

        delegate.start(inetAddress, port)
      }
    
      @Synchronized
      @Throws(IOException::class)
      fun shutdown() {
        delegate.close()
      }
    
      @Synchronized override fun after() {
        try {
          shutdown()
        } catch (e: IOException) {
          logger.log(Level.WARNING, "MockWebServer shutdown failed", e)
        }
      }
    
      override fun toString(): String = delegate.toString()
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 00:19:42 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  8. 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) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  9. 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()
          }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  10. 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() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 03 13:16:34 UTC 2025
    - 22.3K bytes
    - Viewed (0)
Back to top