- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 1,134 for executors (0.17 sec)
-
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/compatibility/CrossVersionTestInterceptor.groovy
import org.gradle.integtests.fixtures.TargetVersions import org.gradle.integtests.fixtures.executer.GradleDistribution import org.gradle.integtests.fixtures.versions.ReleasedVersionDistributions import org.gradle.util.GradleVersion import org.spockframework.runtime.extension.IMethodInvocation /** * <p>Executes instances of {@link org.gradle.integtests.fixtures.CrossVersionIntegrationSpec} against each previous Gradle version. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.6K bytes - Viewed (0) -
platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/ExecutorFactory.java
/** * Creates an executor which can run multiple actions concurrently. It is the caller's responsibility to stop the executor. * * The executor will collect failures thrown by actions and rethrow when the executor is stopped. * * @param displayName The display name for the this executor. Used for thread names, logging and error message. * @return The executor. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 3.4K bytes - Viewed (0) -
platforms/core-runtime/concurrent/src/test/groovy/org/gradle/internal/concurrent/DefaultExecutorFactoryTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 11.2K bytes - Viewed (0) -
tensorflow/c/experimental/stream_executor/stream_executor_test.cc
free(mem->opaque); mem->opaque = nullptr; mem->size = 0; }; StreamExecutor* executor = GetExecutor(0); DeviceMemory<int> mem = executor->AllocateArray<int>(2); ASSERT_NE(mem.opaque(), nullptr); ASSERT_EQ(mem.size(), 2 * sizeof(int)); executor->Deallocate(&mem); } TEST_F(StreamExecutorTest, HostMemoryAllocate) { static bool allocate_called = false;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon May 20 19:54:04 UTC 2024 - 26.5K bytes - Viewed (0) -
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) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/extensions/BehindFlagFeatureInterceptor.groovy
@Override protected void before(IMethodInvocation invocation) { featureValues.each { sysProp, value -> // Ensure that the system property is propagated to forked Gradle executions AbstractGradleExecuter.propagateSystemProperty(sysProp) System.setProperty(sysProp, value) } } @Override protected void after() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 5.4K 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) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectMaxNConcurrentRequestsThenRelease.java
super(lock, testId, timeout, maxConcurrent, previous, expectedRequests); this.executor = executor; } @Override protected boolean isAutoRelease() { return true; } @Override protected void onExpectedRequestsReceived(BlockingHttpServer.BlockingHandler handler, int yetToBeReceived) { executor.execute(() -> {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
* exception itself. * @param executor the executor that runs {@code fallback} if the input fails */ public <X extends Throwable> ClosingFuture<V> catching( Class<X> exceptionType, ClosingFunction<? super X, ? extends V> fallback, Executor executor) { return catchingMoreGeneric(exceptionType, fallback, executor); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 98.3K bytes - Viewed (0)