Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 350 for submit (0.18 sec)

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

        @Override
        public <T> Future<T> submit(Callable<T> task) {
          lastMethodCalled = "submit";
          assertThat(task).isInstanceOf(WrappedCallable.class);
          return inline.submit(task);
        }
    
        @Override
        public Future<?> submit(Runnable task) {
          lastMethodCalled = "submit";
          assertThat(task).isInstanceOf(WrappedRunnable.class);
          return inline.submit(task);
        }
    
        @Override
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Jan 05 19:41:03 GMT 2023
    - 9.8K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/collect/QueuesTest.java

          Future<?> possiblyIgnoredError = threadPool.submit(new Producer(q, 20));
          @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored
          Future<?> possiblyIgnoredError1 = threadPool.submit(new Producer(q, 20));
          @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored
          Future<?> possiblyIgnoredError2 = threadPool.submit(new Producer(q, 20));
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 12K bytes
    - Viewed (0)
  3. guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

        return delegate.awaitTermination(timeout, unit);
      }
    
      @Override
      public <T> ListenableFuture<T> submit(Callable<T> task) {
        Preconditions.checkNotNull(task, "task must not be null!");
        return delegate.submit(task);
      }
    
      @Override
      public <T> ListenableFuture<T> submit(Runnable task, T result) {
        Preconditions.checkNotNull(task, "task must not be null!");
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Oct 06 00:47:57 GMT 2021
    - 6.4K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java

        TestRunnable runnable = new TestRunnable();
        ListenableFuture<?> runnableFuture = e.submit(runnable);
        assertThat(runnableFuture).isInstanceOf(TrustedListenableFutureTask.class);
        assertTrue(runnableFuture.isDone());
        assertTrue(runnable.run);
    
        ListenableFuture<String> callableFuture = e.submit(new TestCallable());
        assertThat(callableFuture).isInstanceOf(TrustedListenableFutureTask.class);
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Mon Dec 04 17:37:03 GMT 2017
    - 3.2K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

        assertNoExpectedFailures();
        super.tearDown();
      }
    
      public void testFrom() throws Exception {
        ClosingFuture<String> closingFuture =
            ClosingFuture.from(executor.submit(Callables.returning(closeable1)))
                .transform(
                    new ClosingFunction<TestCloseable, String>() {
                      @Override
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 75.3K bytes
    - Viewed (0)
  6. android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

        return delegate.awaitTermination(timeout, unit);
      }
    
      @Override
      public <T> ListenableFuture<T> submit(Callable<T> task) {
        Preconditions.checkNotNull(task, "task must not be null!");
        return delegate.submit(task);
      }
    
      @Override
      public <T> ListenableFuture<T> submit(Runnable task, T result) {
        Preconditions.checkNotNull(task, "task must not be null!");
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Oct 06 00:47:57 GMT 2021
    - 6.4K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

        }
    
        @Override
        public <T> Future<T> submit(Callable<T> task) {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public Future<?> submit(Runnable task) {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public <T> Future<T> submit(Runnable task, T result) {
          throw new UnsupportedOperationException();
        }
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 16 19:54:45 GMT 2020
    - 7.6K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/AbstractListeningExecutorService.java

      @Override
      public ListenableFuture<?> submit(Runnable task) {
        return (ListenableFuture<?>) super.submit(task);
      }
    
      @CanIgnoreReturnValue // TODO(kak): consider removing this
      @Override
      public <T extends @Nullable Object> ListenableFuture<T> submit(
          Runnable task, @ParametricNullness T result) {
        return (ListenableFuture<T>) super.submit(task, result);
      }
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri May 12 18:32:03 GMT 2023
    - 3K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToValueAndCloserTest.java

            .isTrue();
      }
    
      public void testFinishToValueAndCloser_throwsIfCalledTwice() throws Exception {
        ClosingFuture<Closeable> closingFuture =
            ClosingFuture.submit(
                new ClosingCallable<Closeable>() {
                  @Override
                  public Closeable call(DeferredCloser closer) throws Exception {
                    return closer.eventuallyClose(mockCloseable, executor);
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 5.7K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/WrappingExecutorService.java

      }
    
      @Override
      public final <T extends @Nullable Object> Future<T> submit(Callable<T> task) {
        return delegate.submit(wrapTask(checkNotNull(task)));
      }
    
      @Override
      public final Future<?> submit(Runnable task) {
        return delegate.submit(wrapTask(task));
      }
    
      @Override
      public final <T extends @Nullable Object> Future<T> submit(
          Runnable task, @ParametricNullness T result) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 5.5K bytes
    - Viewed (0)
Back to top