- Sort Score
- Result 10 results
- Languages All
Results 511 - 520 of 898 for Concurrent (0.09 sec)
-
src/test/java/org/codelibs/fess/query/QueryProcessorTest.java
* either express or implied. See the License for the specific language * governing permissions and limitations under the License. */ package org.codelibs.fess.query; import java.util.concurrent.atomic.AtomicBoolean; import org.apache.lucene.search.MatchAllDocsQuery; import org.apache.lucene.search.Query; import org.codelibs.fess.entity.QueryContext; import org.codelibs.fess.query.QueryProcessor.FilterChain;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 3.5K bytes - Viewed (0) -
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) -
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) -
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) -
src/test/java/org/codelibs/fess/job/ExecJobTest.java
import java.io.FileOutputStream; import java.io.IOException; import java.nio.file.Files; import java.util.ArrayList; import java.util.List; import java.util.Properties; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; import java.util.regex.Pattern; import org.apache.commons.io.FileUtils; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.timer.TimeoutManager;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 24.5K bytes - Viewed (0) -
cmd/peer-rest-common.go
peerRESTIsGroup = "is-group" peerRESTSignal = "signal" peerRESTSubSys = "sub-sys" peerRESTProfiler = "profiler" peerRESTSize = "size" peerRESTConcurrent = "concurrent" peerRESTDuration = "duration" peerRESTStorageClass = "storage-class" peerRESTEnableSha256 = "enableSha256" peerRESTEnableMultipart = "enableMultipart" peerRESTAccessKey = "access-key"
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 3K bytes - Viewed (0) -
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) -
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) -
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) -
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)