- Sort Score
- Result 10 results
- Languages All
Results 231 - 240 of 2,328 for executors (0.15 sec)
-
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) -
guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
} /** * Adds a listener that will be called using the given executor when events are later {@link * #enqueue enqueued} and {@link #dispatch dispatched}. */ public void addListener(L listener, Executor executor) { checkNotNull(listener, "listener"); checkNotNull(executor, "executor"); listeners.add(new PerListenerQueue<>(listener, executor)); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 8.2K bytes - Viewed (0) -
pkg/volume/util/types/types.go
// UniquePVCName defines the type to key pvc off type UniquePVCName types.UID // GeneratedOperations contains the operation that is created as well as // supporting functions required for the operation executor type GeneratedOperations struct { // Name of operation - could be used for resetting shared exponential backoff OperationName string OperationFunc func() (context OperationContext) EventRecorderFunc func(*error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 31 17:23:56 UTC 2024 - 5.2K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/streams/ForwardStdinStreamsHandler.java
this.input = input; } @Override public void connectStreams(Process process, String processName, Executor executor) { this.executor = executor; /* There's a potential problem here in that DisconnectableInputStream reads from input in the background.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jul 11 16:06:58 UTC 2023 - 2.7K 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) -
subprojects/core/src/integTest/groovy/org/gradle/api/tasks/TaskServiceInjectionIntegrationTest.groovy
class CustomTask extends DefaultTask { private final WorkerExecutor executor @Inject CustomTask(WorkerExecutor executor) { this.executor = executor } @TaskAction void printIt() { println(executor != null ? "got it" : "NOT IT") } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 04 22:26:51 UTC 2021 - 7.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
} /** * Adds a listener that will be called using the given executor when events are later {@link * #enqueue enqueued} and {@link #dispatch dispatched}. */ public void addListener(L listener, Executor executor) { checkNotNull(listener, "listener"); checkNotNull(executor, "executor"); listeners.add(new PerListenerQueue<>(listener, executor)); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 8.2K 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)