- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 625 for executors (0.26 sec)
-
guava/src/com/google/common/util/concurrent/DirectExecutorService.java
} } } } /** * Checks if the executor has been shut down and increments the running task count. * * @throws RejectedExecutionException if the executor has been previously shutdown */ private void startTask() { synchronized (lock) { if (shutdown) { throw new RejectedExecutionException("Executor already shutdown"); } runningTasks++; } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 3.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/cli/RunBuildAction.java
public RunBuildAction( BuildActionExecutor<BuildActionParameters, ClientBuildRequestContext> executor, StartParameterInternal startParameter, GradleLauncherMetaData clientMetaData, long startTime, BuildActionParameters buildActionParameters, ServiceRegistry sharedServices, Stoppable stoppable) { this.executor = executor; this.startParameter = startParameter; this.clientMetaData = clientMetaData;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 3.2K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/PluginServiceInjectionIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 02 18:26:28 UTC 2024 - 7.4K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/async/DefaultAsyncConsumerActionExecutor.java
private final ConsumerActionExecutor actionExecutor; private final ManagedExecutor executor; private final ServiceLifecycle lifecycle; public DefaultAsyncConsumerActionExecutor(ConsumerActionExecutor actionExecutor, ExecutorFactory executorFactory) { this.actionExecutor = actionExecutor; executor = executorFactory.create("Connection worker");
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:55 UTC 2024 - 2.8K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/TestManagedExecutor.groovy
private int count private final TestExecutor executor; TestManagedExecutor(TestExecutor executor) { this.executor = executor } void execute(Runnable command) { lock.lock() try { count++ } finally { lock.unlock() } executor.execute { try { command.run()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2.7K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/initialization/InitScriptHandlerTest.groovy
def processor = Mock(InitScriptProcessor) def executor = new TestBuildOperationRunner() def gradle = Mock(GradleInternal) def startParameter = Stub(StartParameterInternal) def resourceLoader = Stub(TextFileResourceLoader) def handler = new InitScriptHandler(processor, executor, resourceLoader) def setup() { _ * gradle.startParameter >> startParameter }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 13:46:07 UTC 2024 - 2.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/api/v2/tf_dialect_to_executor.cc
"Counts how often a successful export from TF Dialect to Executor Dialect " "is", "status"); constexpr char kExportSuccess[] = "success"; constexpr char kExportFailed[] = "failed"; namespace { void AddTfDialectToExecutorPasses(OpPassManager &pm) { pm.addPass(mlir::TF::CreateTFRegionControlFlowToFunctional()); // First, we need to convert from functional, to executor dialect. pm.addNestedPass<FuncOp>(
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon May 13 23:22:50 UTC 2024 - 6.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/DirectExecutorService.java
} } } } /** * Checks if the executor has been shut down and increments the running task count. * * @throws RejectedExecutionException if the executor has been previously shutdown */ private void startTask() { synchronized (lock) { if (shutdown) { throw new RejectedExecutionException("Executor already shutdown"); } runningTasks++; } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 3.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CombinedFuture.java
boolean allMustSucceed, Executor listenerExecutor, AsyncCallable<V> callable) { super(futures, allMustSucceed, false); this.task = new AsyncCallableInterruptibleTask(callable, listenerExecutor); init(); } CombinedFuture( ImmutableCollection<? extends ListenableFuture<?>> futures, boolean allMustSucceed, Executor listenerExecutor, Callable<V> callable) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 6.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/CombinedFuture.java
boolean allMustSucceed, Executor listenerExecutor, AsyncCallable<V> callable) { super(futures, allMustSucceed, false); this.task = new AsyncCallableInterruptibleTask(callable, listenerExecutor); init(); } CombinedFuture( ImmutableCollection<? extends ListenableFuture<?>> futures, boolean allMustSucceed, Executor listenerExecutor, Callable<V> callable) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 6.8K bytes - Viewed (0)