Search Options

Results per page
Sort
Preferred Languages
Advance

Results 611 - 620 of 1,082 for concurrent (0.05 sec)

  1. android/guava-testlib/src/com/google/common/testing/ForwardingWrapperTester.java

    import java.lang.reflect.InvocationTargetException;
    import java.lang.reflect.Method;
    import java.lang.reflect.Modifier;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.atomic.AtomicInteger;
    import org.jspecify.annotations.NullMarked;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Tester to ensure forwarding wrapper works by delegating calls to the corresponding method with
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 9.1K bytes
    - Viewed (0)
  2. android/guava-testlib/src/com/google/common/collect/testing/Helpers.java

       *     the size method
       */
      public static <T extends @Nullable Object> Collection<T> misleadingSizeCollection(int delta) {
        // It would be nice to be able to return a real concurrent
        // collection like ConcurrentLinkedQueue, so that e.g. concurrent
        // iteration would work, but that would not be GWT-compatible.
        // We are not "just" inheriting from ArrayList here as this doesn't work for J2kt.
        return new AbstractList<T>() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Oct 10 23:13:45 UTC 2025
    - 17.2K bytes
    - Viewed (0)
  3. src/main/java/jcifs/util/transport/Transport.java

    import java.io.InputStream;
    import java.net.SocketTimeoutException;
    import java.util.Iterator;
    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.Set;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.atomic.AtomicLong;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import jcifs.RuntimeCIFSException;
    import jcifs.smb.RequestParam;
    
    /**
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

    import java.net.SocketTimeoutException
    import java.time.Duration
    import java.util.Arrays
    import java.util.Collections
    import java.util.Random
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.atomic.AtomicInteger
    import kotlin.test.assertFailsWith
    import mockwebserver3.Dispatcher
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 35.5K bytes
    - Viewed (0)
  5. mockwebserver-junit5/src/test/java/mockwebserver3/junit5/StartStopTest.kt

     * limitations under the License.
     */
    package mockwebserver3.junit5
    
    import assertk.assertThat
    import assertk.assertions.isFalse
    import assertk.assertions.isTrue
    import java.util.concurrent.CopyOnWriteArrayList
    import mockwebserver3.Dispatcher
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import mockwebserver3.RecordedRequest
    import org.junit.jupiter.api.Test
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Jun 18 11:13:17 UTC 2025
    - 3.3K bytes
    - Viewed (1)
  6. guava/src/com/google/common/util/concurrent/UncaughtExceptionHandlers.java

     * or implied. See the License for the specific language governing permissions and limitations under
     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static java.util.logging.Level.SEVERE;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.annotations.VisibleForTesting;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Feb 10 21:03:40 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  7. impl/maven-core/src/main/java/org/apache/maven/execution/DefaultMavenExecutionResult.java

     * under the License.
     */
    package org.apache.maven.execution;
    
    import java.util.Collections;
    import java.util.IdentityHashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.CopyOnWriteArrayList;
    
    import org.apache.maven.project.DependencyResolutionResult;
    import org.apache.maven.project.MavenProject;
    
    public class DefaultMavenExecutionResult implements MavenExecutionResult {
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  8. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/PluginLifecycle.java

     * KIND, either express or implied.  See the License for the
     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.lifecycle.internal.concurrent;
    
    import java.util.Collection;
    import java.util.Collections;
    import java.util.List;
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    import org.apache.maven.api.Lifecycle;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

    import java.util.EnumMap;
    import java.util.List;
    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.Set;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.locks.ReentrantLock;
    import java.util.concurrent.locks.ReentrantReadWriteLock;
    import java.util.logging.Level;
    import org.jspecify.annotations.Nullable;
    
    /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 11 17:06:34 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  10. okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt

     * limitations under the License.
     *
     */
    package okhttp3.coroutines
    
    import assertk.assertThat
    import assertk.assertions.isEqualTo
    import assertk.assertions.isTrue
    import java.io.IOException
    import java.util.concurrent.TimeUnit
    import kotlin.test.assertFailsWith
    import kotlin.time.Duration.Companion.seconds
    import kotlinx.coroutines.CancellationException
    import kotlinx.coroutines.Dispatchers
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 5.3K bytes
    - Viewed (0)
Back to top