Search Options

Results per page
Sort
Preferred Languages
Advance

Results 211 - 220 of 937 for Concurrent (0.04 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java

    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    import java.util.concurrent.Semaphore;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReadWriteLock;
    import java.util.concurrent.locks.ReentrantLock;
    import java.util.concurrent.locks.ReentrantReadWriteLock;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    import java.util.concurrent.Semaphore;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReadWriteLock;
    import java.util.concurrent.locks.ReentrantLock;
    import java.util.concurrent.locks.ReentrantReadWriteLock;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  3. src/test/java/jcifs/smb1/smb1/BufferCacheSecurityTest.java

    import static org.junit.jupiter.api.Assertions.assertTrue;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicInteger;
    
    import org.junit.jupiter.api.Test;
    
    /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 9.6K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/cache/AbstractLoadingCacheTest.java

    import static com.google.common.truth.Truth.assertThat;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.util.concurrent.ExecutionError;
    import com.google.common.util.concurrent.UncheckedExecutionException;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.atomic.AtomicReference;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    import org.jspecify.annotations.Nullable;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 5K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/cache/Cache.java

    import com.google.common.util.concurrent.ExecutionError;
    import com.google.common.util.concurrent.UncheckedExecutionException;
    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import com.google.errorprone.annotations.CompatibleWith;
    import com.google.errorprone.annotations.DoNotMock;
    import java.util.Map;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ConcurrentMap;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  6. src/test/java/jcifs/SmbSessionTest.java

            @Test
            @DisplayName("Should handle concurrent access patterns")
            void shouldHandleConcurrentAccessPatterns() throws InterruptedException {
                SmbSession mockSession = mock(SmbSession.class);
                Configuration mockConfig = mock(Configuration.class);
                when(mockSession.getConfig()).thenReturn(mockConfig);
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.1K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.collect.Sets.newConcurrentHashSet;
    import static java.util.Objects.requireNonNull;
    import static java.util.concurrent.atomic.AtomicIntegerFieldUpdater.newUpdater;
    import static java.util.concurrent.atomic.AtomicReferenceFieldUpdater.newUpdater;
    
    import com.google.common.annotations.GwtCompatible;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  8. guava-gwt/test/com/google/common/collect/testing/google/Google.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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 19 16:02:36 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/FuturesGetChecked.java

    import java.lang.reflect.InvocationTargetException;
    import java.util.Arrays;
    import java.util.List;
    import java.util.Set;
    import java.util.concurrent.CopyOnWriteArraySet;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import org.jspecify.annotations.Nullable;
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/ForwardingBlockingDeque.java

    package com.google.common.collect;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import java.util.Collection;
    import java.util.concurrent.BlockingDeque;
    import java.util.concurrent.TimeUnit;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A {@link BlockingDeque} which forwards all its method calls to another {@code BlockingDeque}.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.3K bytes
    - Viewed (0)
Back to top