Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 79 for isShutdown (0.19 sec)

  1. platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/AbstractDelegatingExecutorService.java

            this.delegate = delegate;
        }
    
        @Override
        public void shutdown() {
            delegate.shutdown();
        }
    
        @Override
        public List<Runnable> shutdownNow() {
            return delegate.shutdownNow();
        }
    
        @Override
        public boolean isShutdown() {
            return delegate.isShutdown();
        }
    
        @Override
        public boolean isTerminated() {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 19:07:35 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/DirectExecutorService.java

      private boolean shutdown = false;
    
      @Override
      public void execute(Runnable command) {
        startTask();
        try {
          command.run();
        } finally {
          endTask();
        }
      }
    
      @Override
      public boolean isShutdown() {
        synchronized (lock) {
          return shutdown;
        }
      }
    
      @Override
      public void shutdown() {
        synchronized (lock) {
          shutdown = true;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 15 10:40:05 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/DirectExecutorService.java

      private boolean shutdown = false;
    
      @Override
      public void execute(Runnable command) {
        startTask();
        try {
          command.run();
        } finally {
          endTask();
        }
      }
    
      @Override
      public boolean isShutdown() {
        synchronized (lock) {
          return shutdown;
        }
      }
    
      @Override
      public void shutdown() {
        synchronized (lock) {
          shutdown = true;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 15 10:40:05 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  4. testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/TestManagedExecutor.groovy

        void stop(int timeoutValue, TimeUnit timeoutUnits) throws IllegalStateException {
            stop()
        }
    
        void shutdown() {
            throw new UnsupportedOperationException()
        }
    
        List<Runnable> shutdownNow() {
            throw new UnsupportedOperationException()
        }
    
        boolean isShutdown() {
            throw new UnsupportedOperationException()
        }
    
        boolean isTerminated() {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  5. 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: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri May 17 17:12:37 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  6. android/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: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri May 17 17:12:37 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt

        val socket = serverSocket!!.accept()!!
        this.socket = socket
    
        // Bail out now if this instance was closed while waiting for the socket to accept.
        synchronized(this) {
          if (executor.isShutdown) {
            socket.close()
            return
          }
        }
        val outputStream = socket.getOutputStream()
        val inputStream = socket.getInputStream()
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/Dispatcher.kt

        }
    
        // Avoid resubmitting if we can't logically progress
        // particularly because RealCall handles a RejectedExecutionException
        // by executing on the same thread.
        if (executorService.isShutdown) {
          for (i in 0 until executableCalls.size) {
            val asyncCall = executableCalls[i]
            asyncCall.callsPerHost.decrementAndGet()
    
            this.withLock {
              runningAsyncCalls.remove(asyncCall)
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 9K bytes
    - Viewed (0)
  9. android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

                  }
                }
              });
          this.shutdown = shutdown;
          start();
        }
    
        void shutdown() {
          shutdown.set(true);
          while (this.isAlive()) {
            Thread.yield();
          }
        }
      }
    
      void assertWrapsInterruptedException(RuntimeException e) {
        assertThat(e).hasMessageThat().contains("Unexpected interrupt");
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jun 10 19:21:11 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  10. docs/en/docs/advanced/events.md

    ### `shutdown` event
    
    To add a function that should be run when the application is shutting down, declare it with the event `"shutdown"`:
    
    ```Python hl_lines="6"
    {!../../../docs_src/events/tutorial002.py!}
    ```
    
    Here, the `shutdown` event handler function will write a text line `"Application shutdown"` to a file `log.txt`.
    
    !!! info
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Thu Apr 18 19:53:19 UTC 2024
    - 7.8K bytes
    - Viewed (0)
Back to top