- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 656 for executors (0.18 sec)
-
platforms/ide/tooling-api/src/testFixtures/groovy/org/gradle/integtests/tooling/fixture/ToolingApiSpecification.groovy
import org.gradle.integtests.fixtures.executer.ExecutionFailure import org.gradle.integtests.fixtures.executer.ExecutionResult import org.gradle.integtests.fixtures.executer.GradleDistribution import org.gradle.integtests.fixtures.executer.IntegrationTestBuildContext import org.gradle.integtests.fixtures.executer.OutputScrapingExecutionFailure import org.gradle.integtests.fixtures.executer.OutputScrapingExecutionResult
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 16 10:10:39 UTC 2024 - 16.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
/** Use {@link MoreExecutors#newSequentialExecutor} */ SequentialExecutor(Executor executor) { this.executor = Preconditions.checkNotNull(executor); } /** * Adds a task to the queue and makes sure a worker thread is running. * * <p>If this method throws, e.g. a {@code RejectedExecutionException} from the delegate executor, * execution of tasks will stop until a call to this method is made. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 10.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/SequentialExecutor.java
/** Use {@link MoreExecutors#newSequentialExecutor} */ SequentialExecutor(Executor executor) { this.executor = Preconditions.checkNotNull(executor); } /** * Adds a task to the queue and makes sure a worker thread is running. * * <p>If this method throws, e.g. a {@code RejectedExecutionException} from the delegate executor, * execution of tasks will stop until a call to this method is made. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 10.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
* returned future. * @param executor Executor to run the function in. * @return A future that holds result of the transformation. */ public final <T extends @Nullable Object> FluentFuture<T> transform( Function<? super V, T> function, Executor executor) { return (FluentFuture<T>) Futures.transform(this, function, executor); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 11 19:08:44 UTC 2023 - 18.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/DefaultExecActionFactory.java
@Nullable private ExternalProcessStartedListener externalProcessStartedListener; BuilderImpl( Executor executor, TemporaryFileProvider temporaryFileProvider ) { this.executor = executor; this.temporaryFileProvider = temporaryFileProvider; } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 10 06:16:11 UTC 2023 - 24K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DispatcherTest.kt
dispatcher.maxRequestsPerHost = 4 executor.assertJobs("http://a/1", "http://a/2", "http://a/3", "http://a/4") } @Test fun oldJobFinishesNewJobCanRunDifferentHost() { dispatcher.maxRequests = 1 client.newCall(newRequest("http://a/1")).enqueue(callback) client.newCall(newRequest("http://b/1")).enqueue(callback) executor.finishJob("http://a/1") executor.assertJobs("http://b/1") } @Test
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Fri Apr 05 03:30:42 UTC 2024 - 12.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/FluentFuture.java
* returned future. * @param executor Executor to run the function in. * @return A future that holds result of the transformation. */ public final <T extends @Nullable Object> FluentFuture<T> transform( Function<? super V, T> function, Executor executor) { return (FluentFuture<T>) Futures.transform(this, function, executor); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 11 19:08:44 UTC 2023 - 19.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
*/ public <T extends @Nullable Object> ListenableFuture<T> submitAsync( AsyncCallable<T> callable, Executor executor) { checkNotNull(callable); checkNotNull(executor); TaskNonReentrantExecutor taskExecutor = new TaskNonReentrantExecutor(executor, this); AsyncCallable<T> task = new AsyncCallable<T>() { @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 22.1K 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) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
*/ public <T extends @Nullable Object> ListenableFuture<T> submitAsync( AsyncCallable<T> callable, Executor executor) { checkNotNull(callable); checkNotNull(executor); TaskNonReentrantExecutor taskExecutor = new TaskNonReentrantExecutor(executor, this); AsyncCallable<T> task = new AsyncCallable<T>() { @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 22.1K bytes - Viewed (0)