- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 184 for task (0.38 sec)
-
maven-core/src/test/java/org/apache/maven/lifecycle/internal/stub/LifecycleTaskSegmentCalculatorStub.java
if (aggr.equals(task)) { boolean aggregating = true; if (currentSegment == null || currentSegment.isAggregating() != aggregating) { currentSegment = new TaskSegment(aggregating); taskSegments.add(currentSegment); } currentSegment.getTasks().add(new GoalTask(task)); } else {
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Wed Sep 06 08:39:32 GMT 2023 - 3.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
AbstractService service, ScheduledExecutorService executor, Runnable task) { return new FutureAsCancellable( executor.scheduleWithFixedDelay(task, initialDelay, delay, unit)); } }; } /** * Returns a {@link Scheduler} that schedules the task using the {@link * ScheduledExecutorService#scheduleAtFixedRate} method. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 25.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheLoaderTest.java
public class CacheLoaderTest extends TestCase { private static class QueuingExecutor implements Executor { private final Deque<Runnable> tasks = Queues.newArrayDeque(); @Override public void execute(Runnable task) { tasks.add(task); } private void runNext() { tasks.removeFirst().run(); } } public void testAsyncReload() throws Exception {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Fri Aug 05 17:21:46 GMT 2022 - 3.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/entity/PingResponse.java
private static final String NUMBER_OF_PENDING_TASKS = "number_of_pending_tasks"; private static final String NUMBER_OF_IN_FLIGHT_FETCH = "number_of_in_flight_fetch"; private static final String DELAYED_UNASSIGNED_SHARDS = "delayed_unassigned_shards"; private static final String TASK_MAX_WAIT_TIME_IN_QUEUE_IN_MILLIS = "task_max_waiting_in_queue_millis";
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 5.9K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/CacheLoader.java
} @Override public ListenableFuture<V> reload(final K key, final V oldValue) { ListenableFutureTask<V> task = ListenableFutureTask.create(() -> loader.reload(key, oldValue).get()); executor.execute(task); return task; } @Override public Map<K, V> loadAll(Iterable<? extends K> keys) throws Exception { return loader.loadAll(keys);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 19 20:20:14 GMT 2022 - 9.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java
@CheckForNull private volatile InterruptibleTask<?> task; TrustedListenableFutureTask(Callable<V> callable) { this.task = new TrustedFutureInterruptibleTask(callable); } TrustedListenableFutureTask(AsyncCallable<V> callable) { this.task = new TrustedFutureInterruptibleAsyncTask(callable); } @Override public void run() { InterruptibleTask<?> localTask = task; if (localTask != null) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Oct 01 17:18:04 GMT 2021 - 5.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/RateLimiter.java
* <p>As an example, imagine that we have a list of tasks to execute, but we don't want to submit * more than 2 per second: * * <pre>{@code * final RateLimiter rateLimiter = RateLimiter.create(2.0); // rate is "2 permits per second" * void submitTasks(List<Runnable> tasks, Executor executor) { * for (Runnable task : tasks) { * rateLimiter.acquire(); // may wait * executor.execute(task); * } * } * }</pre> *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 18.2K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoDescriptorCreator.java
return new org.codehaus.plexus.util.xml.Xpp3Dom(dom); } // org.apache.maven.plugins:maven-remote-resources-plugin:1.0:process@executionId public MojoDescriptor getMojoDescriptor(String task, MavenSession session, MavenProject project) throws PluginNotFoundException, PluginResolutionException, PluginDescriptorParsingException,
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Jan 10 12:55:54 GMT 2024 - 11.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
} /** * Submits a blocking task for the given {@link Future} to provide {@link ListenableFuture} * functionality. * * <p><b>Warning:</b> If the input future does not already implement {@code ListenableFuture}, the * returned future will emulate {@link ListenableFuture#addListener} by submitting a task to the * given executor at the first call to {@code addListener}. The task must be started by the
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Dec 14 20:35:03 GMT 2023 - 7.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
ExecutorService delegate = mock(ExecutorService.class); ListeningExecutorService service = listeningDecorator(delegate); Runnable task = new Runnable() { @Override public void run() {} }; service.execute(task); verify(delegate).execute(task); } public void testListeningDecorator_scheduleSuccess() throws Exception {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (3)