Search Options

Results per page
Sort
Preferred Languages
Advance

Results 491 - 500 of 1,082 for concurrents (0.06 sec)

  1. docs/smb3-features/01-smb3-lease-design.md

            return parentLeaseKey != null;
        }
    }
    ```
    
    ### 4.3 Lease Manager
    ```java
    package jcifs.internal.smb2.lease;
    
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.locks.ReadWriteLock;
    import java.util.concurrent.locks.ReentrantReadWriteLock;
    import jcifs.CIFSContext;
    
    public class LeaseManager {
        private final ConcurrentHashMap<Smb2LeaseKey, LeaseEntry> leases;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 22K bytes
    - Viewed (0)
  2. docs/smb3-features/02-persistent-handles-design.md

        }
    }
    ```
    
    ### 4.5 Persistent Handle Manager
    ```java
    package jcifs.internal.smb2.persistent;
    
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.TimeUnit;
    import java.io.*;
    import java.nio.file.*;
    
    public class PersistentHandleManager {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 31.6K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/Tags.kt

     */
    package okhttp3.internal
    
    import java.util.concurrent.atomic.AtomicReference
    import kotlin.reflect.KClass
    
    /**
     * An immutable collection of key-value pairs implemented as a singly-linked list.
     *
     * Build up a collection by starting with [EmptyTags] and repeatedly calling [plus]. Each such call
     * returns a new instance.
     *
     * This collection is optimized for safe concurrent access over a very small number of elements.
     *
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Oct 24 11:37:46 UTC 2025
    - 3.9K bytes
    - Viewed (0)
  4. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AggregateFutureState.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 static com.google.common.collect.Sets.newHashSet;
    
    import java.util.Set;
    import org.jspecify.annotations.Nullable;
    
    /** Emulation of AggregateFutureState. */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  5. guava-tests/benchmark/com/google/common/base/StopwatchBenchmark.java

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package com.google.common.base;
    
    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    
    import com.google.caliper.Benchmark;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Simple benchmark: create, start, read. This does not currently report the most useful result
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 1.5K bytes
    - Viewed (0)
  6. fess-crawler/src/test/java/org/codelibs/fess/crawler/rule/RuleManagerTest.java

     */
    package org.codelibs.fess.crawler.rule;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.CopyOnWriteArrayList;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.atomic.AtomicInteger;
    
    import org.codelibs.fess.crawler.entity.ResponseData;
    import org.codelibs.fess.crawler.processor.ResponseProcessor;
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 23.8K bytes
    - Viewed (0)
  7. guava-testlib/src/module-info.java

      exports com.google.common.collect.testing.google;
      exports com.google.common.collect.testing.testers;
      exports com.google.common.escape.testing;
      exports com.google.common.testing;
      exports com.google.common.util.concurrent.testing;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Apr 01 21:16:20 UTC 2025
    - 1.2K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/helper/PopularWordHelper.java

    package org.codelibs.fess.helper;
    
    import static org.codelibs.core.stream.StreamUtil.stream;
    
    import java.util.ArrayList;
    import java.util.Collections;
    import java.util.List;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.TimeUnit;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  9. android/guava-testlib/src/com/google/common/collect/testing/testers/CollectionAddAllTester.java

       * figure out what to do with <a
       * href="https://github.com/openjdk/jdk/blob/c25c4896ad9ef031e3cddec493aef66ff87c48a7/src/java.base/share/classes/java/util/concurrent/ConcurrentHashMap.java#L4830">{@code
       * ConcurrentHashMap} support for {@code entrySet().add()}</a>.
       */
      @J2ktIncompatible
      @GwtIncompatible // reflection
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  10. src/main/java/jcifs/internal/smb2/rdma/RdmaBufferManager.java

     */
    package jcifs.internal.smb2.rdma;
    
    import java.io.IOException;
    import java.nio.ByteBuffer;
    import java.util.EnumSet;
    import java.util.concurrent.ConcurrentLinkedQueue;
    import java.util.concurrent.atomic.AtomicLong;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    /**
     * RDMA buffer manager for efficient memory region pooling.
     *
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 8.7K bytes
    - Viewed (0)
Back to top