Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 976 for concurrently (0.12 sec)

  1. src/main/java/jcifs/smb1/dcerpc/DcerpcConstants.java

        /**
         * Reserved flag for future use
         */
        int DCERPC_RESERVED_1 = 0x08;
        /**
         * Supports concurrent multiplexing flag
         */
        int DCERPC_CONC_MPX = 0x10; /* supports concurrent multiplexing */
        /**
         * Did not execute flag - indicates request was not executed
         */
        int DCERPC_DID_NOT_EXECUTE = 0x20;
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.2K bytes
    - Viewed (0)
  2. 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;
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ForwardingBlockingQueue.java

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.collect.ForwardingQueue;
    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import java.util.Collection;
    import java.util.concurrent.BlockingQueue;
    import java.util.concurrent.TimeUnit;
    import org.jspecify.annotations.Nullable;
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 3K bytes
    - Viewed (0)
  4. android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

    import static org.junit.Assert.assertThrows;
    
    import com.google.common.testing.GcFinalization.FinalizationPredicate;
    import com.google.common.util.concurrent.SettableFuture;
    import java.lang.ref.WeakReference;
    import java.util.WeakHashMap;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.atomic.AtomicBoolean;
    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
    - 7.9K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static java.util.concurrent.Executors.defaultThreadFactory;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.testing.NullPointerTester;
    import java.lang.Thread.UncaughtExceptionHandler;
    import java.util.Locale;
    import java.util.concurrent.ThreadFactory;
    import junit.framework.TestCase;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  6. src/main/java/jcifs/internal/smb2/lease/LeaseManager.java

    import java.util.Map;
    import java.util.concurrent.CompletableFuture;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import java.util.concurrent.locks.ReadWriteLock;
    import java.util.concurrent.locks.ReentrantReadWriteLock;
    
    import org.slf4j.Logger;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 18.8K bytes
    - Viewed (0)
  7. src/main/java/jcifs/internal/smb2/lease/DirectoryCacheEntry.java

     */
    package jcifs.internal.smb2.lease;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.locks.ReadWriteLock;
    import java.util.concurrent.locks.ReentrantReadWriteLock;
    
    /**
     * Cache entry for directory contents with thread-safe operations
     */
    public class DirectoryCacheEntry {
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 02:21:31 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import java.lang.Thread.UncaughtExceptionHandler;
    import java.util.Locale;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ThreadFactory;
    import java.util.concurrent.atomic.AtomicLong;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A ThreadFactory builder, providing any combination of these features:
     *
     * <ul>
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:35:26 UTC 2025
    - 9K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/TimeLimiter.java

     */
    
    package com.google.common.util.concurrent;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import com.google.errorprone.annotations.DoNotMock;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.TimeUnit;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Jan 18 02:54:30 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import com.google.common.collect.ImmutableSet;
    import java.lang.reflect.Field;
    import java.lang.reflect.Method;
    import java.lang.reflect.Modifier;
    import java.net.URLClassLoader;
    import java.util.Set;
    import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
    import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
    import junit.framework.TestCase;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 6.5K bytes
    - Viewed (0)
Back to top