Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 401 - 410 of 848 for concurrence (0.3 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  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;
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 22K bytes
    - Click Count (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 {
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 31.6K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

    import java.io.InterruptedIOException
    import java.util.concurrent.TimeUnit
    import okhttp3.Headers
    import okhttp3.internal.EMPTY_BYTE_ARRAY
    import okhttp3.internal.closeQuietly
    import okhttp3.internal.concurrent.Lockable
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.concurrent.assertLockNotHeld
    import okhttp3.internal.concurrent.notifyAll
    import okhttp3.internal.concurrent.wait
    import okhttp3.internal.concurrent.withLock
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 31.8K bytes
    - Click Count (0)
  4. 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.
     *
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Oct 24 11:37:46 GMT 2025
    - 3.9K bytes
    - Click Count (0)
  5. 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. */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 1.7K bytes
    - Click Count (0)
  6. 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
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Aug 11 19:31:30 GMT 2025
    - 1.5K bytes
    - Click Count (0)
  7. 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;
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sat Sep 06 04:15:37 GMT 2025
    - 23.8K bytes
    - Click Count (0)
  8. 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.
     *
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 8.7K bytes
    - Click Count (0)
  9. samples/guide/src/main/java/okhttp3/recipes/PrintEvents.java

     */
    package okhttp3.recipes;
    
    import java.io.IOException;
    import java.net.InetAddress;
    import java.net.InetSocketAddress;
    import java.net.Proxy;
    import java.util.List;
    import java.util.concurrent.atomic.AtomicLong;
    import okhttp3.Call;
    import okhttp3.Callback;
    import okhttp3.Connection;
    import okhttp3.EventListener;
    import okhttp3.Handshake;
    import okhttp3.HttpUrl;
    import okhttp3.OkHttpClient;
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Feb 16 23:20:49 GMT 2020
    - 6.1K bytes
    - Click Count (0)
  10. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildPlanLogger.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 javax.inject.Named;
    
    import java.util.Comparator;
    import java.util.HashSet;
    import java.util.List;
    import java.util.Map;
    import java.util.Optional;
    import java.util.Set;
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Sun Mar 30 23:08:36 GMT 2025
    - 7.1K bytes
    - Click Count (0)
Back to Top