- Sort Score
- Result 10 results
- Languages All
Results 221 - 230 of 2,328 for executors (0.12 sec)
-
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) -
android/guava/src/com/google/common/eventbus/AsyncEventBus.java
super(identifier, executor, Dispatcher.legacyAsync(), LoggingHandler.INSTANCE); } /** * Creates a new AsyncEventBus that will use {@code executor} to dispatch events. * * @param executor Executor to use to dispatch events. It is the caller's responsibility to shut * down the executor after the last event has been posted to this event bus.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Apr 22 13:05:46 UTC 2021 - 2.5K 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) -
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) -
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) -
guava/src/com/google/common/eventbus/AsyncEventBus.java
super(identifier, executor, Dispatcher.legacyAsync(), LoggingHandler.INSTANCE); } /** * Creates a new AsyncEventBus that will use {@code executor} to dispatch events. * * @param executor Executor to use to dispatch events. It is the caller's responsibility to shut * down the executor after the last event has been posted to this event bus.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Apr 22 13:05:46 UTC 2021 - 2.5K bytes - Viewed (0) -
guava/src/com/google/common/cache/RemovalListeners.java
* executor}. * * @param listener the backing listener * @param executor the executor with which removal notifications are asynchronously executed */ public static <K, V> RemovalListener<K, V> asynchronous( RemovalListener<K, V> listener, Executor executor) { checkNotNull(listener); checkNotNull(executor); return (RemovalNotification<K, V> notification) ->
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Oct 01 16:02:17 UTC 2021 - 1.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/tests/empty-main.mlir
// RUN: tf-opt -tf-executor-graph-pruning %s | FileCheck %s --check-prefix=CONTROL // CONTROL-LABEL: func @main // CONTROL-NEXT: return // EXECUTOR-LABEL: func @main // EXECUTOR-NEXT: tf_executor.graph { // EXECUTOR-NEXT: tf_executor.fetch // EXECUTOR-NEXT: } // EXECUTOR-NEXT: return func.func @main() { func.return
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Mar 28 12:06:33 UTC 2022 - 342 bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/streams/OutputStreamsForwarder.java
this.completed = new CountDownLatch(readErrorStream ? 2 : 1); } @Override public void connectStreams(Process process, String processName, Executor executor) { this.executor = executor; standardOutputReader = new ExecOutputHandleRunner("read standard output of " + processName, process.getInputStream(), standardOutput, completed); if (readErrorStream) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jul 11 16:06:58 UTC 2023 - 3.2K bytes - Viewed (0)