Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 230 for isShutdown (0.17 sec)

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

      private final ListeningExecutorService delegate = newDirectExecutorService();
    
      @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() {
        return delegate.isTerminated();
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 02 18:21:29 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  2. 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() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 3.2K bytes
    - Viewed (0)
  3. 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() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 3.2K bytes
    - Viewed (0)
  4. 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: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:18:12 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  5. 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
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  6. 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: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Jun 20 14:10:53 UTC 2024
    - 9K 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: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/MoreExecutors.java

        }
    
        @Override
        public final boolean isShutdown() {
          return delegate.isShutdown();
        }
    
        @Override
        public final boolean isTerminated() {
          return delegate.isTerminated();
        }
    
        @Override
        public final void shutdown() {
          delegate.shutdown();
        }
    
        @Override
        public final List<Runnable> shutdownNow() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  9. internal/http/server.go

    		return srv.Server.Serve(l)
    	}
    
    	return
    }
    
    // Shutdown - shuts down HTTP server.
    func (srv *Server) Shutdown() error {
    	srv.listenerMutex.Lock()
    	if srv.listener == nil {
    		srv.listenerMutex.Unlock()
    		return http.ErrServerClosed
    	}
    	srv.listenerMutex.Unlock()
    
    	if atomic.AddUint32(&srv.inShutdown, 1) > 1 {
    		// shutdown in progress
    		return http.ErrServerClosed
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 18:42:47 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  10. 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()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 7.9K bytes
    - Viewed (0)
Back to top