Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 571 - 580 of 1,216 for Concurrent (0.13 seconds)

  1. src/main/java/jcifs/internal/smb2/rdma/disni/DisniMemoryRegion.java

     */
    package jcifs.internal.smb2.rdma.disni;
    
    import java.nio.ByteBuffer;
    import java.util.EnumSet;
    import java.util.Map;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.atomic.AtomicLong;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import jcifs.internal.smb2.rdma.RdmaAccess;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java

    import java.util.HashMap;
    import java.util.Map;
    import java.util.Random;
    import java.util.Set;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Future;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.concurrent.atomic.AtomicInteger;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 25.7K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/cache/CacheBuilderTest.java

    import java.util.HashMap;
    import java.util.Map;
    import java.util.Random;
    import java.util.Set;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Future;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.concurrent.atomic.AtomicInteger;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 25.6K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ThreadInterruptTest.kt

    import assertk.fail
    import java.io.IOException
    import java.net.ServerSocket
    import java.net.Socket
    import java.net.SocketException
    import java.util.concurrent.CompletableFuture
    import java.util.concurrent.RejectedExecutionException
    import java.util.concurrent.TimeUnit
    import kotlin.test.assertFailsWith
    import okhttp3.Call
    import okhttp3.Callback
    import okhttp3.DelegatingServerSocketFactory
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 18:33:48 GMT 2025
    - 6.4K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/base/StopwatchTest.java

    import static com.google.common.base.ReflectionFreeAssertThrows.assertThrows;
    import static com.google.common.truth.Truth.assertThat;
    import static java.util.concurrent.TimeUnit.MICROSECONDS;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    
    import com.google.common.annotations.GwtCompatible;
    import com.google.common.annotations.GwtIncompatible;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 6.3K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/collect/ReflectionFreeAssertThrows.java

    import java.nio.charset.UnsupportedCharsetException;
    import java.util.ConcurrentModificationException;
    import java.util.NoSuchElementException;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.TimeoutException;
    import junit.framework.AssertionFailedError;
    import org.jspecify.annotations.NullMarked;
    import org.jspecify.annotations.Nullable;
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 6.9K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

    import java.security.PrivilegedExceptionAction;
    import java.util.Locale;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
    import java.util.concurrent.locks.LockSupport;
    import org.jspecify.annotations.Nullable;
    import sun.misc.Unsafe;
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 33.2K bytes
    - Click Count (0)
  8. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/GwtFuturesCatchingSpecialization.java

     * or implied. See the License for the specific language governing permissions and limitations under
     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import com.google.common.base.Function;
    import java.util.concurrent.Executor;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Hidden superclass of {@link Futures} that provides us a place to declare special GWT versions of
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 2K bytes
    - Click Count (0)
  9. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

    import android.annotation.SuppressLint
    import java.util.concurrent.ThreadFactory
    import java.util.concurrent.TimeUnit
    import java.util.logging.Handler
    import java.util.logging.Level
    import java.util.logging.LogManager
    import java.util.logging.LogRecord
    import java.util.logging.Logger
    import okhttp3.internal.buildConnectionPool
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.concurrent.withLock
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/Futures.java

    import com.google.j2objc.annotations.RetainedLocalRef;
    import java.time.Duration;
    import java.util.Collection;
    import java.util.List;
    import java.util.concurrent.Callable;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.RejectedExecutionException;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 64.2K bytes
    - Click Count (0)
Back to Top