Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 977 for concurrent (0.14 sec)

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

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.base.Preconditions.checkNotNull;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.base.Preconditions;
    import com.google.common.collect.Queues;
    import com.google.errorprone.annotations.concurrent.GuardedBy;
    import java.util.ArrayList;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Dec 13 19:45:20 UTC 2023
    - 8.2K bytes
    - Viewed (0)
  2. 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;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  3. 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;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static org.junit.Assert.assertThrows;
    
    import java.util.concurrent.Callable;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  5. guava-gwt/src/com/google/common/base/Base.gwt.xml

        util.concurrent tests under Guava.
    
        The problem is that GWT responds poorly to two .gwt.xml files in the same
        Java package; see
        https://groups.google.com/g/google-web-toolkit-contributors/c/CqYH59Dt_rQ/m/uVGW1QdUsXUJ
        for details.
    
        The summary is that it ignores one file in favor of the other.
        util.concurrent, like nearly all our packages, has two .gwt.xml files: one
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jul 19 16:02:36 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

    import com.google.common.collect.Lists;
    import java.util.Collection;
    import java.util.List;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import junit.framework.TestCase;
    
    /**
     * Test for {@link WrappingExecutorService}
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/AtomicLongMap.java

    import java.util.Map;
    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 javax.annotation.CheckForNull;
    
    /**
     * A map containing {@code long} values that can be atomically updated. While writes to a
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  8. 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.checkerframework.checker.nullness.qual.Nullable;
    
    /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  9. 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.checkerframework.checker.nullness.qual.Nullable;
    
    /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.Executor;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeoutException;
    import junit.framework.TestCase;
    
    /**
     * Unit test for {@link AbstractExecutionThreadService}.
     *
     * @author Jesse Wilson
     */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 12.7K bytes
    - Viewed (0)
Back to top