- Sort Score
- Result 10 results
- Languages All
Results 261 - 270 of 2,328 for executors (0.17 sec)
-
subprojects/core/src/main/java/org/gradle/process/internal/DefaultExecHandleBuilder.java
public DefaultExecHandleBuilder(PathToFileResolver fileResolver, Executor executor) { this(fileResolver, executor, new DefaultBuildCancellationToken()); } public DefaultExecHandleBuilder(PathToFileResolver fileResolver, Executor executor, BuildCancellationToken buildCancellationToken) { super(fileResolver, executor, buildCancellationToken); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 06 16:16:31 UTC 2020 - 4.8K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* * @param listener the listener to run when the computation is complete * @param executor the executor to run the listener in * @throws RejectedExecutionException if we tried to execute the listener immediately but the * executor rejected it. */ void addListener(Runnable listener, Executor executor);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 26 21:13:41 UTC 2023 - 8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenableFuture.java
* * @param listener the listener to run when the computation is complete * @param executor the executor to run the listener in * @throws RejectedExecutionException if we tried to execute the listener immediately but the * executor rejected it. */ void addListener(Runnable listener, Executor executor);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 26 21:13:41 UTC 2023 - 8K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java
} } private static final class Listener { final Runnable command; final Executor executor; Listener(Runnable command, Executor executor) { this.command = checkNotNull(command); this.executor = checkNotNull(executor); } void execute() { try { executor.execute(command); } catch (RuntimeException e) { log.log( Level.SEVERE,
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jan 22 19:37:41 UTC 2024 - 12.3K bytes - Viewed (0) -
test/typeparam/issue50561.dir/diameter.go
r() } type Executor interface { ExecuteUnsafe(runnable Runnable) } type Promise[T any] interface { Future() Future[T] Success(value T) bool Failure(err error) bool IsCompleted() bool Complete(result Try[T]) bool } type Future[T any] interface { OnFailure(cb func(err error), ctx ...Executor) OnSuccess(cb func(success T), ctx ...Executor) Foreach(f func(v T), ctx ...Executor)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jan 13 22:58:24 UTC 2022 - 1.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ImmediateFuture.java
public void addListener(Runnable listener, Executor executor) { checkNotNull(listener, "Runnable was null."); checkNotNull(executor, "Executor was null."); try { executor.execute(listener); } catch (Exception e) { // sneaky checked exception // ListenableFuture's contract is that it will not throw unchecked exceptions, so log the bad // runnable and/or executor and swallow it. log.get() .log(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 3.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/DirectExecutor.java
import com.google.common.annotations.GwtCompatible; import java.util.concurrent.Executor; /** * An {@link Executor} that runs each task in the thread that invokes {@link Executor#execute * execute}. */ @GwtCompatible @ElementTypesAreNonnullByDefault enum DirectExecutor implements Executor { INSTANCE; @Override public void execute(Runnable command) { command.run(); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 05 22:27:35 UTC 2021 - 1.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/DirectExecutor.java
import com.google.common.annotations.GwtCompatible; import java.util.concurrent.Executor; /** * An {@link Executor} that runs each task in the thread that invokes {@link Executor#execute * execute}. */ @GwtCompatible @ElementTypesAreNonnullByDefault enum DirectExecutor implements Executor { INSTANCE; @Override public void execute(Runnable command) { command.run(); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 05 22:27:35 UTC 2021 - 1.1K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/connection/ParameterizedActionRunner.java
private final InternalParameterAcceptingConnection executor; ParameterizedActionRunner(InternalParameterAcceptingConnection executor, CancellationExceptionTransformer exceptionTransformer, VersionDetails versionDetails) { super(null, exceptionTransformer, versionDetails); this.executor = executor; } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 12:11:05 UTC 2024 - 1.7K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/connection/CancellableActionRunner.java
private final InternalCancellableConnection executor; private final CancellationExceptionTransformer exceptionTransformer; private final VersionDetails versionDetails; CancellableActionRunner(InternalCancellableConnection executor, CancellationExceptionTransformer exceptionTransformer, VersionDetails versionDetails) { this.executor = executor; this.exceptionTransformer = exceptionTransformer;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 12:11:05 UTC 2024 - 3K bytes - Viewed (0)