Search Options

Results per page
Sort
Preferred Languages
Advance

Results 511 - 520 of 895 for Concurrent (0.09 sec)

  1. android/guava/src/com/google/common/collect/NaturalOrdering.java

    import com.google.common.annotations.GwtCompatible;
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.errorprone.annotations.concurrent.LazyInit;
    import java.io.Serializable;
    import org.jspecify.annotations.Nullable;
    
    /** An ordering that uses the natural order of the values. */
    @GwtCompatible
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jun 04 13:03:16 UTC 2025
    - 3K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/SneakyThrows.java

     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express 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.annotations.GwtCompatible;
    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    
    /** Static utility method for unchecked throwing of any {@link Throwable}. */
    @GwtCompatible
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Dec 30 18:44:22 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/JdkBackedImmutableMultiset.java

    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.primitives.Ints;
    import com.google.errorprone.annotations.concurrent.LazyInit;
    import java.util.Collection;
    import java.util.Map;
    import org.jspecify.annotations.Nullable;
    
    /**
     * An implementation of ImmutableMultiset backed by a JDK Map and a list of entries. Used to protect
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Apr 08 13:05:15 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  4. guava-tests/benchmark/com/google/common/cache/SegmentBenchmark.java

    import com.google.caliper.BeforeExperiment;
    import com.google.caliper.Benchmark;
    import com.google.caliper.Param;
    import com.google.common.cache.LocalCache.Segment;
    import java.util.concurrent.atomic.AtomicReferenceArray;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Benchmark for {@code LocalCache.Segment.expand()}.
     *
     * @author Charles Fry
     */
    @NullUnmarked
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  5. docs/smb3-features/03-multi-channel-design.md

            
            return Math.max(0, score);
        }
    }
    ```
    
    ### 4.3 Channel Manager
    ```java
    package jcifs.internal.smb2.multichannel;
    
    import java.util.*;
    import java.util.concurrent.*;
    import java.util.concurrent.atomic.AtomicInteger;
    
    public class ChannelManager {
        private final CIFSContext context;
        private final SmbSession session;
        private final Map<String, ChannelInfo> channels;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 39.6K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Writer.kt

     */
    package okhttp3.internal.http2
    
    import java.io.Closeable
    import java.io.IOException
    import java.util.logging.Level.FINE
    import java.util.logging.Logger
    import okhttp3.internal.concurrent.Lockable
    import okhttp3.internal.concurrent.withLock
    import okhttp3.internal.format
    import okhttp3.internal.http2.Http2.CONNECTION_PREFACE
    import okhttp3.internal.http2.Http2.FLAG_ACK
    import okhttp3.internal.http2.Http2.FLAG_END_HEADERS
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 11K bytes
    - Viewed (0)
  7. android/guava-testlib/src/com/google/common/collect/testing/TestsForMapsInJavaUtil.java

    import java.util.Hashtable;
    import java.util.LinkedHashMap;
    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.SortedMap;
    import java.util.TreeMap;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentSkipListMap;
    import junit.framework.Test;
    import junit.framework.TestSuite;
    
    /**
     * Generates a test suite covering the {@link Map} implementations in the {@link java.util} package.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 12 16:28:01 UTC 2025
    - 17.2K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt

    import java.net.Socket
    import java.net.SocketTimeoutException
    import java.nio.charset.Charset
    import java.util.Collections
    import java.util.Locale
    import java.util.TimeZone
    import java.util.concurrent.ThreadFactory
    import java.util.concurrent.TimeUnit
    import kotlin.text.Charsets.UTF_16BE
    import kotlin.text.Charsets.UTF_16LE
    import kotlin.text.Charsets.UTF_32BE
    import kotlin.text.Charsets.UTF_32LE
    import kotlin.text.Charsets.UTF_8
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 10.2K bytes
    - Viewed (1)
  9. src/main/java/jcifs/internal/smb2/rdma/tcp/TcpMemoryRegion.java

     * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
     */
    package jcifs.internal.smb2.rdma.tcp;
    
    import java.nio.ByteBuffer;
    import java.util.EnumSet;
    import java.util.concurrent.atomic.AtomicInteger;
    
    import jcifs.internal.smb2.rdma.RdmaAccess;
    import jcifs.internal.smb2.rdma.RdmaMemoryRegion;
    
    /**
     * TCP memory region implementation.
     *
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/Lockable.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    @file:Suppress("PLATFORM_CLASS_MAPPED_TO_KOTLIN", "NOTHING_TO_INLINE")
    
    package okhttp3.internal.concurrent
    
    import kotlin.contracts.ExperimentalContracts
    import kotlin.contracts.InvocationKind
    import kotlin.contracts.contract
    import okhttp3.internal.assertionsEnabled
    
    /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 2.1K bytes
    - Viewed (0)
Back to top