- Sort Score
- Num 10 results
- Language All
Results 401 - 410 of 848 for concurrence (0.3 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)