Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 198 for isShutdown (0.09 sec)

  1. 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);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  2. 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);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java

        return delegate().invokeAny(tasks, timeout, unit);
      }
    
      @Override
      public boolean isShutdown() {
        return delegate().isShutdown();
      }
    
      @Override
      public boolean isTerminated() {
        return delegate().isTerminated();
      }
    
      @Override
      public void shutdown() {
        delegate().shutdown();
      }
    
      @Override
      @CanIgnoreReturnValue
      public List<Runnable> shutdownNow() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  4. 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);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/RecordingExecutor.kt

            return
          }
        }
        throw AssertionError("No such job: $url")
      }
    
      override fun shutdown() {
        shutdown = true
      }
    
      override fun shutdownNow(): List<Runnable> {
        throw UnsupportedOperationException()
      }
    
      override fun isShutdown(): Boolean {
        return shutdown
      }
    
      override fun isTerminated(): Boolean {
        throw UnsupportedOperationException()
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  6. 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 {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  7. 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);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

       */
      @Throws(IOException::class)
      fun shutdown(statusCode: ErrorCode) {
        writer.withLock {
          val lastGoodStreamId: Int
          this.withLock {
            if (isShutdown) {
              return
            }
            isShutdown = true
            lastGoodStreamId = this.lastGoodStreamId
          }
          // TODO: propagate exception message into debugData.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  9. 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: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  10. 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)
Back to top