Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 141 - 150 of 855 for concurrent (0.07 seconds)

  1. guava/src/com/google/common/util/concurrent/AtomicLongMap.java

    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.concurrent.atomic.AtomicLong;
    import java.util.function.LongBinaryOperator;
    import java.util.function.LongUnaryOperator;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A map containing {@code long} values that can be atomically updated. While writes to a
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Oct 10 23:13:45 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

    import java.util.concurrent.Callable;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.atomic.AtomicReference;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Serializes execution of tasks, somewhat like an "asynchronous {@code synchronized} block." Each
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 23 01:35:55 GMT 2025
    - 22.1K bytes
    - Click Count (0)
  3. guava/src/com/google/common/util/concurrent/MoreExecutors.java

    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.Executor;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    import java.util.concurrent.RejectedExecutionException;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.ScheduledFuture;
    import java.util.concurrent.ScheduledThreadPoolExecutor;
    import java.util.concurrent.ThreadFactory;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Oct 08 18:55:33 GMT 2025
    - 45.2K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static java.util.concurrent.TimeUnit.MINUTES;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.base.Joiner;
    import com.google.common.util.concurrent.CycleDetectingLockFactory.Policies;
    import com.google.common.util.concurrent.CycleDetectingLockFactory.Policy;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 19 18:03:30 GMT 2024
    - 16.2K bytes
    - Click Count (0)
  5. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/InterruptibleTask.java

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.util.concurrent.NullnessCasts.uncheckedCastNullableTToT;
    
    import org.jspecify.annotations.Nullable;
    
    /** Emulation for InterruptibleTask in GWT. */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 1.6K bytes
    - Click Count (0)
  6. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/MapMaker.java

     */
    
    package com.google.common.collect;
    
    import static com.google.common.base.Preconditions.checkArgument;
    
    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentMap;
    
    /**
     * MapMaker emulation.
     *
     * @author Charles Fry
     */
    public final class MapMaker {
      private int initialCapacity = 16;
    
      public MapMaker() {}
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 1.6K bytes
    - Click Count (0)
  7. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import com.google.errorprone.annotations.DoNotMock;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.RejectedExecutionException;
    import org.jspecify.annotations.NullMarked;
    import org.jspecify.annotations.Nullable;
    
    /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 8K bytes
    - Click Count (0)
  8. guava/src/com/google/common/util/concurrent/ListenableFuture.java

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import com.google.errorprone.annotations.DoNotMock;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.RejectedExecutionException;
    import org.jspecify.annotations.NullMarked;
    import org.jspecify.annotations.Nullable;
    
    /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 8K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

    import java.net.Socket
    import java.util.concurrent.ConcurrentLinkedQueue
    import java.util.concurrent.TimeUnit
    import okhttp3.Address
    import okhttp3.ConnectionPool
    import okhttp3.Route
    import okhttp3.internal.closeQuietly
    import okhttp3.internal.concurrent.Task
    import okhttp3.internal.concurrent.TaskQueue
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.concurrent.assertLockHeld
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Oct 08 03:50:05 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTest.java

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertWithMessage;
    
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /** Test for {@link ListenableFuture}. */
    @NullUnmarked
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 19 18:03:30 GMT 2024
    - 1.7K bytes
    - Click Count (0)
Back to Top