- Sort Score
- Result 10 results
- Languages All
Results 251 - 260 of 2,328 for executors (0.21 sec)
-
platforms/core-runtime/logging/src/test/groovy/org/gradle/internal/logging/console/ThrottlingOutputEventListenerTest.groovy
} def "shuts down executor when receiving end output event"() { expect: !executor.isShutdown() when: renderer.onOutput(new EndOutputEvent()) then: executor.isShutdown() } def "throwables are not propagated out of the run method of the output loop"() { given: def executor = new MockExecutor()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 4.6K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/ExecHandleRunner.java
private final Executor executor; private Process process; private boolean aborted; private final StreamsHandler streamsHandler; private volatile BuildOperationRef associatedBuildOperation; public ExecHandleRunner( DefaultExecHandle execHandle, StreamsHandler streamsHandler, ProcessLauncher processLauncher, Executor executor, BuildOperationRef associatedBuildOperation
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 4.8K bytes - Viewed (0) -
android/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) -
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) -
android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
} public void testNoOpScheduledExecutorShutdown() { ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor(); assertFalse(executor.isShutdown()); assertFalse(executor.isTerminated()); executor.shutdown(); assertTrue(executor.isShutdown()); assertTrue(executor.isTerminated()); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 3.7K bytes - Viewed (0) -
guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
} public void testNoOpScheduledExecutorShutdown() { ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor(); assertFalse(executor.isShutdown()); assertFalse(executor.isTerminated()); executor.shutdown(); assertTrue(executor.isShutdown()); assertTrue(executor.isTerminated()); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 3.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) -
android/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) -
subprojects/core/src/main/java/org/gradle/process/internal/AbstractExecHandleBuilder.java
protected boolean daemon; private final Executor executor; AbstractExecHandleBuilder(PathToFileResolver fileResolver, Executor executor, BuildCancellationToken buildCancellationToken) { super(fileResolver); this.buildCancellationToken = buildCancellationToken; this.executor = executor; streamsSpec.setStandardOutput(SafeStreams.systemOut());
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 06 16:16:31 UTC 2020 - 6K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_host_send_recv_device_context_test.cc
stream_executor::StreamExecutor* executor = platform->ExecutorForDevice(0).value(); TF_ASSERT_OK_AND_ASSIGN(auto stream, executor->CreateStream()); se::DeviceMemoryBase gpu_dst{device_tensor.data(), 4 * sizeof(float)}; xla::Shape shape; TF_ASSERT_OK(TensorShapeToXLAShape(DT_FLOAT, TensorShape({2, 2}), &shape)); TF_ASSERT_OK_AND_ASSIGN(auto se_event, executor->CreateEvent());
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 17 22:46:36 UTC 2024 - 7.2K bytes - Viewed (0)