- Sort Score
- Result 10 results
- Languages All
Results 491 - 500 of 1,082 for concurrents (0.84 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)