Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 30 for shutdownNow (0.16 sec)

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

        mock.assertLastMethodCalled("isShutdown");
        testExecutor.shutdown();
        mock.assertLastMethodCalled("shutdown");
        List<Runnable> list = testExecutor.shutdownNow();
        mock.assertLastMethodCalled("shutdownNow");
        assertEquals(ImmutableList.of(), list);
      }
    
      public void testExecute() {
        MockExecutor mock = new MockExecutor();
        TestExecutor testExecutor = new TestExecutor(mock);
    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. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

     */
    @GwtIncompatible
    public final class TestingExecutors {
      private TestingExecutors() {}
    
      /**
       * Returns a {@link ScheduledExecutorService} that never executes anything.
       *
       * <p>The {@code shutdownNow} method of the returned executor always returns an empty list despite
       * the fact that everything is still technically awaiting execution. The {@code getDelay} method
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:18:12 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java

        return delegate().isTerminated();
      }
    
      @Override
      public void shutdown() {
        delegate().shutdown();
      }
    
      @Override
      @CanIgnoreReturnValue
      public List<Runnable> shutdownNow() {
        return delegate().shutdownNow();
      }
    
      @Override
      public void execute(Runnable command) {
        delegate().execute(command);
      }
    
      @Override
    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. guava/src/com/google/common/util/concurrent/MoreExecutors.java

          return delegate.isTerminated();
        }
    
        @Override
        public final void shutdown() {
          delegate.shutdown();
        }
    
        @Override
        public final List<Runnable> shutdownNow() {
          return delegate.shutdownNow();
        }
    
        @Override
        public final void execute(Runnable command) {
          delegate.execute(command);
        }
    
        @Override
        public final String toString() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

        mock.assertLastMethodCalled("isShutdown");
        testExecutor.shutdown();
        mock.assertLastMethodCalled("shutdown");
        List<Runnable> list = testExecutor.shutdownNow();
        mock.assertLastMethodCalled("shutdownNow");
        assertEquals(ImmutableList.of(), list);
      }
    
      public void testExecute() {
        MockExecutor mock = new MockExecutor();
        TestExecutor testExecutor = new TestExecutor(mock);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

          }
        }
      }
    
      public void testDirectExecutorService_shutdownNow() {
        ExecutorService executor = newDirectExecutorService();
        assertEquals(ImmutableList.of(), executor.shutdownNow());
        assertTrue(executor.isShutdown());
      }
    
      public void testExecuteAfterShutdown() {
        ExecutorService executor = newDirectExecutorService();
        executor.shutdown();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  7. okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/TestDohMain.kt

            workingOnly = true,
            getOnly = true,
          )
        runBatch(dnsProviders, names)
      } finally {
        bootstrapClient.connectionPool.evictAll()
        bootstrapClient.dispatcher.executorService.shutdownNow()
        bootstrapClient.cache?.close()
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/collect/ConcurrentHashMultisetBasherTest.java

                      return multiset.count(key);
                    }
                  });
          assertEquals("Counts not as expected", Ints.asList(deltas), actualCounts);
        } finally {
          pool.shutdownNow();
        }
    
        // Since we have access to the backing map, verify that there are no zeroes in the map
        for (AtomicInteger value : map.values()) {
          assertTrue("map should not contain a zero", value.get() != 0);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  9. 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)
  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