subdir - Code Search

android/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

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Mon Jul 14 14:44:08 GMT 2025

- 9.9K bytes

- Click Count (0)

github.com/google/guava

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

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Mon Jul 14 14:44:08 GMT 2025

- 9.9K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

            },
            directExecutor());
    for (int i = 0; i < 25_000; i++) {
      serializer.submit(Callables.<Void>returning(null), directExecutor()).cancel(true);
      unused = serializer.submit(Callables.returning(null), directExecutor());
    }
    ListenableFuture<Integer> stackDepthCheck =
        serializer.submit(
            new Callable<Integer>() {
              @Override
              public Integer call() {

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Tue Sep 23 01:35:55 GMT 2025

- 16.2K bytes

- Click Count (0)

github.com/go-gorm/gorm

statement.go

					sql = strings.Replace(sql, bindvar.String(), "?", 1)
				}

				subdb.Statement.SQL.Reset()
				subdb.Statement.Vars = stmt.Vars
				if strings.Contains(sql, "@") {
					clause.NamedExpr{SQL: sql, Vars: vars}.Build(subdb.Statement)
				} else {
					clause.Expr{SQL: sql, Vars: vars}.Build(subdb.Statement)
				}
			} else {
				subdb.Statement.Vars = append(stmt.Vars, subdb.Statement.Vars...)

Created: Sun Dec 28 09:35:17 GMT 2025

- Last Modified: Fri Sep 12 04:33:27 GMT 2025

- 20.9K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/util/concurrent/ForwardingListeningExecutorService.java

  public <T extends @Nullable Object> ListenableFuture<T> submit(Callable<T> task) {
    return delegate().submit(task);
  }

  @Override
  public ListenableFuture<?> submit(Runnable task) {
    return delegate().submit(task);
  }

  @Override
  public <T extends @Nullable Object> ListenableFuture<T> submit(
      Runnable task, @ParametricNullness T result) {
    return delegate().submit(task, result);
  }

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Sun Dec 22 03:38:46 GMT 2024

- 2.2K bytes

- Click Count (0)

github.com/google/guava

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);
  }

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Wed Feb 12 17:47:46 GMT 2025

- 3K bytes

- Click Count (0)

github.com/google/guava

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!");

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Thu Aug 07 16:37:28 GMT 2025

- 6.5K bytes

- Click Count (0)

github.com/google/guava

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!");

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Thu Aug 07 16:37:28 GMT 2025

- 6.5K bytes

- Click Count (0)

github.com/google/guava

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));

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Tue Nov 04 17:24:58 GMT 2025

- 12.6K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java

  public <T extends @Nullable Object> Future<T> submit(Callable<T> task) {
    return delegate().submit(task);
  }

  @Override
  public Future<?> submit(Runnable task) {
    return delegate().submit(task);
  }

  @Override
  public <T extends @Nullable Object> Future<T> submit(
      Runnable task, @ParametricNullness T result) {
    return delegate().submit(task, result);
  }

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Sun Dec 22 03:38:46 GMT 2024

- 4.1K bytes

- Click Count (0)

Search Options