- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for task (0.2 sec)
-
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* turn, and does not create any threads of its own. * * <p>After execution begins on a thread from the {@code delegate} {@link Executor}, tasks are * polled and executed from a task queue until there are no more tasks. The thread will not be * released until there are no more tasks to run. * * <p>If a task is submitted while a thread is executing tasks from the task queue, the thread
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
@CheckForNull // null only for TOMBSTONE final Runnable task; @CheckForNull // null only for TOMBSTONE final Executor executor; // writes to next are made visible by subsequent CAS's on the listeners field @CheckForNull Listener next; Listener(Runnable task, Executor executor) { this.task = task; this.executor = executor; } Listener() {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* * @throws RejectedExecutionException if the task cannot be scheduled for execution * @since 28.2 */ public static <O extends @Nullable Object> ListenableFuture<O> submit( Callable<O> callable, Executor executor) { TrustedListenableFutureTask<O> task = TrustedListenableFutureTask.create(callable); executor.execute(task); return task; } /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 59.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionError.java
import javax.annotation.CheckForNull; /** * {@link Error} variant of {@link java.util.concurrent.ExecutionException}. As with {@code * ExecutionException}, the error's {@linkplain #getCause() cause} comes from a failed task, * possibly run in another thread. That cause should itself be an {@code Error}; if not, use {@code * ExecutionException} or {@link UncheckedExecutionException}. This allows the client code to
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Mar 07 17:52:19 GMT 2024 - 3.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
return callable.toString(); } }); executor.execute(task); this.future = task; } private ClosingFuture(final AsyncClosingCallable<V> callable, Executor executor) { checkNotNull(callable); TrustedListenableFutureTask<V> task = TrustedListenableFutureTask.create( new AsyncCallable<V>() { @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 98.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/UncheckedExecutionException.java
* ExecutionException}, the exception's {@linkplain #getCause() cause} comes from a failed task, * possibly run in another thread. * * <p>{@code UncheckedExecutionException} is intended as an alternative to {@code * ExecutionException} when the exception thrown by a task is an unchecked exception. However, it * may also wrap a checked exception in some cases. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Mar 07 17:52:19 GMT 2024 - 4.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/RegularImmutableMap.java
} if (hashTableObject instanceof byte[]) { byte[] hashTable = (byte[]) hashTableObject; int mask = hashTable.length - 1; for (int h = Hashing.smear(key.hashCode()); ; h++) { h &= mask; int keyIndex = hashTable[h] & BYTE_MASK; // unsigned read if (keyIndex == BYTE_MASK) { // -1 signed becomes 255 unsigned return null;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Apr 15 22:32:14 GMT 2024 - 22.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/CompactLinkedHashMap.java
setPredecessor(succ, pred); } } @Override void insertEntry( int entryIndex, @ParametricNullness K key, @ParametricNullness V value, int hash, int mask) { super.insertEntry(entryIndex, key, value, hash, mask); setSucceeds(lastEntry, entryIndex); setSucceeds(entryIndex, ENDPOINT); } @Override void accessEntry(int index) { if (accessOrder) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 8.5K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/Hashing.java
* <li>When you reduce the number of buckets, you can accept that the most recently added * buckets will be removed first. More concretely, if you are dividing traffic among tasks, * you can decrease the number of tasks from 15 and 10, killing off the final 5 tasks, and * {@code consistentHash} will handle it. If, however, you are dividing traffic among
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 09 00:37:15 GMT 2024 - 29.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/TreeMultimapExplicitTest.java
assertEquals(Sets.<@Nullable String>newHashSet(null, "tree"), keySet.headSet("yahoo")); assertEquals(Sets.newHashSet("google"), keySet.tailSet("yahoo")); assertEquals(Sets.newHashSet("tree"), keySet.subSet("ask", "yahoo")); } @GwtIncompatible // SerializableTester public void testExplicitComparatorSerialization() { TreeMultimap<@Nullable String, @Nullable Integer> multimap = createPopulate();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Mar 07 18:34:03 GMT 2024 - 8.3K bytes - Viewed (0)