- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,153 for concurrently (0.23 sec)
-
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
* * <ul> * <li>Multiple events for the same listener are never dispatched concurrently. * <li>Events for the different listeners are dispatched concurrently. * <li>All events for a given listener dispatch on the provided {@link #executor}. * <li>It is easy for the user to ensure that listeners are never invoked while holding locks. * </ul> *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 8.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
*/ package okhttp3 import java.util.ArrayDeque import java.util.Collections import java.util.Deque import java.util.concurrent.ExecutorService import java.util.concurrent.SynchronousQueue import java.util.concurrent.ThreadPoolExecutor import java.util.concurrent.TimeUnit import java.util.concurrent.locks.ReentrantLock import okhttp3.internal.assertNotHeld import okhttp3.internal.connection.Locks.withLock
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 9K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/LongAddable.java
* the License. */ package com.google.common.cache; import com.google.common.annotations.GwtCompatible; /** * Abstract interface for objects that can concurrently add longs. * * @author Louis Wasserman */ @GwtCompatible @ElementTypesAreNonnullByDefault interface LongAddable { void increment(); void add(long x); long sum();
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Jun 15 18:00:07 GMT 2021 - 918 bytes - Viewed (0) -
guava/src/com/google/common/cache/LoadingCache.java
import com.google.common.base.Function; import com.google.common.collect.ImmutableMap; import com.google.common.util.concurrent.ExecutionError; import com.google.common.util.concurrent.UncheckedExecutionException; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ExecutionException; /**
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Sat Aug 06 17:12:03 GMT 2022 - 8.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
import com.google.errorprone.annotations.concurrent.GuardedBy; import com.google.j2objc.annotations.WeakOuter; import java.util.concurrent.Callable; import java.util.concurrent.Executor; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledFuture; import java.util.concurrent.ThreadFactory; import java.util.concurrent.TimeUnit;
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) -
guava/src/com/google/common/cache/LongAddable.java
* the License. */ package com.google.common.cache; import com.google.common.annotations.GwtCompatible; /** * Abstract interface for objects that can concurrently add longs. * * @author Louis Wasserman */ @GwtCompatible @ElementTypesAreNonnullByDefault interface LongAddable { void increment(); void add(long x); long sum();
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Tue Jun 15 18:00:07 GMT 2021 - 918 bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MapMaker.java
} /** * Guides the allowed concurrency among update operations. Used as a hint for internal sizing. The * table is internally partitioned to try to permit the indicated number of concurrent updates * without contention. Because assignment of entries to these partitions is not necessarily * uniform, the actual concurrency observed may vary. Ideally, you should choose a value to
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Mar 13 14:30:51 GMT 2023 - 12.8K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/LongAddable.java
* or implied. See the License for the specific language governing permissions and limitations under * the License. */ package com.google.common.hash; /** * Abstract interface for objects that can concurrently add longs. * * @author Louis Wasserman */ @ElementTypesAreNonnullByDefault interface LongAddable { void increment(); void add(long x); long sum();
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 20 18:43:59 GMT 2021 - 850 bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/Task.kt
* decide not to by returning -1L. * * Task Queues * ----------- * * Tasks are bound to the [TaskQueue] they are scheduled in. Each queue is sequential and the tasks * within it never execute concurrently. It is an error to use a task in multiple queues. */ abstract class Task( val name: String, val cancelable: Boolean = true, ) { // Guarded by the TaskRunner. internal var queue: TaskQueue? = null
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.4K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
* limitations under the License. */ package okhttp3.internal.concurrent import assertk.assertThat import assertk.assertions.isEqualTo import java.io.Closeable import java.util.AbstractQueue import java.util.concurrent.BlockingQueue import java.util.concurrent.Executors import java.util.concurrent.TimeUnit import java.util.logging.Logger import kotlin.concurrent.withLock import okhttp3.OkHttpClient
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 12.5K bytes - Viewed (0)